如何将DynamoDB用作AWS数据分析应用程序（Flink）的接收器？我没有找到示例或现有的DynamoDB Sink实现类。
igsr9ssn1#
Apache Flink社区正在努力解决这个问题。这是相关的PR。
fd3cxomn2#
Flink没有正式的DynamoDB连接器。但是，也有各种第三方服务，例如https://github.com/klarna-incubator/flink-connector-dynamodb或者https://github.com/fabricalab/streaming-flink-dynamodb-connector我强烈建议您测试任何第三方连接器，以确保它们已准备好生产并满足您的需求。
2条答案
按热度按时间igsr9ssn1#
Apache Flink社区正在努力解决这个问题。这是相关的PR。
fd3cxomn2#
Flink没有正式的DynamoDB连接器。
但是，也有各种第三方服务，例如
https://github.com/klarna-incubator/flink-connector-dynamodb
或者
https://github.com/fabricalab/streaming-flink-dynamodb-connector
我强烈建议您测试任何第三方连接器，以确保它们已准备好生产并满足您的需求。