如何在AWS Lambda中等待forEach循环完成后再执行return语句？

这个问题很常见——forEach本身并不支持异步等待，它会同步遍历数组，但不会等待里面的异步操作（比如你的axios.post）完成，所以你的Lambda函数会直接跳过这些请求，提前返回响应。咱们来一步步修复它：

核心修改思路 #

• 把forEach替换成map：map会遍历数组并返回每个异步操作的Promise对象，形成一个Promise数组
• 使用await Promise.all()等待所有Promise完成：这个方法会等待数组里所有异步操作都成功完成后，才继续执行后续代码

修改后的完整代码 #

// 最佳实践：把依赖引入放在函数外部，Lambda会缓存这些依赖，提升性能
const axios = require("axios");

module.exports.shipments = async (event) => { 
  try {
    let data = JSON.parse(event.body); 
    let url = data.apiURL + "/api/1.1/wf/bulkshipments/initialize"; 
    let patchURL = data.apiURL + "/api/1.1/obj/company/" + data.companyID; 

    // 用map生成Promise数组，然后用Promise.all等待所有请求完成
    const requestPromises = data.shipments.map((item) => { 
      return axios.post(url, { 
        batchID: data.batchID, 
        companyID: data.companyID, 
        shipment: item
      }); 
    });

    // 等待所有POST请求完成
    await Promise.all(requestPromises);

    return { 
      statusCode: 200, 
      body: JSON.stringify({ 
        message: 'Created successfully!', 
        totalShipments: data.shipments.length, 
      }, null, 2), 
    }; 
  } catch (error) {
    // 捕获错误并返回友好的错误响应，方便调试
    return {
      statusCode: 500,
      body: JSON.stringify({
        message: 'Failed to process shipments',
        error: error.message
      }, null, 2)
    };
  }
};

额外注意事项 #

• 错误处理：我加了try/catch块，这样如果某个请求失败，整个函数不会崩溃，而是返回500状态码和错误信息，便于排查问题
• 依赖位置：把axios的引入移到了函数外部，Lambda会在冷启动时缓存这个依赖，后续调用性能更好
• 并发控制：如果你的data.shipments数量很大，Promise.all会同时发起所有请求，可能触发API的限流。如果需要控制并发，可以用Promise.allSettled（不管成功失败都等待），或者用第三方库来限制并发数

内容的提问来源于stack exchange，提问作者Shawn C.