Aktivieren Sie einen CDC-Stream, wenn Sie eine neue Tabelle in Amazon Keyspaces erstellen - Amazon Keyspaces (für Apache Cassandra)

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Aktivieren Sie einen CDC-Stream, wenn Sie eine neue Tabelle in Amazon Keyspaces erstellen

Um beim Erstellen einer Tabelle einen CDC-Stream zu aktivieren, können Sie die CREATE TABLE Anweisung in CQL oder den Befehl mit dem create-table verwenden. AWS CLI

Für jede geänderte Zeile in der Tabelle kann Amazon Keyspaces basierend auf der view_type von cdc_specification Ihnen ausgewählten Zeile die folgenden Änderungen erfassen:

  • NEW_AND_OLD_IMAGES— beide Versionen der Zeile, vor und nach der Änderung. Dies ist die Standardeinstellung.

  • NEW_IMAGE— die Version der Zeile nach der Änderung.

  • OLD_IMAGE— die Version der Zeile vor der Änderung.

  • KEYS_ONLY— die Partitions- und Clusterschlüssel der Zeile, die geändert wurde.

Hinweise zum Taggen eines Streams finden Sie unterFügen Sie beim Erstellen einer Tabelle Tags zu einem neuen Stream hinzu.

Anmerkung

Amazon Keyspaces CDC erfordert das Vorhandensein einer serviceverknüpften Rolle (AWSServiceRoleForAmazonKeyspacesCDC), die in Ihrem Namen Metrikdaten aus Amazon Keyspaces CDC-Streams "cloudwatch:namespace": "AWS/Cassandra" in Ihrem CloudWatch Konto veröffentlicht. Diese Rolle wird automatisch für Sie erstellt. Weitere Informationen finden Sie unter Rollen für Amazon Keyspaces CDC-Streams verwenden.

Cassandra Query Language (CQL)
Aktivieren Sie einen CDC-Stream, wenn Sie eine Tabelle mit CQL erstellen
  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. Um die Stream-Einstellungen zu bestätigen, können Sie die folgende Anweisung verwenden.

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

    Die Ausgabe dieser Anweisung sollte in etwa so aussehen.

    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
Aktivieren Sie einen CDC-Stream, wenn Sie eine Tabelle mit dem erstellen AWS CLI

  1. Um einen Stream zu erstellen, können Sie die folgende Syntax verwenden. 

    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. Die Ausgabe dieses Befehls zeigt die create-table Standardantwort und sieht diesem Beispiel ähnlich. 

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