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

Menggunakan pgactive untuk mendukung replikasi aktif-aktif

pgactiveEkstensi menggunakan replikasi aktif-aktif untuk mendukung dan mengoordinasikan operasi penulisan pada beberapa RDS database Postgre. SQL Amazon RDS untuk Postgre SQL mendukung pgactive ekstensi pada versi berikut:

Menginisialisasi kemampuan ekstensi pgactive

Untuk menginisialisasi kemampuan pgactive ekstensi pada instance Postgre SQL DB AndaRDS, tetapkan nilai rds.enable_pgactive parameter ke 1 dan kemudian buat ekstensi dalam database. Melakukannya secara otomatis menyalakan parameter rds.logical_replication dan track_commit_timestamp lalu menetapkan nilai wal_level ke logical.

Anda harus memiliki izin sebagai peran rds_superuser untuk melakukan tugas-tugas ini.

Anda dapat menggunakan AWS Management Console atau AWS CLI untuk membuat yang diperlukan RDS untuk instance Postgre SQL DB. Langkah-langkah berikut mengasumsikan bahwa instans Postgre SQL DB Anda RDS dikaitkan dengan grup parameter DB kustom. Untuk informasi tentang cara membuat grup parameter DB kustom, lihat Grup parameter untuk RDS.

Menyiapkan replikasi aktif-aktif untuk cluster DB RDS SQL

Prosedur berikut menunjukkan cara memulai replikasi aktif-aktif antara dua yang menjalankan Postgre RDS 15.4 atau lebih tinggi di wilayah SQL yang sama. SQL Untuk menjalankan contoh ketersediaan tinggi multi-wilayah, Anda perlu menerapkan Amazon RDS untuk SQL instans Postgre di dua wilayah berbeda dan menyiapkan Peering. VPC Untuk informasi lebih lanjut, lihat VPCmengintip.

Langkah-langkah ini mengasumsikan bahwa instance RDS for Postgre SQL DB telah diatur dengan ekstensi. pgactive Untuk informasi selengkapnya, lihat Menginisialisasi kemampuan ekstensi pgactive.

Menangani konflik dalam replikasi aktif-aktif

Ekstensi pgactive bekerja per basis data dan bukan per klaster. Setiap instans DB yang menggunakan pgactive adalah instans independen dan dapat menerima perubahan data dari sumber apa pun. Ketika perubahan dikirim ke instance DB, Postgre SQL mengkomitmennya secara lokal dan kemudian menggunakannya pgactive untuk mereplikasi perubahan secara asinkron ke instance DB lainnya. Ketika dua instans Postgre SQL DB memperbarui catatan yang sama pada waktu yang hampir bersamaan, konflik dapat terjadi.

Ekstensi pgactive menyediakan mekanisme untuk deteksi konflik dan resolusi otomatis. Ini akan melacak stempel waktu ketika transaksi dilakukan pada kedua instans DB dan secara otomatis menerapkan perubahan dengan stempel waktu terbaru. Ekstensi pgactive juga melakukan log ketika konflik terjadi dalam tabel pgactive.pgactive_conflict_history.

pgactive.pgactive_conflict_historyAkan terus tumbuh. Anda mungkin ingin menentukan kebijakan pembersihan. Ini dapat dilakukan dengan menghapus beberapa catatan secara teratur atau mendefinisikan skema partisi untuk hubungan ini (dan kemudian melepaskan, menjatuhkan, memotong partisi yang menarik). Untuk menerapkan kebijakan pembersihan secara teratur, salah satu opsi adalah menggunakan pg_cron ekstensi. Lihat informasi berikut dari contoh untuk tabel pg_cron riwayat, Penjadwalan pemeliharaan dengan ekstensi Postgre SQL pg_cron.

Menangani urutan dalam replikasi aktif-aktif

Instance RDS for Postgre SQL DB dengan pgactive ekstensi menggunakan dua mekanisme urutan yang berbeda untuk menghasilkan nilai unik.

Urutan Global

Untuk menggunakan urutan global, buat urutan lokal dengan pernyataan CREATE SEQUENCE. Gunakan pgactive.pgactive_snowflake_id_nextval(seqname) alih-alih usingnextval(seqname) untuk mendapatkan nilai unik berikutnya dari urutan.

Contoh berikut membuat urutan global:

postgres=> CREATE TABLE gstest (
      id bigint primary key,
      parrot text
    );

postgres=>CREATE SEQUENCE gstest_id_seq OWNED BY gstest.id;

postgres=> ALTER TABLE gstest \
      ALTER COLUMN id SET DEFAULT \
      pgactive.pgactive_snowflake_id_nextval('gstest_id_seq');

Urutan yang dipartisi

Dalam urutan split-step atau partisi, urutan Postgre SQL normal digunakan pada setiap node. Setiap urutan bertambah dengan jumlah yang sama dan dimulai pada offset yang berbeda. Misalnya, dengan langkah 100, simpul 1 menghasilkan urutan sebagai 101, 201, 301, dan seterusnya dan simpul 2 menghasilkan urutan sebagai 102, 202, 302, dan seterusnya. Skema ini bekerja dengan baik bahkan jika simpul tidak dapat berkomunikasi untuk waktu yang lama, tetapi mengharuskan perancang menentukan jumlah simpul maksimum saat membuat skema dan memerlukan konfigurasi per-simpul. Kesalahan dapat dengan mudah menyebabkan urutan yang tumpang tindih.

Hal ini relatif mudah untuk mengonfigurasi pendekatan ini dengan pgactive dengan membuat urutan yang diinginkan pada simpul sebagai berikut:

CREATE TABLE some_table (generated_value bigint primary key);

postgres=> CREATE SEQUENCE some_seq INCREMENT 100 OWNED BY some_table.generated_value;

postgres=> ALTER TABLE some_table ALTER COLUMN generated_value SET DEFAULT nextval('some_seq');
    

Kemudian panggil setval setiap simpul untuk memberikan nilai awal offset yang berbeda sebagai berikut.

postgres=>
-- On node 1
SELECT setval('some_seq', 1);

-- On node 2
SELECT setval('some_seq', 2);     

Referensi parameter untuk ekstensi pgactive

Anda dapat menggunakan kueri berikut untuk melihat semua parameter yang terkait dengan ekstensi pgactive.

postgres=> SELECT * FROM pg_settings WHERE name LIKE 'pgactive.%';

Mengukur lag replikasi di antara anggota pgactive

Anda dapat menggunakan kueri berikut untuk melihat lag replikasi di antara pgactive anggota. Jalankan kueri ini di setiap pgactive node untuk mendapatkan gambaran lengkap.

      postgres=# SELECT *, (last_applied_xact_at - last_applied_xact_committs) AS lag FROM pgactive.pgactive_node_slots;
-{ RECORD 1 ]----------------+----------------------------------------------------------------- 
node_name                    | node2-app
slot_name                    | pgactive_5_7332551165694385385_0_5__
slot_restart_lsn             | 0/1A898A8
slot_confirmed_lsn           | 0/1A898E0
walsender_active             | t
walsender_pid                | 69022
sent_lsn                     | 0/1A898E0 
write_lsn                    | 0/1A898E0
flush_lsn                    | 0/1A898E0  
replay_lsn                   | 0/1A898E0
last_sent_xact_id            | 746
last_sent_xact_committs      | 2024-02-06 18:04:22.430376+00
last_sent_xact_at            | 2024-02-06 18:04:22.431359+00
last_applied_xact_id         | 746
last_applied_xact_committs   | 2024-02-06 18:04:22.430376+00
last_applied_xact_at         | 2024-02-06 18:04:52.452465+00
lag                          | 00:00:30.022089

Batasan untuk ekstensi pgactive