Streaming pengambilan data perubahan (CDC) dari database Amazon Aurora PostgreSQL ke BigQuery, Cloud Storage, atau tujuan yang didukung lain memerlukan replikasi logis di cluster sumber Anda. Untuk menyiapkan database Anda untuk Datastream, Anda mengonfigurasi grup parameter cluster, membuat publikasi dan slot replikasi, serta menyiapkan pengguna Datastream.
Sebelum memulai, pastikan Anda memiliki cluster Amazon Aurora yang ada dan terhubung ke endpoint Penulis server database utama Anda.
Membuat grup parameter
- Luncurkan Dasbor Amazon RDS.
- Di panel navigasi, klik Grup Parameter, lalu klik Buat Grup Parameter. Halaman Create Parameter Group akan muncul.
- Gunakan tabel berikut untuk mengisi kolom halaman ini, lalu klik Create:
Kolom Deskripsi Parameter group family Pilih family yang cocok dengan database Anda. Jenis Pilih DB Cluster Parameter Group. Nama grup Berikan nama untuk grup parameter. Deskripsi Berikan deskripsi untuk grup parameter. - Centang kotak di sebelah kiri grup parameter yang baru Anda buat, lalu, di bagian Parameter group actions, klik Edit.
- Ubah nilai parameter
rds.logical_replicationmenjadi 1. - Klik Save Changes.
Menetapkan grup parameter ke instance database
- Luncurkan Dasbor Amazon RDS.
- Di panel navigasi, klik Databases, lalu pilih instance database Anda.
- Dari menu Instance Actions, pilih Modify. Dialog Modify DB Instance akan muncul.
- Di bagian Additional configuration, pilih grup parameter cluster database yang Anda buat.
- Tetapkan Backup retention period ke 7 days.
- Klik Continue.
- Di panel Scheduling of modifications, pilih opsi Apply immediately.
Mem-reboot instance database
- Luncurkan Dasbor Amazon RDS.
- Di panel navigasi, klik Databases, lalu pilih instance database Anda.
- Di menu drop-down Actions , pilih Reboot , lalu Confirm.
Membuat publikasi dan slot replikasi
Buat publikasi untuk perubahan pada tabel yang ingin Anda replikasi. Sebaiknya buat publikasi hanya untuk tabel yang ingin Anda replikasi. Hal ini memungkinkan Datastream hanya membaca data yang relevan, dan menurunkan beban pada database dan Datastream:
CREATE PUBLICATION PUBLICATION_NAME FOR TABLE SCHEMA1.TABLE1, SCHEMA2.TABLE2;
Ganti kode berikut:
- PUBLICATION_NAME: Nama publikasi Anda. Anda harus memberikan nama ini saat membuat stream di wizard pembuatan stream Datastream.
- SCHEMA: Nama skema yang berisi tabel.
- TABLE: Nama tabel yang ingin Anda replikasi.
Anda juga dapat membuat publikasi untuk semua tabel di database Anda. Perhatikan bahwa pendekatan ini meningkatkan beban pada database sumber dan Datastream:
CREATE PUBLICATION PUBLICATION_NAME FOR ALL TABLES;
Buat slot replikasi dengan memasukkan perintah PostgreSQL berikut:
SELECT PG_CREATE_LOGICAL_REPLICATION_SLOT('REPLICATION_SLOT_NAME', 'pgoutput');Ganti kode berikut:
- REPLICATION_SLOT_NAME: Nama slot replikasi Anda. Anda harus memberikan nama ini saat membuat stream di wizard pembuatan stream Datastream.
Membuat pengguna Datastream
Untuk membuat pengguna Datastream, masukkan perintah PostgreSQL berikut:
CREATE USER USER_NAME WITH ENCRYPTED PASSWORD 'USER_PASSWORD';
Ganti kode berikut:
- USER_NAME: Nama pengguna Datastream yang ingin Anda buat.
- USER_PASSWORD: Sandi untuk pengguna Datastream yang ingin Anda buat.
Berikan hak istimewa berikut kepada pengguna yang Anda buat:
GRANT RDS_REPLICATION TO USER_NAME; GRANT SELECT ON ALL TABLES IN SCHEMA SCHEMA_NAME TO USER_NAME; GRANT USAGE ON SCHEMA SCHEMA_NAME TO USER_NAME; ALTER DEFAULT PRIVILEGES IN SCHEMA SCHEMA_NAME GRANT SELECT ON TABLES TO USER_NAME;
Ganti kode berikut:
- SCHEMA_NAME: Nama skema yang ingin Anda berikan hak istimewanya.
- USER_NAME: Pengguna yang ingin Anda berikan hak istimewanya.
Langkah berikutnya
- Pelajari lebih lanjut cara kerja Datastream dengan sumber PostgreSQL.