Lambda触发DynamoDB MODIFY事件更新无效果且无报错，求排查

你的代码主要存在两个核心问题，导致更新操作未执行且无相关日志输出：

1. 异步操作未被正确等待（Lambda提前终止） #

你的Lambda handler是async函数，但调用docClient.update时使用了回调模式，没有等待这个异步操作完成。Lambda的async函数会在执行到return response时直接结束，此时回调函数还没来得及执行——这就是为什么你看不到更新结果，也没有CloudWatch日志的原因（回调里的console.log还没运行，函数就已经终止了）。

AWS SDK for JavaScript v2的DocumentClient方法支持Promise化，你可以改用await来等待更新操作完成，确保Lambda在执行完所有异步逻辑后再返回。

2. 硬编码主键值（更新了错误的记录） #

你代码里的Key是固定的"student_id": 'abc_123'，而不是从触发MODIFY事件的record.dynamodb.NewImage中获取当前修改的学生ID。这意味着即使更新执行了，也只会修改这条固定ID的记录，而不是你触发修改的那条目标记录。

修正后的代码 #

var AWS = require('aws-sdk');
const docClient = new AWS.DynamoDB.DocumentClient();

exports.handler = async (event, context) => {
  // 使用for...of循环替代forEach，确保异步操作顺序执行并等待完成
  for (const record of event.Records) {
    console.log('Stream record: ', JSON.stringify(record, null, 2));
    
    if (record.eventName === 'MODIFY') {
      const newImage = record.dynamodb.NewImage;
      console.log("Printing new image values", JSON.stringify(newImage, null, 2));
      
      // 从NewImage中获取实际的student_id（根据表结构调整数据类型：字符串用S，数字用N）
      const studentId = newImage.student_id.S; 
      
      var params = {
        TableName: 'my-table name',
        Key: { "student_id": studentId },
        UpdateExpression: "set score1 = :r",
        ExpressionAttributeValues: { ":r": 88 },
        ReturnValues: "UPDATED_NEW"
      };
      
      console.log("Updating the item...");
      try {
        const data = await docClient.update(params).promise();
        console.log("UpdateItem succeeded:", JSON.stringify(data, null, 2));
      } catch (err) {
        console.error("Unable to update item. Error JSON:", JSON.stringify(err, null, 2));
        // 可根据需求在这里添加异常处理逻辑
      }
    }
  }

  console.log(event);
  const response = {
    statusCode: 200,
    body: JSON.stringify(event),
  };
  return response;
};

额外注意事项 #

• 数据类型匹配：代码中newImage.student_id.S假设student_id是字符串类型（DynamoDB的S类型），如果你的表中student_id是数字类型，需要改为newImage.student_id.N，并转换为数字（比如parseInt(newImage.student_id.N)）。
• 循环处理：用for...of替代forEach是因为forEach不会等待异步操作完成，会导致多个update同时触发，而for...of会逐个等待每个update完成，逻辑更可控。
• 权限验证：你已配置AmazonDynamoDBFullAccess和AWSLambdaDynamoDBExecutionRole，权限方面应该没问题，但可以确认Lambda的执行角色是否正确关联，若Lambda在VPC内，需确保VPC配置允许访问DynamoDB。

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