範例：搭配 Aurora PostgreSQL 資料庫叢集使用邏輯複寫

在兩個 Aurora PostgreSQL 資料庫叢集之間啟動邏輯複寫程序

這些步驟假設您的 Aurora PostgreSQL 資料庫叢集具有一個寫入器執行個體，其中包含可在其中建立範例資料表的資料庫。

1. 在發佈者 Aurora PostgreSQL 資料庫叢集上

   1. 使用下列 SQL 陳述式建立資料表。

      CREATE TABLE LogicalReplicationTest (a int PRIMARY KEY);

   2. 使用下列 SQL 陳述式，將資料插入發佈者資料庫。

      INSERT INTO LogicalReplicationTest VALUES (generate_series(1,10000));

   3. 使用下列 SQL 陳述式，驗證資料是否存在於資料表中。

      SELECT count(*) FROM LogicalReplicationTest;

   4. 使用 CREATE PUBLICATION 陳述式建立此資料表的發佈，如下所示。

      CREATE PUBLICATION testpub FOR TABLE LogicalReplicationTest;

2. 在訂閱者 Aurora PostgreSQL 資料庫叢集上

   1. 在訂閱者上建立您已在發佈者上建立的相同 LogicalReplicationTest 資料表，如下所示。

      CREATE TABLE LogicalReplicationTest (a int PRIMARY KEY);

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

      SELECT count(*) FROM LogicalReplicationTest;

   3. 建立訂閱以從發佈者取得變更。您必須使用有關發佈者 Aurora PostgreSQL 資料庫叢集的下列詳細資訊。

      • host – 發佈者 Aurora PostgreSQL 資料庫叢集的寫入器資料庫執行個體。

      • port – 寫入器資料庫執行個體正在聆聽的連接埠。PostgreSQL 的預設值為 5432。

      • dbname – 資料庫的名稱。

      CREATE SUBSCRIPTION testsub CONNECTION 
         'host=publisher-cluster-writer-endpoint port=5432 dbname=db-name user=user password=password' 
         PUBLICATION testpub; 
      

      注意

      指定此處所顯示提示以外的密碼，作為安全最佳實務。

      建立訂閱後，發佈者會建立一個邏輯複寫槽。

   4. 對於本範例，若要驗證初始資料已複寫在訂閱者上，請對訂閱者資料庫使用下列 SQL 陳述式。

      SELECT count(*) FROM LogicalReplicationTest;