AWS SQS Node.js 脚本不等待

Question

尝试发送多条消息（来自 AWS SQS lambda，如果这很重要），但它从不等待承诺。

function getEndpoint(settings){
    return new Promise(function(resolve, reject) { 
    // [...] more stuff here
}

然后循环调用：

exports.handler = async (event) => {
    var messages = [];
    event.Records.forEach(function(messageId, body) {
        //options object created from some stuff
        messages.push(getEndpoint(options).then(function(response){
            console.log("anything at all"); //NEVER LOGGED
        }));
    });
    await Promise.all(messages);
};

但是 await 似乎完全被跳过了。我不确定我是如何通过明确的await 获得Process exited before completing request 的。我在其他有效的脚本中有类似的异步等待/承诺设置，但无法发现我在这个脚本中做错了什么。

Answer 1

你忘了给 lambda 返回一些东西：

exports.handler = async (event) => {
    var messages = [];
    event.Records.forEach(function(messageId, body) {
        //options object created from some stuff
        messages.push(getEndpoint(options));
    });
    await Promise.all(messages);
    return 'OK'
};

这也应该有效：

exports.handler = (event) => { // async is not mandatory here
    var messages = [];
    event.Records.forEach(function(messageId, body) {
        //options object created from some stuff
        messages.push(getEndpoint(options));
    });
    return Promise.all(messages); // returning a promise
};

你可以使用地图：

exports.handler = (event) => { // async is not mandatory here
    const messages = event.Records.map(function(messageId, body) {
        //options object created from some stuff
        return getEndpoint(options)
    });
    return Promise.all(messages); // returning a promise
};

要了解为什么会发生这种情况，您必须深入了解 lambda 的实现：它本质上会等待函数堆栈被清除，并且由于您根本没有返回任何内容，因此函数堆栈在排队后立即为空所有的东西 - 在 await 调用之后添加一个简单的 return 会使 fn 堆栈不为空，这意味着 lambda 将等待它完成。

如果你在标准节点上运行它，你的函数也会在承诺完成之前返回，但你的节点进程在堆栈被清除之前不会退出。这是 lambda 与股票节点不同的地方。