AWS Lambda和承诺：未调用回调

Question

我假设我在诺言方面缺乏一些基本知识。我有一个在AWS Lambda内的流程，该流程下载三个文件，然后生成通过电子邮件发送的输出。module.exports.test = async (event) => {   var p = download1();   var c = download2();   var h = download3();   await Promise.all([p, c, h]).then(() => {     ... bunch of logic manipulating the data     customers.forEach(i => {       buildFile().then(data => {         sendEmail(data).then(response => {            console.log('Email sent successfully');         });       });     });   }, errHandler);};buildFile和sendEmail函数都返回Promise，但是我从没收到“电子邮件已成功发送”消息。它运行代码，但实际上不会在Lambda完成之前返回（至少我认为这是正在发生的事情）。我的理解是Promise将完成回调，但是现在我想我需要做的事情与在原始Promise.all（）中进行下载的方式类似。那是正确的方向吗？该过程应获取文件，然后遍历客户以创建每个文件并通过SES发送。

Answer 1

您正在寻找

module.exports.test = async (event) => {

  var p = download1();

  var c = download2();

  var h = download3();

  try {

    await Promise.all([p, c, h]);

    // ... bunch of logic manipulating the data

    var promises = customers.map(async (i) => {

      var data = await buildFile();

      var response = await sendEmail(data);

      console.log('Email sent successfully');

    });

    await Promise.all(promises);

  } catch(e) {

    errHandler(e);

  }

};

您的test函数没有等待您在forEach循环中创建的promise ，因此lambda在完成所有操作之前就完成了。

Answer 2

我想稍微扩展一下，并为您提供一些资源以增加或增强您的Promises知识。我将使用下一个代码段，这有点麻烦，因为我在代码段上编写了代码，Google Chrome因此可以随意将其粘贴并使用它：

(function() {

    const promise1 = new Promise(function(resolve, reject) {

        setTimeout(function() {

            resolve('Replicant');

        }, 300);

    });

    const promise2 = new Promise(function(resolve, reject) {

        setTimeout(function() {

            resolve('Human?');

        }, 300);

    });

    function buildFile(type) {

        return new Promise((resolve, reject) => {

            setTimeout(() => {

                resolve(`${type}`);

            }, 300);

        });

    }

    function sendMail(customer, answer) {

        return new Promise((resolve, reject) => {

            setTimeout(() => {

                resolve(`Sent test to: ${customer}, he/she is a ${answer}`);

            }, 300);

        });

    }

    let customers = ['Rob Batty', 'Rachel', 'Deckard'];

    async function myFunc() {

        const [a, b, c] = await Promise.all([promise1, promise1, promise2]);

        const answers = [a, b, c];

//         const promises = customers.map(async (name, index) => {

//             const file = await buildFile(answers[index]);

//             const mail = await sendMail(name, file);

//             console.log(mail);

//         });

        const promises = customers.map((name, index) => {

            buildFile(answers[index])

                .then(file => sendMail(name, file))

                .then(sent => console.log(sent))

                // If you're going to use Promises this is important! :D

                .catch(err => console.log(err))

        });

        const [m1, m2, m3] = await Promise.all(promises);

        console.log(m1, m2, m3);

    }

    myFunc();

})()

正如答案中指出的那样，问题与的使用有关forEach，为什么呢？好吧，仅因为您是asynchronous在一种synchronous方法上执行代码，所以相处的不是很好:)，因此，解决方案是创建一个Arrayof Promises，如a Factory。后map功能Promises是Pending也不Fullfiled或Rejected当你调用它的Promise.all()方法，你等待他们的结果，他们给你的价值观或你的使用情况，生成该文件，然后将电子邮件发送给用户。我希望这可以帮助您更好地了解其Promises工作原理。最后，我将留下两个非常重要的链接，至少对我来说，这在一定程度上帮助了我Promises。干杯，sigfried。