Aurora PostgreSQL DB クラスターに論理レプリケーションを設定する

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;

次のように、この Aurora PostgreSQL DB クラスターをパブリッシャーノードとして指定します。

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)

psql を使用して、パブリッシャーから更新を受け取るインスタンスに接続します。

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

サブスクライバーの Aurora PostgreSQL DB クラスターで、パブリッシャーに存在するのと同じテーブルを作成します。この例では、テーブルは docs_lab_table です。次に示すようにテーブルを作成できます。

CREATE TABLE docs_lab_table (a int PRIMARY KEY);

このテーブルが空であることを確認します。

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

次のように、この Aurora PostgreSQL DB クラスターをサブスクライバーノードとして指定します。

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)