amazon-web-services - 使用 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 SDK 文档的链接:

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

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