Acceda a los registros de las transmisiones de los CDC en Amazon Keyspaces

Para acceder a los registros de una transmisión, utilice la API Amazon Keyspaces Streams. La siguiente sección contiene ejemplos sobre cómo acceder a los registros mediante. AWS CLI

Para conocer los permisos necesarios, consulte Configure los permisos para trabajar con las transmisiones de los CDC en Amazon Keyspaces.

Acceda a los registros de una transmisión mediante el AWS CLI

1. Puede utilizar la API Amazon Keyspaces Streams para acceder a los registros de cambios de la transmisión. Para obtener más información, consulte la referencia de la API de Amazon Keyspaces Streams. Para recuperar los fragmentos de la transmisión, puede utilizar la get-stream API, tal y como se muestra en el siguiente ejemplo.

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

   A continuación se muestra un ejemplo de la salida.

   {
      "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 de la transmisión, comience por obtener un iterador que le proporcione el punto de partida para acceder a los registros. Para ello, puedes usar los fragmentos de la transmisión de CDC devueltos por la API en el paso anterior. Para recopilar el iterador, puedes usar la get-shard-iterator API. Para este ejemplo, se utiliza un iterador del tipo TRIM_HORIZON que recupera datos del último punto recortado (o principio) del 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'

   El resultado del comando es similar al del siguiente ejemplo.

   {
       "ShardIterator": "<SHARD_ITERATOR>" 
   }

3. Para recuperar los registros de los CDC mediante la get-records API, puede utilizar el iterador devuelto en el último paso. El siguiente comando es un ejemplo de esto.

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