使用Lambda设置DynamoDB触发器

Question

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

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

你们谁能给我指出一个在Java中处理这个用例的代码或帖子吗？

谢谢：）

Answer 1

DynamoDB Streams会将JSON发送到处理程序。只需创建一个处理程序，它接受JavaInputStream并从inputstream反序列化JSON。我在这里发布了一个类似问题的示例。

Answer 2

嗯，我似乎找不到将JavaLambda函数与DynamoDB流集成的留档，但其概念与使用DDB流编写NodeJS Lambda函数相同，此处记录了这一点：http://docs.aws.amazon.com/lambda/latest/dg/wt-ddb.html.只需将NodeJS函数替换为Java函数（请参阅此处的文档以创建JavaLambda函数：http://docs.aws.amazon.com/lambda/latest/dg/java-lambda.html）。要将数据从表A复制到B，您可以使用AWSJavaSDK DynamoClient DB在Lambda函数中将流记录从A写入B。

Answer 3

这段代码对我很有用。你可以用它在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中的流添加为事件源，就可以开始了