0

我是使用实时应用程序的新手。目前，我正在使用 AWS Kinesis/Flink 和 Scala 我有以下架构：

旧建筑

如您所见，我使用 CSVTableSource 使用 CSV 文件。不幸的是，CSV 文件对于 Flink 作业来说太大了。该文件每天更新​​，然后添加新行。所以，现在我在一个新架构中工作，我想用 CSV 替换 DynamoDB。

新架构

我的问题是：你推荐什么来使用 DynamoDB 表？

PD：我需要使用 DynamoDB 表和 Kinesis Data Stream 数据进行左外连接

4

0 回答 0