Aktifkan aliran CDC saat membuat tabel baru di Amazon Keyspaces - Amazon Keyspaces (untuk Apache Cassandra)

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Aktifkan aliran CDC saat membuat tabel baru di Amazon Keyspaces

Untuk mengaktifkan aliran CDC saat Anda membuat tabel, Anda dapat menggunakan CREATE TABLE pernyataan di CQL atau create-table perintah dengan. AWS CLI

Untuk setiap baris yang diubah dalam tabel, Amazon Keyspaces dapat menangkap perubahan berikut berdasarkan pilihan view_type yang cdc_specification Anda pilih:

  • NEW_AND_OLD_IMAGES— kedua versi baris, sebelum dan sesudah perubahan. Ini adalah opsi default.

  • NEW_IMAGE— versi baris setelah perubahan.

  • OLD_IMAGE— versi baris sebelum perubahan.

  • KEYS_ONLY— kunci partisi dan pengelompokan baris yang diubah.

Untuk informasi tentang cara menandai aliran, lihatTambahkan tag ke aliran baru saat membuat tabel.

catatan

Amazon Keyspaces CDC memerlukan keberadaan peran terkait layanan (AWSServiceRoleForAmazonKeyspacesCDC) yang menerbitkan data metrik dari aliran CDC Amazon Keyspaces ke dalam akun Anda atas nama Anda. "cloudwatch:namespace": "AWS/Cassandra" CloudWatch Peran ini dibuat secara otomatis untuk Anda. Untuk informasi selengkapnya, lihat Menggunakan peran untuk aliran CDC Amazon Keyspaces.

Cassandra Query Language (CQL)
Aktifkan aliran CDC saat Anda membuat tabel dengan 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. Untuk mengonfirmasi pengaturan streaming, Anda dapat menggunakan pernyataan berikut.

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

    Output dari pernyataan itu akan terlihat mirip dengan ini.

    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
Aktifkan aliran CDC saat Anda membuat tabel dengan AWS CLI

  1. Untuk membuat stream Anda dapat menggunakan sintaks berikut. 

    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. Output dari perintah itu menunjukkan create-table respons standar dan terlihat mirip dengan contoh ini. 

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