使用AWS Lambda函数写入Kinesis流

Question

7

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

- AKSHAY SHINGOTE

1

欢迎来到StackOverflow。请先查看StackOverflow有关提问的帮助文档。重点关注如何提出好问题和如何创建一个最小、完整且可验证的示例，但其他帮助主题也会很有用。 - David Ferenczy Rogožan

如果您想找到有关此问题的解决方案，请访问由Terraform创建的示例存储库：https://github.com/gnokoheat/aws-serverless-data-pipeline-by-terraform。 - GNOKOHEAT

2个回答

1

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

当我们向Dynamo DB表中写入记录并将该记录写入Kinesis流时，

- Sachin Kariyattin

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Scott Wisniewski · Accepted Answer

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

以下是一篇教程，展示如何创建一个触发器：

在Lambda函数的主体中，您可以调用Kinesis的"putRecord"函数。以下是有关"putRecord"的信息：

如果您正在使用Node.js实现Lambda函数，则以下链接为Kinesis SDK文档：

类似地，如果您正在使用Java，则以下是Java SDK的链接：

如果您使用Python，则以下是Boto文件的链接：

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