為 Amazon RDS for PostgreSQL 執行邏輯複寫

開啟 RDS for PostgreSQL 資料庫執行個體的邏輯解碼

1. 確保您正在使用的使用者帳戶具有以下角色：

   • 可讓您開啟邏輯複寫的 rds_superuser 角色

   • 授權來管理邏輯槽和利用邏輯槽來串流資料的 rds_replication 角色

2. 將 rds.logical_replication 靜態參數設為 1。套用此參數時，也會設定 wal_level、max_wal_senders、max_replication_slots 和 max_connections 參數。這些參數變更會產生更多 WAL，因此請僅在使用邏輯槽時才設定 rds.logical_replication 參數。

3. 為了讓靜態 rds.logical_replication 參數生效，請重新啟動資料庫執行個體。

4. 建立邏輯複寫槽將在下一章節中說明。此程序要求您指定解碼外掛程式。目前，RDS for PostgreSQL 支援隨附於 PostgreSQL 的 test_decoding 和 wal2json 輸出外掛程式。

1. 建立來源資料表

   連線至 RDS for PostgreSQL 資料庫執行個體中的來源資料庫：

   
   source=> CREATE TABLE testtab (slno int primary key);
   CREATE TABLE
           

2. 將資料插入來源資料表

   
   source=> INSERT INTO testtab VALUES (generate_series(1,1000));
   INSERT 0 1000
           

3. 建立來源資料表的發佈

   • 建立來源資料表的發佈：

     
     source=> CREATE PUBLICATION testpub FOR TABLE testtab;
     CREATE PUBLICATION
             

   • 使用 SELECT 查詢來驗證所建立發佈的詳細資訊：

     
     source=> SELECT * FROM pg_publication;
       oid   | pubname | pubowner | puballtables | pubinsert | pubupdate | pubdelete | pubtruncate | pubviaroot
     --------+---------+----------+--------------+-----------+-----------+-----------+-------------+------------
      115069 | testpub |    16395 | f            | t         | t         | t         | t           | f
     (1 row)
             

   • 確認來源資料表已新增至發佈：

     
     source=> SELECT * FROM pg_publication_tables; 
     pubname | schemaname | tablename
     ---------+------------+-----------
      testpub | public     | testtab
     (1 rows)
             

   • 若要複寫資料庫中的所有資料表，請使用：

     
     CREATE PUBLICATION testpub FOR ALL TABLES;
               

   • 如果已為個別資料表建立發佈，且您需要新增資料表，您可以在查詢下方執行 ，將任何新資料表新增至現有發佈：

     
     ALTER PUBLICATION <publication_name> add table <new_table_name>;
               

4. 連線至目標資料庫並建立目標資料表

   • 連線至目標資料庫執行個體中的目標資料庫。使用與來源資料表相同的名稱建立目標資料表：

     
     target=> CREATE TABLE testtab (slno int primary key);
     CREATE TABLE
     

   • 在目標資料表上執行 SELECT 查詢，以確保目標資料表中沒有資料：

         
     target=> SELECT count(*) FROM testtab;
      count
     -------
          0
     (1 row)
             

5. 在目標資料庫中建立和驗證訂閱

   • 在目標資料庫中建立訂閱：

     
     target=> CREATE SUBSCRIPTION testsub 
     CONNECTION 'host=<source RDS/host endpoint> port=5432 dbname=<source_db_name> user=<user> password=<password>' 
     PUBLICATION testpub;
     NOTICE:  Created replication slot "testsub" on publisher
     CREATE SUBSCRIPTION
             

   • 使用 SELECT 查詢來驗證訂閱是否已啟用：

     
     target=> SELECT oid, subname, subenabled, subslotname, subpublications FROM pg_subscription;
       oid  | subname | subenabled | subslotname | subpublications
     -------+---------+------------+-------------+-----------------
      16434 | testsub | t          | testsub     | {testpub}
     (1 row)
             

   • 建立訂閱時，它會將來源資料表中的所有資料載入目標資料表。在目標資料表上執行 SELECT 查詢，以確認初始資料載入：

     
     target=> SELECT count(*) FROM testtab;
      count
     -------
       1000
     (1 row)
             

6. 驗證來源資料庫中的複寫槽

   在目標資料庫中建立訂閱會在來源資料庫中建立複寫槽。在來源資料庫上執行下列 SELECT 查詢，以驗證複寫槽詳細資訊：

   
   source=> SELECT * FROM pg_replication_slots;
    
   slot_name |  plugin  | slot_type | datoid | database | temporary | active | active_pid | xmin | catalog_xmin | restart_lsn | confirmed_flush_lsn | wal_status | safe_wal_size
   ----------+----------+-----------+--------+----------+-----------+--------+------------+------+--------------+-------------+---------------------+------------+---------------
   testsub   | pgoutput | logical   | 115048 | source   | f         | t      |        846 |      |         6945 | 58/B4000568 | 58/B40005A0         | reserved   |
   (1 row)
           

7. 測試複寫

   • 將資料列插入來源資料表，以測試來源資料表中的資料變更是否複寫至目標資料表：

     
     source=> INSERT INTO testtab VALUES(generate_series(1001,2000));
     INSERT 0 1000
     
     source=> SELECT count(*) FROM testtab; 
      count
     -------
       2000
     (1 row)
           

   • 驗證目標資料表中的資料列數，以確認正在複寫新的插入：

     
     target=> SELECT count(*) FROM testtab;
      count
     -------
       2000
     (1 row)
           

8. 新增資料表後重新整理訂閱

   • 當您將新資料表新增至現有發佈時，必須重新整理訂閱，變更才會生效：

     
     ALTER SUBSCRIPTION <subscription_name> REFRESH PUBLICATION;
           

   • 此命令會從發佈者擷取缺少的資料表資訊，並開始複寫自訂閱建立或上次重新整理以來新增至訂閱發佈的資料表。