Habilite um stream CDC para uma tabela existente 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á.

Habilite um stream CDC para uma tabela existente no Amazon Keyspaces

Para habilitar um stream CDC para uma tabela existente, você pode usar a ALTER TABLE instrução em CQL, o update-table comando com o. AWS CLI ou você pode usar o console.

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, consulteAdicionar novas tags a um stream.

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)
Ativar um fluxo (fluxo CDC) com CQL

Você pode usar ALTER TABLE para habilitar um stream para uma tabela existente.

  1. O exemplo a seguir cria um fluxo que captura somente as alterações na partição e nas chaves de agrupamento de uma linha alterada.

    ALTER TABLE mykeyspace.mytable
WITH cdc = TRUE
WITH CUSTOM_PROPERTIES={'cdc_specification': {'view_type': 'KEYS_ONLY'}};

  2. Para verificar as configurações do stream, 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 da declaração é semelhante a essa.

     keyspace_name | table_name | cdc  | custom_properties
---------------+------------+------+--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
    mykeyspace |    mytable | True | {'capacity_mode': {'last_update_to_pay_per_request_timestamp': '1741385897045', 'throughput_mode': 'PAY_PER_REQUEST'}, 'cdc_specification': {'latest_stream_arn': 'arn:aws:cassandra:aws-region:111122223333:/keyspace/mykeyspace/table/mytable/stream/2025-03-07T22:20:10.454', 'status': 'ENABLED', 'view_type': 'KEYS_ONLY'}, 'encryption_specification': {'encryption_type': 'AWS_OWNED_KMS_KEY'}, 'point_in_time_recovery': {'status': 'disabled'}}
CLI
Crie um fluxo CDC com o AWS CLI

  1. Para criar um fluxo para uma tabela existente, você pode usar a sintaxe a seguir.

    aws keyspaces update-table \
--keyspace-name 'mykeyspace' \
--table-name 'mytable' \
--cdc-specification status=ENABLED,viewType=NEW_AND_OLD_IMAGES

  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" }
Console
Habilite um stream do CDC com o console do Amazon Keyspaces

  1. Faça login no AWS Management Console e abra o console do Amazon Keyspaces em casahttps://console.aws.amazon.com/keyspaces/.

  2. No painel de navegação, escolha Tabelas e, em seguida, escolha uma tabela na lista.

  3. Escolha a guia Streams.

  4. Escolha Editar para ativar um stream.

  5. Selecione Ativar transmissões.

  6. Escolha o tipo de exibição do stream. As seguintes opções estão disponíveis: Observe que você não pode alterar o tipo de visualização de um stream depois que ele foi criado.

    • Imagens novas e antigas — o Amazon Keyspaces captura as duas versões da linha, antes e depois da alteração. Esse é o padrão.

    • Nova imagem — O Amazon Keyspaces captura somente a versão da linha após a alteração.

    • Imagem antiga — O Amazon Keyspaces captura somente a versão da linha antes da alteração.

    • Somente chave primária — O Amazon Keyspaces captura somente as colunas de partição e chave de agrupamento da linha que foi alterada.

  7. Para finalizar, escolha Salvar alterações.