Lambda定时任务及控制台测试中DynamoDB Put不写入问题

看起来你遇到的核心问题是异步写入操作没有被正确等待，导致Lambda函数在数据写入DynamoDB之前就提前终止了——而本地环境的运行机制会等待所有异步任务完成，所以本地测试一切正常。

具体问题拆解 #

1. saveJob函数的异步逻辑未被正确处理：
   你的saveJob调用了dynamoDb.put().promise()，这会返回一个异步Promise，但函数本身既没有返回这个Promise，也没有用await等待写入完成。这意味着调用saveJob时，写入操作会在后台“悬空”，Lambda不会感知到它的存在。

2. forEach无法等待异步函数：
   Array.forEach是同步遍历方法，它不会等待每个saveJob的异步操作完成。当你的Lambda函数执行到return语句时，所有saveJob的写入请求可能还在排队，函数一旦结束，这些未完成的操作就会被直接中断。

修复步骤 #

1. 修正saveJob函数，确保它等待异步写入

修改saveJob.js，让它成为异步函数并显式等待DynamoDB操作完成：

// saveJob.js
module.exports = async (job) => {
  validateJob(job);
  // 等待DynamoDB写入操作完成
  await dynamoDb.put({
    TableName: tableName,
    Item: job,
  }).promise();
};

2. 用Promise.all替代forEach等待所有写入

在runModules函数中，通过map生成所有写入操作的Promise，再用Promise.all等待全部完成：

if (saveJobs) {
  // 用map生成所有异步任务的Promise，再统一等待完成
  await Promise.all(goodJobs.map(saveJob));
}

额外排查点 #

虽然本地运行正常，但还是建议确认：

• Lambda执行角色是否拥有dynamodb:PutItem权限（权限缺失会导致写入失败，通常会在CloudWatch日志中报错）
• 查看Lambda的CloudWatch日志，确认是否有DynamoDB相关的错误（比如表名错误、数据格式不合法等）

为什么本地运行正常？ #

本地执行serverless invoke local时，Node.js进程会等待所有异步任务完成后才会退出；而Lambda是事件驱动的，一旦函数的主Promise（runAggregator返回的Promise）resolve，Lambda就会立即终止执行，不会等待未处理的异步操作。

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