我正在将带有kinesis数据流的实时数据流传输到kinesis数据分析中,我希望将转换后的数据发送到dynamoDB中。目前,可以通过将转换后的数据发送到另一个流中来完成,该流将触发lambda写入dynamoDB。但是我想知道是否有一种方法可以直接从kinesis数据分析中调用lambda?
bwleehnv1#
Apache Flink官方不提供Dynamo DB的sink连接器。您必须建立自己的sink连接器或使用一些非官方的连接器。您可以尝试以下连接器-Flink connector Dynamodb
Apache Flink
Dynamo DB
sink
1条答案
按热度按时间bwleehnv1#
Apache Flink
官方不提供Dynamo DB
的sink
连接器。您必须建立自己的sink
连接器或使用一些非官方的连接器。您可以尝试以下连接器-Flink connector Dynamodb