如何将数据从Kinesis data Analytics写入DynamoDB



我正在将kineesis数据流的实时数据流式传输到kineesis数据分析中,我想将转换后的数据发送到dynamoDB中。目前可以通过将转换后的数据发送到另一个流来完成,该流将触发lambdas写入dynamoDB。

但我想知道是否有一种方法可以直接从kinesis数据分析调用lambda ?

Apache Flink官方没有为Dynamo DB提供任何sink连接器。要么必须构建自己的sink连接器,要么使用一些非官方的连接器。你可以试试下面这个

Flink连接器Dynamodb

最新更新