使用 DynamoDB Streams Kinesis Adapter 处理流记录

使用 Amazon Kinesis Adapter 是使用来自 Amazon DynamoDB 的流的建议方法。DynamoDB Streams API 有意与 Kinesis Data Streams 相似，这是一种用于实时处理大规模流数据的服务。在这两种服务中，数据流都由分片组成，分片是流记录的容器。这两种服务的 API 都包含 ListStreams、DescribeStream、GetShards 和 GetShardIterator 操作。（虽然这些 DynamoDB Streams 操作与 Kinesis Data Streams 中的对应操作类似，但它们并不完全相同。）

您可以使用 Kinesis 客户端库 (KCL) 为 Kinesis Data Streams 编写应用程序。KCL 提供低级 Kinesis Data Streams API 之上的有用抽象来简化编码。有关 KCL 的更多信息，请参阅 Amazon Kinesis Data Streams 开发人员指南中的使用 Kinesis 客户端库开发使用者。

作为 DynamoDB Streams 用户，您可以使用 KCL 中找到的设计模式来处理 DynamoDB Streams 分片和流记录。若要执行此操作，请使用 DynamoDB Streams Kinesis Adapter。Kinesis Adapter 实现 Kinesis Data Streams 接口，以便 KCL 可用于使用和处理来自 DynamoDB Streams 的记录。有关如何设置和安装 DynamoDB Streams Kinesis 适配器的说明，请参阅存储库。GitHub

下图表显示了这些库之间的交互方式。

有了 DynamoDB Streams Kinesis Adapter，您可以开始针对 KCL 接口进行开发，使 API 调用无缝定向到 DynamoDB Streams 终端节点。

应用程序启动后，调用 KCL 来实例化工作进程。您必须向工作人员提供应用程序的配置信息，例如流描述符和 Amazon 凭证，以及您提供的记录处理器类的名称。在记录处理器中运行代码时，工作进程执行以下任务：