pgactive を使用したアクティブ/アクティブレプリケーションのサポート

pgactive 拡張を使用して最初の RDS for PostgreSQL DB インスタンスを設定するには

次の例は、pgactive グループの作成方法と、RDS for PostgreSQL DB インスタンスで pgactive 拡張を作成するために必要なその他の手順を示しています。

1. psql または別のクライアントツールを使用して、最初の RDS for PostgreSQL DB インスタンスに接続します。

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

2. 次のコマンドを使用して RDS for PostgreSQL インスタンスにデータベースを作成します。

   postgres=> CREATE DATABASE app;

3. 次のコマンドを使用して、接続先を新しいデータベースに切り替えます。

   \c app

4. shared_preload_libraries パラメータに pgactive が含まれているかどうかを確認するには、次のコマンドを実行します。

   app=>SELECT setting ~ 'pgactive' FROM pg_catalog.pg_settings WHERE name = 'shared_preload_libraries';

   
    ?column? 
   ----------
    t

5. 次の SQL ステートメントを使用して、サンプルのテーブルを作成および設定します。

   1. 次の SQL ステートメントを使用してサンプルテーブルを作成します。

      app=> CREATE SCHEMA inventory;
      CREATE TABLE inventory.products (
      id int PRIMARY KEY, product_name text NOT NULL,
      created_at timestamptz NOT NULL DEFAULT CURRENT_TIMESTAMP);

   2. 次の SQL ステートメントを使用して、サンプルデータをテーブルに入力します。

      app=> INSERT INTO inventory.products (id, product_name)
      VALUES (1, 'soap'), (2, 'shampoo'), (3, 'conditioner');
      

   3. 次の SQL ステートメントを使用して、テーブルにデータが存在することを確認します。

       app=>SELECT count(*) FROM inventory.products;
      
       count
      -------
       3

6. 既存のデータベースで pgactive 拡張を作成します。

   app=> CREATE EXTENSION pgactive;

7. 以下のコマンドを使用して pgactive グループを作成して初期化します。

   app=> SELECT pgactive.pgactive_create_group(
       node_name := 'node1-app',
       node_dsn := 'dbname=app host=firstinstance.111122223333.aws-region.rds.amazonaws.com user=master username password=PASSWORD');

   node1-app は、pgactive グループ内のノードを一意に識別するために割り当てる名前です。

   注記

   パブリックにアクセス可能な DB インスタンスで、このステップを正常に実行するには、rds.custom_dns_resolution パラメータを 1 に設定して有効にする必要があります。

8. DB インスタンスの準備が整っているかどうかを確認するには、次のコマンドを使用します。

   app=> SELECT pgactive.pgactive_wait_for_node_ready();

   コマンドが正常に完了した場合は、次の出力が表示されます。

   
   pgactive_wait_for_node_ready 
   ------------------------------ 
   (1 row)
   

2 番目の RDS for PostgreSQL インスタンスを設定して pgactive グループに参加させるには

次の例は、RDS for PostgreSQL DB インスタンスを pgactive グループに参加させる方法と、DB インスタンスに pgactive 拡張を作成するために必要なその他のステップを示しています。

次の手順では、RDS for PostgreSQL DB インスタンスが pgactive 拡張を使用して設定されていることを前提としています。詳細については、「pgactive 拡張機能の初期化」を参照してください。

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

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

2. 次のコマンドを使用して、2 番目の RDS for PostgreSQL DB インスタンスにデータベースを作成します。

   postgres=> CREATE DATABASE app;

3. 次のコマンドを使用して、接続先を新しいデータベースに切り替えます。

   \c app

4. 既存のデータベースに pgactive 拡張を作成します。

   app=> CREATE EXTENSION pgactive;

5. 次に示すように、RDS for PostgreSQL の 2 番目の DB インスタンスを pgactive グループに参加させます。

   app=> SELECT pgactive.pgactive_join_group(
   node_name := 'node2-app',
   node_dsn := 'dbname=app host=secondinstance.111122223333.aws-region.rds.amazonaws.com user=master username password=PASSWORD',
   join_using_dsn := 'dbname=app host=firstinstance.111122223333.aws-region.rds.amazonaws.com user=postgres password=PASSWORD');

   node2-app は、pgactive グループ内のノードを一意に識別するために割り当てる名前です。

6. DB インスタンスの準備が整っているかどうかを確認するには、次のコマンドを使用します。

   app=> SELECT pgactive.pgactive_wait_for_node_ready(); 

   コマンドが正常に完了すると、次の出力が表示されます。

   
   pgactive_wait_for_node_ready 
   ------------------------------ 
   (1 row)
   

   最初の RDS for PostgreSQL データベースが比較的大きい場合は、pgactive.pgactive_wait_for_node_ready() から復元操作の進行状況レポートを出力されることを確認できます。出力は次の例のようになります:

   NOTICE:  restoring database 'app', 6% of 7483 MB complete
   NOTICE:  restoring database 'app', 42% of 7483 MB complete
   NOTICE:  restoring database 'app', 77% of 7483 MB complete
   NOTICE:  restoring database 'app', 98% of 7483 MB complete
   NOTICE:  successfully restored database 'app' from node node1-app in 00:04:12.274956
    pgactive_wait_for_node_ready 
   ------------------------------ 
   (1 row)
   

   この時点から、pgactive は 2 つの DB インスタンス間でデータを同期します。

7. 次のコマンドを使用して、2 番目の DB インスタンスのデータベースにデータがあるかどうかを確認できます。

   app=> SELECT count(*) FROM inventory.products;

   データが正常に同期されると、次の出力が表示されます。

   
    count
   -------
    3

8. 次のコマンドを実行して新しい値を挿入します。

   app=> INSERT INTO inventory.products (id, product_name) VALUES ('lotion');

9. 最初の DB インスタンスのデータベースに接続し、次のクエリを実行します。

   app=> SELECT count(*) FROM inventory.products;

   アクティブ/アクティブレプリケーションが初期化されると、出力は次のようになります。

   count
   -------
    4

pgactive グループから DB インスタンスをデタッチして削除するには

pgactive グループから DB インスタンスをデタッチして削除するには、次の手順に従います。

1. 次のコマンドを使用して、最初のインスタンスから 2 番目の DB インスタンスをデタッチできます。

   app=> SELECT * FROM pgactive.pgactive_detach_nodes(ARRAY[‘node2-app']);

2. 次のコマンドを使用して、2 番目の DB インスタンスから pgactive 拡張を削除します。

   app=> SELECT * FROM pgactive.pgactive_remove();

   拡張を強制的に削除するには

   app=> SELECT * FROM pgactive.pgactive_remove(true);

3. 次のコマンドを使用して拡張をドロップします。

   app=> DROP EXTENSION pgactive;