回滚后向前滚动到 KCL 3.x - Amazon Kinesis Data Streams
步骤 1：运行KCL迁移工具 第 2 步：使用 KCL 3.x 部署代码

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

回滚后向前滚动到 KCL 3.x

本主题说明了在回滚后将使用器回滚到 KCL 3.x 的步骤。当你需要向前滚动时，你必须经历两个步骤的过程：

  1. 运行KCL迁移工具。

  2. 使用 KCL 3.x 部署代码。

步骤 1：运行KCL迁移工具

运行KCL迁移工具。KCL迁移工具使用以下命令向前滚动到 KCL 3.x：

python3 ./KclMigrationTool.py --region <region> --mode rollforward [--application_name <applicationName>] [--coordinator_state_table_name <coordinatorStateTableName>]

参数

  • --region：<region>替换为你的。 AWS 区域

  • --application_name：如果您使用协调器状态表的默认名称，则此参数是必填的。如果您为协调器状态表指定了自定义名称，则可以省略此参数。<applicationName>替换为实际的KCL应用程序名称。如果未提供自定义名称，则该工具将使用此名称派生默认表名。

  • --coderator_state_table_name（可选）：当您在配置中为协调器状态表设置了自定义名称时，需要此参数。KCL如果您使用的是默认表名，则可以省略此参数。<coordinatorStateTableName>替换为您为协调器状态表指定的自定义表名。

在前滚模式下运行迁移工具后，将KCL创建 3.x 所需的以下 DynamoDB 资源：KCL

  • 租赁表上的全球二级索引

  • 工作人员指标表

第 2 步：使用 KCL 3.x 部署代码

运行KCL迁移工具进行向前滚动后，将使用 KCL 3.x 版本的代码部署到工作线程中。请步骤 8：完成迁移按照以下步骤完成迁移。