Accédez aux enregistrements des flux CDC sur Amazon Keyspaces

Accédez aux enregistrements d'un flux à l'aide du AWS CLI

1. Vous pouvez utiliser l'API Amazon Keyspaces Streams pour accéder aux enregistrements de modifications du flux. Pour plus d'informations, consultez le manuel de référence de l'API Amazon Keyspaces Streams. Pour récupérer les fragments contenus dans le flux, vous pouvez utiliser l'get-streamAPI comme indiqué dans l'exemple suivant.

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

   Voici un exemple de la sortie.

   {
      "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. Pour récupérer des enregistrements du flux, vous devez commencer par obtenir un itérateur qui vous fournit le point de départ pour accéder aux enregistrements. Pour ce faire, vous pouvez utiliser les fragments contenus dans le flux CDC renvoyé par l'API à l'étape précédente. Pour rassembler l'itérateur, vous pouvez utiliser l'get-shard-iteratorAPI. Dans cet exemple, vous utilisez un itérateur de type TRIM_HORIZON qui extrait à partir du dernier point découpé (ou début) de la partition.

   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'

   Le résultat de la commande ressemble à celui de l'exemple suivant.

   {
       "ShardIterator": "<SHARD_ITERATOR>" 
   }

3. Pour récupérer les enregistrements CDC à l'aide de l'get-recordsAPI, vous pouvez utiliser l'itérateur renvoyé à la dernière étape. La commande suivante en est un exemple.

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