要求與限制設定 pglogical 延伸模組設定邏輯複寫在升級之後重新建立邏輯複寫管理邏輯複寫槽 pglogical 延伸模組參數的參數參考

使用 pglogical 跨執行個體同步資料

Postgre SQL 版本都支持該pglogical擴展。pglogical 擴充功能早於 Postgre SQL 在版本 10 中引入的功能上類似的邏輯複寫功能。如需詳細資訊，請參閱為 Amazon RDS 執行邏輯複寫 SQL。

此pglogical延伸模組支援兩個或多個之間的邏輯複寫。RDS適用於後置SQL資料庫執行個體。它也支援在不同 Postgre SQL 版本之間以及在 Postgre 資料庫執行個體和 Aurora Postgre RDS 資料庫叢集上執行的資料SQL庫之間進行複寫。SQLpglogical 延伸模組會使用發佈-訂閱模型，將資料表和其他物件 (例如序列) 的變更從發佈者複製到訂閱者。它依賴複寫槽，以確保變更從發佈者節點同步到訂閱者節點，其定義如下。

發行者節點是，是要複寫到其他節點的資料來源。發佈者節點定義要在發佈集中複製的資料表。
訂閱者節點是，可從發行者接收WAL更新。訂閱者會建立訂閱以連線至發行者並取得解碼的WAL資料。訂閱者建立訂閱時，系統會在發佈者節點上建立複寫槽。

您可以在以下內容中找到如何設定 pglogical 延伸模組的相關資訊。

pglogical 延伸模組的需求和限制

所有當前可用的版本為 Postgre SQL 支持擴展。pglogical

發佈者節點和訂閱者節點都必須針對邏輯複寫進行設定。

您要從發行者複寫到訂閱者的表格必須具有相同的名稱和相同的結構描述。這些資料表亦須包含相同的資料欄，而且這些資料欄必須使用相同的資料類型。發佈者和訂閱者資料表都必須具有相同的主索引鍵。我們建議您僅使用PRIMARYKEY作為唯一條件約束。

與NOTNULL發行者節點上的限制條件約束和條件約束相比，訂閱者節點上的表格具有更寬鬆的CHECK條件約束。

pglogical擴充功能提供諸如 Postgre SQL (版本 10 及更新版本) 內建的邏輯複寫功能不支援的雙向複製等功能。如需詳細資訊，請參閱使用 pglogical 進行SQL雙向複寫。

設定 pglogical 延伸模組

若要在 Postgre 資料庫執行個體 Aurora Postgre SQL 資料SQL庫叢集上設定pglogical擴充功能，RDS請資料庫執行個體的自訂資料庫參數群組上新增pglogical至共用程式庫。RDS 您亦需將 rds.logical_replication 參數的值設為 1，以開啟邏輯解碼。最後，您可以在資料庫中建立延伸模組。您可以使用 AWS Management Console 或 AWS CLI 對於這些任務。

您必須具有做為 rds_superuser 角色的許可，才能執行這些任務。

以下步驟假設 RDS與自訂資料庫參數群組相關聯。如需建立自訂資料庫叢集參數群組的相關資訊，請參閱的參數組 RDS。

設定 pglogical 延伸模組

登入到 AWS Management Console 並打開 Amazon RDS 控制台https://console.aws.amazon.com/rds/。
在瀏覽窗格中，RDS為 Postgre 資料庫執行個體選擇。SQL
開啟的組態索引標籤。RDS對於後置SQL數據庫實例。在執行個體詳細資訊之間，尋找 Parameter group (參數群組) 連結。
選擇連結以開啟與您的相關聯的自訂參數。RDS對於後置SQL數據庫實例。
在 Parameters (參數) 搜尋欄位中，輸入 shared_pre 以尋找 shared_preload_libraries 參數。
選擇 Edit parameters (編輯參數) 以存取屬性值。
在 Values (值) 欄位中，將 pglogical 新增至清單。使用逗號區隔值清單中的項目。
尋找 rds.logical_replication 參數並將其設為 1，以開啟邏輯複寫。
重新啟動RDS適用於 Postgre 資料庫入器執行個體，以便您的變更生效。SQL

執行個體可用時，您可以使用 psql (或pgAdmin) 連線至。 RDS對於後置SQL數據庫實例。


psql --host=111122223333.aws-region.rds.amazonaws.com --port=5432 --username=postgres --password --dbname=labdb

若要驗證 pglogical 是否已初始化，請執行下列命令。


SHOW shared_preload_libraries;
shared_preload_libraries 
--------------------------
rdsutils,pglogical
(1 row)

驗證啟用邏輯解碼的設定，如下所示。


SHOW wal_level;
wal_level
-----------
 logical
(1 row)

建立延伸模組，如下所示。


CREATE EXTENSION pglogical;
EXTENSION CREATED

選擇 Save changes (儲存變更)。
在打開 Amazon RDS 控制台https://console.aws.amazon.com/rds/。
從「資料庫」清單中選擇入器執行個體，加以選取，然後從「動作」功能表選擇「重新開機」。

設定 pglogical 延伸模組

若要使用 AWS CLI，您可以呼叫modify-db-parameter-group作業來修改自訂參數群組中的某些參數，如下列程序所示。

使用以下內容 AWS CLI 要新增pglogical至shared_preload_libraries參數的指令。


aws rds modify-db-parameter-group \
   --db-parameter-group-name custom-param-group-name \
   --parameters "ParameterName=shared_preload_libraries,ParameterValue=pglogical,ApplyMethod=pending-reboot" \
   --region aws-region

使用以下內容 AWS CLI 指令設定為rds.logical_replication1以開啟邏輯解碼功能。RDS對於後置SQL數據庫實例。


aws rds modify-db-parameter-group \
   --db-parameter-group-name custom-param-group-name \
   --parameters "ParameterName=rds.logical_replication,ParameterValue=1,ApplyMethod=pending-reboot" \
   --region aws-region

使用以下內容 AWS CLI 此指令可重新啟動 Postgre 資料庫入器執行個體，以便初始化 pglogical 程式庫。SQL
```
aws rds reboot-db-instance \
    --db-instance-identifier your-instance \
    --region aws-region
```

執行個體可用時，請用psql來連線至。 RDS對於後置SQL數據庫實例。


psql --host=111122223333.aws-region.rds.amazonaws.com --port=5432 --username=postgres --password --dbname=labdb

建立延伸模組，如下所示。


CREATE EXTENSION pglogical;
EXTENSION CREATED

使用以下方法重新啟動RDS適用於 Postgre SQL 資料庫執行個體的 Aurora Postgre SQL 資料庫 AWS CLI 指令。
```
aws rds reboot-db-instance \
    --db-instance-identifier your-instance \
    --region aws-region
```

為 RDS行個體設定邏輯複寫 SQL

下列程序說明如何在兩個之間啟動邏輯複寫。 RDS適用於後置SQL資料庫執行個體。這些步驟假設來源 (發佈者) 和目標 (訂閱者) 都已設定 pglogical 延伸模組，如設定 pglogical 延伸模組中所述。

建立發佈者節點並定義要複製的資料表

這些步驟假設您的一或多個您要複寫到另一個節點的表格。您必須在訂閱者上重新建立來自發佈者的資料表結構，因此必要時先取得資料表結構。您可以使用 psq1 中繼命令 \d tablename，然後在訂閱者執行個體上建立相同的資料表，以執行該操作。下列程序會在發佈者 (來源) 上建立範例資料表，以供示範之用。

使用 psql 連線至具有資料表的執行個體，您想要將該資料表用作訂閱者的來源。
```
psql --host=source-instance.aws-region.rds.amazonaws.com --port=5432 --username=postgres --password --dbname=labdb
```
如果您沒有要複寫的現有資料表，則可以建立如下的範例資料表。
1. 使用下列陳述式建立範例資料SQL表。
```
CREATE TABLE docs_lab_table (a int PRIMARY KEY);
```
2. 使用下列陳述式將產生的資料填入資料SQL表。
```
INSERT INTO docs_lab_table VALUES (generate_series(1,5000));
INSERT 0 5000
```
3. 使用下列SQL陳述式確認資料表中是否存在資料。
```
SELECT count(*) FROM docs_lab_table;
```

將識別為發行者節點，如下所示。


SELECT pglogical.create_node(
    node_name := 'docs_lab_provider',
    dsn := 'host=source-instance.aws-region.rds.amazonaws.com port=5432 dbname=labdb');
 create_node
-------------
   3410995529
(1 row)

將您要複寫的資料表新增至預設複寫集。如需複寫集的詳細資訊，請參閱 pglogical 文件中的 Replication sets (複寫集)。


SELECT pglogical.replication_set_add_table('default', 'docs_lab_table', 'true', NULL, NULL);
 replication_set_add_table
  ---------------------------
  t
  (1 row)

發佈者節點設定完成。您現在可以設定訂閱者節點，從發佈者接收更新。

設定訂閱者節點並建立訂閱來接收更新

這些步驟假設已設定RDS為擴充功能。pglogical如需詳細資訊，請參閱設定 pglogical 延伸模組。

使用 psql 來連線至您想要從發佈者接收更新的執行個體。


psql --host=target-instance.aws-region.rds.amazonaws.com --port=5432 --username=postgres --password --dbname=labdb

在訂閱者針對 Postgre SQL 資料庫執行個體，建立發行者上存在的相同表格。在此範例中，資料表是 docs_lab_table。您可以建立資料表，如下所示。
```
CREATE TABLE docs_lab_table (a int PRIMARY KEY);
```

驗證此資料表是否為空的。


SELECT count(*) FROM docs_lab_table;
 count
-------
  0
(1 row)

將 RDS識別為訂閱者節點，如下所示。


SELECT pglogical.create_node(
    node_name := 'docs_lab_target',
    dsn := 'host=target-instance.aws-region.rds.amazonaws.com port=5432 sslmode=require dbname=labdb user=postgres password=********');
 create_node
-------------
   2182738256
(1 row)

建立訂閱。


SELECT pglogical.create_subscription(
   subscription_name := 'docs_lab_subscription',
   provider_dsn := 'host=source-instance.aws-region.rds.amazonaws.com port=5432 sslmode=require dbname=labdb user=postgres password=*******',
   replication_sets := ARRAY['default'],
   synchronize_data := true,
   forward_origins := '{}' );  
 create_subscription
---------------------
1038357190
(1 row)

完成此步驟時，會在訂閱者上的資料表中建立來自發佈者上資料表的資料。您可以使用以下SQL查詢驗證是否發生了這種情況。


SELECT count(*) FROM docs_lab_table;
 count
-------
  5000
(1 row)

從此開始，對發佈者上資料表所做的變更會複寫到訂閱者上的資料表。

在重大升級之後重新建立邏輯複寫

針對執行主要版本升級之前，您必須捨棄所有複寫插槽，甚至是未使用的複寫插槽。建議您暫時從發行者節點轉移資料庫交易、卸除複寫插槽、升級執行個體的 Po stgre 資料SQL庫執行個體，然後重新建立並重新啟動複寫。RDS

複寫槽僅託管於發佈者節點上。邏輯複寫案例中的 RDS for Postgre 訂SQL閱者節點沒有可卸除的插槽，但在指定為具有發行者訂閱的訂閱者節點時，無法升級至主要版本。在升級 Postgre RDS 訂SQL閱者節點之前，請先刪除訂閱和節點。如需詳細資訊，請參閱管理適用於的邏輯複寫插槽 SQL。

判斷邏輯複寫是否已中斷

您可以查詢發佈者節點或訂閱者節點，來判斷複寫程序是否已中斷，如下所示。

檢查發佈者節點

使用 psql 連線到發佈者節點，然後查詢 pg_replication_slots 函數。請注意作用中資料欄中的值。通常，這會傳回 t (true)，表明複寫作用中。如果查詢傳回 f (false)，表示已停止複寫至訂閱者。


SELECT slot_name,plugin,slot_type,active FROM pg_replication_slots;
                    slot_name              |      plugin      | slot_type | active
-------------------------------------------+------------------+-----------+--------
 pgl_labdb_docs_labcb4fa94_docs_lab3de412c | pglogical_output | logical   | f
(1 row)

檢查訂閱者節點

在訂閱者節點上，您可以採取三種不同的方式來檢查複寫的狀態。

查看訂閱者節點上的 Postgre SQL 記錄檔，以尋找失敗訊息。日誌會以包含結束代碼 1 的訊息識別失敗，如下所示。


2022-07-06 16:17:03 UTC::@:[7361]:LOG: background worker "pglogical apply 16404:2880255011" (PID 14610) exited with exit code 1
2022-07-06 16:19:44 UTC::@:[7361]:LOG: background worker "pglogical apply 16404:2880255011" (PID 21783) exited with exit code 1

查詢 pg_replication_origin 函數。使用 psql 連線至訂閱者節點上的資料庫，然後查詢 pg_replication_origin 函數，如下所示。


SELECT * FROM pg_replication_origin;
 roident | roname
---------+--------
(0 rows)

空白結果集表示複寫已中斷。通常，您會看到如下輸出。


   roident |                       roname
  ---------+----------------------------------------------------
         1 | pgl_labdb_docs_labcb4fa94_docs_lab3de412c
  (1 row)

查詢 pglogical.show_subscription_status 函數，如下列範例所示。


SELECT subscription_name,status,slot_name FROM pglogical.show_subscription_status();
     subscription_name | status |              slot_name
---====----------------+--------+-------------------------------------
 docs_lab_subscription | down   | pgl_labdb_docs_labcb4fa94_docs_lab3de412c
(1 row)

此輸出表明複寫已中斷。其狀態為 down。通常，輸出會將狀態顯示為 replicating。

如果您的邏輯複寫程序已中斷，您可以遵循下列步驟重新建立複寫。

重新建立發佈者與訂閱者節點之間的邏輯複寫

若要重新建立複寫，首先中斷訂閱者與發佈者節點的連線，然後重新建立訂閱，如下列步驟所述。

使用 psql 連線至訂閱者節點，如下所示。


psql --host=222222222222.aws-region.rds.amazonaws.com --port=5432 --username=postgres --password --dbname=labdb

使用 pglogical.alter_subscription_disable 函數停用訂閱。


SELECT pglogical.alter_subscription_disable('docs_lab_subscription',true);
 alter_subscription_disable
----------------------------
 t
(1 row)

透過查詢 pg_replication_origin 取得發佈者節點的識別符，如下所示。


SELECT * FROM pg_replication_origin;
 roident |               roname
---------+-------------------------------------
       1 | pgl_labdb_docs_labcb4fa94_docs_lab3de412c
(1 row)

使用上一個步驟的回應搭配 pg_replication_origin_create 命令，來指派訂閱可在重新建立時使用的識別符。


SELECT pg_replication_origin_create('pgl_labdb_docs_labcb4fa94_docs_lab3de412c');
  pg_replication_origin_create
------------------------------
                            1
(1 row)

透過傳送訂閱的名稱來開啟訂閱，其狀態為 true，如下列範例所示。


SELECT pglogical.alter_subscription_enable('docs_lab_subscription',true);
  alter_subscription_enable
---------------------------
 t
(1 row)

檢查節點的狀態。其狀態應為 replicating，如這個範例所示。


SELECT subscription_name,status,slot_name
  FROM pglogical.show_subscription_status();
             subscription_name |   status    |              slot_name
-------------------------------+-------------+-------------------------------------
 docs_lab_subscription         | replicating | pgl_labdb_docs_lab98f517b_docs_lab3de412c
(1 row)

檢查發佈者節點上訂閱者複寫槽的狀態。複寫槽的 active 資料欄應傳回 t (true)，表示已重新建立複寫。


SELECT slot_name,plugin,slot_type,active
  FROM pg_replication_slots;
                    slot_name              |      plugin      | slot_type | active
-------------------------------------------+------------------+-----------+--------
 pgl_labdb_docs_lab98f517b_docs_lab3de412c | pglogical_output | logical   | t
(1 row)

管理適用於的邏輯複寫插槽 SQL

在邏輯複寫案例中做為發行者節點的執行個體上執行主要版本升級之前，您必須先將複寫插槽放在執行個體上。主要版本升級預先檢查程序會通知您，除非捨棄複寫槽，否則升級無法繼續進行。

若要從 Postgre SQL 資料庫執行個體中刪除插槽，RDS請先刪除訂閱，然後放下插槽。

若要識別已使用 pglogical 延伸模組建立的複寫槽，請登入每個資料庫並取得節點的名稱。查詢訂閱者節點時，您會在輸出中同時取得發佈者和訂閱者節點，如本範例所示。


SELECT * FROM pglogical.node;
node_id   |     node_name
------------+-------------------
 2182738256 | docs_lab_target
 3410995529 | docs_lab_provider
(2 rows)

您可以使用下列查詢，取得有關訂閱的詳細資訊。


SELECT sub_name,sub_slot_name,sub_target
  FROM pglogical.subscription;
 sub_name |         sub_slot_name          | sub_target
----------+--------------------------------+------------
  docs_lab_subscription     | pgl_labdb_docs_labcb4fa94_docs_lab3de412c | 2182738256
(1 row)

您現在可以捨棄訂閱，如下所示。


SELECT pglogical.drop_subscription(subscription_name := 'docs_lab_subscription');
 drop_subscription
-------------------
                 1
(1 row)

捨棄訂閱之後，您可以刪除節點。


SELECT pglogical.drop_node(node_name := 'docs-lab-subscriber');
 drop_node
-----------
 t
(1 row)

您可以驗證節點是否不再存在，如下所示。


SELECT * FROM pglogical.node;
 node_id | node_name
---------+-----------
(0 rows)

pglogical 延伸模組的參數參考

在資料表中，您可以尋找與 pglogical 延伸模組相關聯的參數。pglogical.conflict_log_level 和 pglogical.conflict_resolution 這類參數用來處理更新衝突。對從發佈者訂閱變更的相同資料表進行本機變更時，可能會出現衝突。在各種案例期間 (例如雙向複寫或從相同發佈者複寫多個訂閱者時)，也會發生衝突。如需詳細資訊，請參閱使用 pglogical 進行SQL雙向複寫。

參數	描述
pglogical.batch_inserts	可能情況下批次插入。依預設不會設定。變更為 '1' 以開啟、變更為 '0' 以關閉。
pglogical.conflict_log_level	設定用於記錄已解決衝突的日誌層級。支援的字串值為 debug5、debug4、debug3、debug2、debug1、info、notice、warning、error、log、fatal、panic。
pglogical.conflict_resolution	設定用來在衝突可解決時解決衝突的方法。支援的字串值為 error、apply_remote、keep_local、last_update_wins、first_update_wins。
pglogical.extra_connection_options	要新增到所有對等節點連線的連線選項。
pglogical.synchronous_commit	pglogical 特定的同步遞交值
pglogical.use_spi	使用SPI（服務器編程接口）而不是低級別API來應用更改。設為 '1' 以開啟、設為 '0' 以關閉。如需有關的詳細資訊SPI，請參閱 Postgre SQL 文件中的伺服器程式設計介面。

您的瀏覽器已停用或無法使用 Javascript。

您必須啟用 Javascript，才能使用 AWS 文件。請參閱您的瀏覽器說明頁以取得說明。

文件慣用形式

使用 pg_cron 擴充功能排程維護

使用 Post 管理空間資料 GIS

使用 pglogical 跨執行個體同步資料

主題

pglogical 延伸模組的需求和限制

設定 pglogical 延伸模組

設定 pglogical 延伸模組

設定 pglogical 延伸模組

為 RDS行個體設定邏輯複寫 SQL

建立發佈者節點並定義要複製的資料表

設定訂閱者節點並建立訂閱來接收更新

在重大升級之後重新建立邏輯複寫

判斷邏輯複寫是否已中斷

檢查發佈者節點

檢查訂閱者節點

重新建立發佈者與訂閱者節點之間的邏輯複寫

管理適用於 的邏輯複寫插槽 SQL

pglogical 延伸模組的參數參考

管理適用於的邏輯複寫插槽 SQL