AWS Lambda提前终止问题求助：Node.js异步调用未完成即结束

你碰到的问题本质是异步操作没有被正确等待：Lambda的异步Handler函数会在所有通过await等待的Promise完成后才终止，但你在forEach里调用的checkIfUpdateRequired是异步函数，forEach本身不会等待这些异步操作完成——相当于只是触发了一堆异步请求，主函数扫完DynamoDB后就直接结束了，Lambda自然会在这些请求完成前终止进程。

另外你的代码里还有个小问题：async函数里混用了await和.then()，虽然语法上没问题，但会让代码逻辑更混乱，建议统一用await风格。

核心是把所有异步操作的Promise收集起来，用Promise.all()等待它们全部完成。具体修改如下：

修改后的完整代码 #

exports.handle = async function(event, context) { 
  var AWS = require("aws-sdk"); 
  AWS.config.update({ 
    region: "eu-west-1", 
    endpoint: "dynamodb.eu-west-1.amazonaws.com" 
  }); 
  var docClient = new AWS.DynamoDB.DocumentClient(); 

  console.log("Scanning Catalogue..."); 
  var params = { TableName : "Catalogue" }; 
  // 直接await获取扫描结果，不用.then()
  const data = await docClient.scan(params).promise();
  console.log("Scan succeeded."); 

  // 用map把每个item转换成Promise，再用Promise.all等待所有完成
  await Promise.all(data.Items.map(item => checkIfUpdateRequired(item)));
} 

async function checkIfUpdateRequired (catalogueItem) { 
  var request = require("request-promise"); 
  console.log("Getting " + catalogueItem.url); 
  // 直接await请求结果，不用.then()
  const response = await request(catalogueItem.url);
  console.log(response.statusCode); 
  console.log(response.headers['content-type']); 
} 

关键修改点说明 #

1. 替换forEach为map+Promise.all：

   • forEach会遍历数组但忽略异步函数的返回值（Promise），而map会把每个checkIfUpdateRequired(item)调用转换成一个Promise，生成一个Promise数组。
   • await Promise.all(...)会让主函数暂停，直到数组里所有的Promise都执行完成，这样Lambda就不会提前终止了。

2. 统一使用await替代.then()：

   • 去掉了扫描DynamoDB后的.then()回调，直接用await获取结果，代码逻辑更线性易读。
   • checkIfUpdateRequired里也直接await request，然后处理返回的response，避免嵌套回调。

• 并发控制：如果你的Catalogue表有大量数据，Promise.all会同时发起所有HTTP请求，可能触发目标服务器的限流，或者Lambda的并发限制。这种情况下可以考虑用分批处理（比如用for...of循环逐个await，或者引入p-limit这类库控制并发数）。
• 错误处理：建议给异步操作加上try/catch块，比如扫描DynamoDB失败、请求URL失败的情况，避免未处理的Promise rejection导致Lambda报错：

  exports.handle = async function(event, context) { 
    try {
      // 原代码逻辑
    } catch (err) {
      console.error("操作失败:", err);
      throw err; // 抛出错误让Lambda标记请求失败
    }
  }
  

内容的提问来源于stack exchange，提问作者creature124