例: Aurora PostgreSQL DB クラスターにおける論理レプリケーションの使用

2 つの Aurora PostgreSQL DB クラスター間で論理レプリケーションを開始するには

これらの手順では、Aurora PostgreSQL DB クラスターに、サンプルテーブルを作成するデータベースを含むライターインスタンスがあることを前提としています。

1. パブリッシャーとしての Aurora PostgreSQL DB クラスター

   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 DB クラスター

   1. 次のように、パブリッシャーで作成したものと同じ LogicalReplicationTest テーブルをサブスクライバーに作成します。

      CREATE TABLE LogicalReplicationTest (a int PRIMARY KEY);

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

      SELECT count(*) FROM LogicalReplicationTest;

   3. サブスクリプションを作成して、パブリッシャーから変更を取得します。パブリッシャーの Aurora PostgreSQL DB クラスターについて、次の詳細を使用する必要があります。

      • host (ホスト) - パブリッシャーである Aurora PostgreSQL DB クラスターのライター DB インスタンス。

      • ポート - 書き込み DB インスタンスがリッスンするポート。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;