求助：通过Lambda将DynamoDB最新条目同步至另一DynamoDB表

看起来你已经走对了关键步骤——用DynamoDB流触发器绑定Lambda，现在只需要把流传递的变更数据同步到目标表就行。下面是完整的实现方案和代码：

核心思路 #

DynamoDB流会把每条变更的新数据快照（也就是NewImage字段）传给Lambda的event参数，我们要做的就是遍历这些记录，把快照里的内容直接写入目标表。

完整Lambda代码 #

'use strict';
console.log('Loading function');

// 引入AWS SDK的DocumentClient（自动处理DynamoDB类型格式）
const AWS = require('aws-sdk');
const dynamodb = new AWS.DynamoDB.DocumentClient();

// 替换成你的目标表名称
const TARGET_TABLE = 'your-target-table-name';

exports.handler = async (event, context) => {
    try {
        // 遍历触发器传来的每条变更记录
        for (const record of event.Records) {
            // 可以根据需求过滤事件类型，比如只同步新增或更新的条目
            if (['INSERT', 'MODIFY'].includes(record.eventName)) {
                // 提取变更后的新数据（DocumentClient会自动把DynamoDB格式转成普通JSON）
                const newItem = record.dynamodb.NewImage;
                
                // 写入目标表
                await dynamodb.put({
                    TableName: TARGET_TABLE,
                    Item: newItem
                }).promise();
                
                console.log(`成功复制条目: ${JSON.stringify(newItem)}`);
            }
        }
        return {
            statusCode: 200,
            body: '条目复制完成'
        };
    } catch (error) {
        console.error('复制条目出错:', error);
        throw error; // 抛出错误触发Lambda重试（可根据需求调整重试策略）
    }
};

关键细节提醒 #

• SDK选择：用DocumentClient而非原始DynamoDB客户端，它会自动处理DynamoDB的类型标记（比如S代表字符串、N代表数字），不用手动转换格式，大幅简化代码。
• 事件过滤：通过record.eventName可以精准控制要同步的操作——如果只需要新增条目就保留INSERT，要同步更新就加上MODIFY，不需要删除同步就忽略REMOVE。
• 权限配置：别忘给Lambda的IAM角色加权限：
  • 原表的流读取权限（触发器配置时一般会自动添加）
  • 目标表的dynamodb:PutItem权限
• 测试方法：替换目标表名后，在原表插入一条测试数据，去Lambda日志里看是否有成功复制的记录，再检查目标表是否出现对应条目。

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