for每个未在lambda函数内部运行

Question

我有一个Node.js AWS Lamba函数，该函数执行数据库调用，然后接受并将数据库调用的结果分成不同的SQS消息。目前，随着Lambda跳过所有内容，这似乎已被打破，当我添加await（如下所示）时，它告诉我我不能对sendMessage部分使用await。

module.exports.companyID = async (event, context, callback) => {
    context.callbackWaitsForEmptyEventLoop = false;
    if (inter_conn == null) {
        inter_conn = await mongoose.createConnection(incident_Mongo_URI, {
            bufferCommands: false, // Disable mongoose buffering
            bufferMaxEntries: 0, // and MongoDB driver buffering
            useNewUrlParser: true // Required or it gives me an error
        });
    }

    const I = inter_conn.model('Incident');
    await I.find().distinct('companyID').exec(function(err, results) {
        if(err) {
            logger.error(`Inter Cleanup: Find: Error message: ${JSON.stringify(err)}`);
            process.exit(1);
        }
        logger.info(results)
        results.forEach(companyID => {
            let params = {
                MessageBody: companyID,
                QueueUrl: process.env.incidentsQueue,
                DelaySeconds: 0
            };

            let sendMessage = sqs.sendMessage(params).promise();

            await sendMessage.then((data) => {
                logger.info(data)
            })
            .catch((err) => {
                logger.error(err)
            })
        }); 
    })

    let output = {
        status: 'Done'
    }
    callback(null, output);
};

从Lambda控制台看到的错误消息

{
  "errorType": "Runtime.UserCodeSyntaxError",
  "errorMessage": "SyntaxError: await is only valid in async function",
  "trace": [
    "Runtime.UserCodeSyntaxError: SyntaxError: await is only valid in async function",
    "    at _loadUserApp (/var/runtime/UserFunction.js:98:13)",
    "    at Object.module.exports.load (/var/runtime/UserFunction.js:140:17)",
    "    at Object.<anonymous> (/var/runtime/index.js:45:30)",
    "    at Module._compile (internal/modules/cjs/loader.js:778:30)",
    "    at Object.Module._extensions..js (internal/modules/cjs/loader.js:789:10)",
    "    at Module.load (internal/modules/cjs/loader.js:653:32)",
    "    at tryModuleLoad (internal/modules/cjs/loader.js:593:12)",
    "    at Function.Module._load (internal/modules/cjs/loader.js:585:3)",
    "    at Function.Module.runMain (internal/modules/cjs/loader.js:831:12)",
    "    at startup (internal/bootstrap/node.js:283:19)"
  ]
}

我已经测试了此代码的基本代码，而没有与lambda相关的内容，并且JS文件中的async / await作为脚本运行，并且运行良好。

我知道问题在于将其转换为lambda，并且与Lambda处于异步/等待状态有关。

我如何做到这一点，以便我的Lambda进行数据库调用并运行forEach，将结果数组中的每个项目放入SQS消息中？

Answer 1

您收到的错误是因为您试图将await内的forEach而不是async。但是，不要以为您也可以使用async函数。

最佳解决方案是停止使用.forEach，而使用更现代的for/of。您的for循环如下所示：

        for (let companyID of results) {
            let params = {
                MessageBody: companyID,
                QueueUrl: process.env.incidentsQueue,
                DelaySeconds: 0
            };

            try {
                const data = await sqs.sendMessage(params).promise();

                logger.info(data)
            }
            catch (err) {
                logger.error(err);
            }
        }

NOTE，我也更改了对sendMessage的调用以使用适当的等待。