Ative um stream do CDC ao criar uma nova tabela no Amazon Keyspaces - Amazon Keyspaces (para Apache Cassandra)

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Ative um stream do CDC ao criar uma nova tabela no Amazon Keyspaces

Para habilitar um stream CDC ao criar uma tabela, você pode usar a CREATE TABLE instrução em CQL ou o create-table comando com o. AWS CLI

Para cada linha alterada na tabela, o Amazon Keyspaces pode capturar as seguintes alterações com base nas view_type cdc_specification que você selecionar:

  • NEW_AND_OLD_IMAGES— ambas as versões da linha, antes e depois da alteração. Esse é o padrão.

  • NEW_IMAGE— a versão da linha após a alteração.

  • OLD_IMAGE— a versão da linha antes da alteração.

  • KEYS_ONLY— as chaves de partição e agrupamento da linha que foi alterada.

Para obter informações sobre como marcar um stream, consulteAdicione tags a um novo stream ao criar uma tabela.

nota

O Amazon Keyspaces CDC exige a presença de uma função vinculada ao serviço (AWSServiceRoleForAmazonKeyspacesCDC) que publique dados métricos dos streams do Amazon Keyspaces CDC na sua conta em seu nome. "cloudwatch:namespace": "AWS/Cassandra" CloudWatch Esta função é criada automaticamente para você. Para obter mais informações, consulte Usando funções para streams CDC do Amazon Keyspaces.

Cassandra Query Language (CQL)
Ative um fluxo CDC ao criar uma tabela com CQL
  1. CREATE TABLE mykeyspace.mytable (a text, b text, PRIMARY KEY(a)) 
WITH CUSTOM_PROPERTIES={'cdc_specification': {'view_type': 'NEW_IMAGE'}} AND CDC = TRUE;

  2. Para confirmar as configurações de transmissão, você pode usar a seguinte declaração.

    SELECT keyspace_name, table_name, cdc, custom_properties FROM system_schema_mcs.tables WHERE keyspace_name = 'mykeyspace' AND table_name = 'mytable';

    A saída dessa declaração deve ser semelhante a essa.

    SELECT keyspace_name, table_name, cdc, custom_properties FROM system_schema_mcs.tables WHERE keyspace_name = 'mykeyspace' AND table_name = 'mytable';keyspace_name | table_name | cdc  | custom_properties
---------------+------------+------+-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
    mykeyspace |   mytable  | True | {'capacity_mode': {'last_update_to_pay_per_request_timestamp': '1741383893782', 'throughput_mode': 'PAY_PER_REQUEST'}, 'cdc_specification': {'latest_stream_arn': 'arn:aws:cassandra:aws-region:111122223333:/keyspace/mykeyspace/table/mytable/stream/2025-03-07T21:44:53.783', 'status': 'ENABLED', 'view_type': 'NEW_IMAGE'}, 'encryption_specification': {'encryption_type': 'AWS_OWNED_KMS_KEY'}, 'point_in_time_recovery': {'status': 'disabled'}}>
CLI
Ative um fluxo CDC ao criar uma tabela com o AWS CLI

  1. Para criar um stream, você pode usar a seguinte sintaxe. 

    aws keyspaces create-table \
--keyspace-name 'mykeyspace' \
--table-name 'mytable' \
--schema-definition 'allColumns=[{name=a,type=text},{name=b,type=text}],partitionKeys=[{name=a}]' \
--cdc-specification status=ENABLED,viewType=NEW_IMAGE

  2. A saída desse comando mostra a create-table resposta padrão e é semelhante a este exemplo. 

    { "resourceArn": "arn:aws:cassandra:us-east-1:111222333444:/keyspace/mykeyspace/table/mytable" }