在 Amazon Keyspaces 中访问 CDC 直播中的记录 - Amazon Keyspaces（Apache Cassandra 兼容）

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

在 Amazon Keyspaces 中访问 CDC 直播中的记录

要访问直播中的记录，您可以使用 Amazon Keyspaces St reams API。以下部分包含有关如何使用访问记录的示例 AWS CLI。

有关所需的权限，请参阅在 Amazon Keyspaces 中配置使用 CDC 流的权限。

使用访问直播中的记录 AWS CLI

  1. 您可以使用 Amazon Keyspaces Streams API 访问直播的更改记录。有关更多信息，请参阅 Amazon Keyspaces Streams Streams API 参考。要检索流中的分片，你可以使用 get-stream API，如以下示例所示。

    aws keyspacesstreams get-stream \
--stream-arn 'arn:aws:cassandra:aws-region:111122223333:/keyspace/mykeyspace/table/mytable/stream/STREAM_LABEL'

    下面是输出的一个示例。

    {
   "StreamArn": "arn:aws:cassandra:aws-region:111122223333:/keyspace/mykeyspace/table/mytable/stream/2023-05-11T21:21:33.291",
   "StreamStatus": "ENABLED",
   "StreamViewType": "NEW_AND_OLD_IMAGES",
   "CreationRequestDateTime": "<CREATION_TIME>",
   "KeyspaceName": "mykeyspace",
   "TableName": "mytable",
   "StreamLabel": "2023-05-11T21:21:33.291",
    "Shards": [
        {
            "SequenceNumberRange": {
                "EndingSequenceNumber": "<END_SEQUENCE_NUMBER>",
                "StartingSequenceNumber": "<START_SEQUENCE_NUMBER>"
            },
            "ShardId": "<SHARD_ID>"
        },
    ]
}

  2. 要从流中检索记录，首先要获取一个迭代器，该迭代器为你提供了访问记录的起点。为此，您可以使用上一步中 API 返回的 CDC 流中的分片。要收集迭代器，可以使用 get-shard-iterator API。在此示例中，您使用类型的迭代器，TRIM_HORIZON该迭代器从分片的最后一个修剪点（或起点）进行检索。

    aws keyspacesstreams get-shard-iterator \
--stream-arn 'arn:aws:cassandra:aws-region:111122223333:/keyspace/mykeyspace/table/mytable/stream/STREAM_LABEL' \
--shard-id 'SHARD_ID' \
--shard-iterator-type 'TRIM_HORIZON'

    该命令的输出如下例所示。

    {
    "ShardIterator": "<SHARD_ITERATOR>" 
}

  3. 要使用 get-records API 检索 CDC 记录，您可以使用上一步返回的迭代器。下面是一个命令示例。

    aws keyspacesstreams get-records \
--shard-iterator 'SHARD_ITERATOR' \
--limit 100