使用 Lambda 设置 DynamoDB 触发器

Question

我正在尝试使用 DynamoDB Streams 和 AWS Lambda 创建一个 DynamoDB 触发器。我研究了很多，但找不到任何方法来读取和处理 Java 8 中的 DynamoDB Stream 事件。我对这两种技术都是全新的，所以不知道如何使用它。

本质上，我想做的是每当在表 A 中创建记录时，在表 B 中创建一条记录。

你们中的任何人都可以指点我在 Java 中处理此用例的代码或帖子吗？

谢谢 ：）

Answer 1

这段代码对我有用。您可以使用它在 Lambda 函数中接收和处理 DynamoDB 事件 -

public class Handler implements RequestHandler<DynamodbEvent, Void> {

    @Override
    public Void handleRequest(DynamodbEvent dynamodbEvent, Context context) {

        for (DynamodbStreamRecord record : dynamodbEvent.getRecords()) {

            if (record == null) {
                continue;
            }

            // Your code here
            // Write to Table B using DynamoDB Java API
        }

        return null;
    }
}

创建 Lambda 时，将表 A 中的流添加为事件源，然后一切顺利