使用AWS Lambda函数写入Kinesis流

Question

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

Answer 1

是.您可以创建由Lambda函数支持的Dynamo Trigger,并将该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

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