使用 AWS Lambda 函数写入 Kinesis 流

Question

我们能否创建一个 Lambda 函数，当我们将记录写入 Dynamo DB 表并将该记录写入 Kinesis 流时可以执行该函数？基本上我们可以使用 Lambda 函数写入 Kinesis 流吗？如果是，请分享示例代码..我也想知道它是如何工作的......谢谢

Answer 1

是的。您可以创建一个由 Lambda 函数支持的 Dynamo 触发器，并将该 Lambda 函数写入流。

下面是一个演示如何创建触发器的演练：

http://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Streams.Lambda.html

然后，您可以在 Lambda 函数的主体中调用 Kinesis“putRecord”函数。这是关于“putRecord”的信息：

http://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecord.html

如果您在 Node.js 中实现 Lambda 函数，这里是 Kinesis 开发工具包文档的链接：

http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/Kinesis.html#putRecord-property

同样，这里是 Java SDK 的链接（如果您使用的是 java）：

http://docs.aws.amazon.com/AWSJavaSDK/latest/javadoc/com/amazonaws/services/kinesis/AmazonKinesis.html#putRecord(com.amazonaws.services.kinesis.model.PutRecordRequest)

以及 Boto 文档的链接（如果您使用的是 python）：

http://boto.cloudhackers.com/en/latest/ref/kinesis.html

文档链接应该包含您需要的所有信息。

Answer 2

不回答问题，但更新问题部分的最新解决方案

当我们将记录写入 Dynamo DB 表并且该记录被写入 Kinesis 流时

您现在可以在 dynamo db 表上直接启用 Kinesis 流https://aws.amazon.com/about-aws/whats-new/2020/11/now-you-can-use-amazon-kinesis-data-streams-to-capture-item-level-changes-in-your-amazon-dynamodb-table/