Acesse registros em streams do CDC no Amazon Keyspaces

Acesse registros em um stream usando o AWS CLI

1. Você pode usar a API Amazon Keyspaces Streams para acessar os registros de alterações do stream. Para obter mais informações, consulte Amazon Keyspaces Streams API Reference. Para recuperar os fragmentos no stream, você pode usar a get-stream API conforme mostrado no exemplo a seguir.

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

   A seguir, veja um exemplo de saída.

   {
      "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. Para recuperar registros do stream, você começa obtendo um iterador que fornece o ponto de partida para acessar os registros. Para fazer isso, você pode usar os fragmentos no stream do CDC retornado pela API na etapa anterior. Para reunir o iterador, você pode usar a get-shard-iterator API. Neste exemplo, você usa um iterador do tipo TRIM_HORIZON que recupera do último ponto recortado (ou início) do fragmento.

   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'

   A saída do comando se parece com o exemplo a seguir.

   {
       "ShardIterator": "<SHARD_ITERATOR>" 
   }

3. Para recuperar os registros do CDC usando a get-records API, você pode usar o iterador retornado na última etapa. O comando a seguir é um exemplo disso.

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