このページでは、AlloyDB Omni バージョン 15.7.1 について説明します。別のバージョンのドキュメントを選択する。

AlloyDB Omni と他のデータベース間でデータを複製する
コレクションでコンテンツを整理必要に応じて、コンテンツの保存と分類を行います。

このページでは、pglogical 拡張機能を使用して AlloyDB Omni と他のデータベースの間でデータを複製する手順について説明します。

詳細については、pglogical 拡張機能についてと pglogical の用語と基本コンポーネントをご覧ください。

サポートされている認証方法

pglogical 拡張機能で使用される主な認証方法は、パスワード認証と信頼認証の 2 つです。

推奨される認証方法は信頼認証です。詳細については、サポートされている認証方法をご覧ください。

始める前に

pglogical は、特定のデータベース内に拡張機能としてインストールできます。

AlloyDB Omni に pglogical 拡張機能を実装する前に、以下のシステム要件を満たしていることを確認してください。

相手側となる非 AlloyDB PostgreSQL クラスタに superuser としてアクセスできる。
pglogical 拡張機能が非 AlloyDB PostgreSQL クラスタにインストールされている。リリースとディストリビューション固有のインストール手順については、pglogical をご覧ください。
AlloyDB Omni サーバーがインストールされ、構成されている。AlloyDB Omni のインストール手順については、AlloyDB Omni をインストールするをご覧ください。
非 AlloyDB PostgreSQL クラスタと AlloyDB Omni ホストサーバーの両方の IP アドレス。
非 AlloyDB PostgreSQL クラスタと AlloyDB Omni ホストサーバーの間に安全なネットワークが確立されている。標準の PostgreSQL ポート 5432 での TCP 接続が必要です。

非 AlloyDB プロバイダのパラメータを調整する

wal_level パラメータを logical に設定し、postgresql.conf ファイル内の shared_preload_libraries パラメータに pglogical を追加します。pglogical 拡張機能を使用するには、非 AlloyDB プロバイダクラスタで最小限のパラメータ調整を行う必要があります。
```
cp postgresql.conf postgresql.bak
sed -r -i "s|(\#)?wal_level\s*=.*|wal_level=logical|" postgresql.conf
sed -r -i "s|(\#)?(shared_preload_libraries\s*=\s*)'(.*)'.*$|\2'\3,pglogical'|" postgresql.conf
sed -r -i "s|',|'|" postgresql.conf
```
パラメータが正しく設定されていることを確認します。
```
grep -iE 'wal_level|shared_preload_libraries' postgresql.conf
```
パラメータの変更を有効にするため、非 AlloyDB クラスタを再起動します。

上記以外のパラメータは、すでに十分な値に設定されている場合もありますが、非 AlloyDB のディストリビューションとバージョンによっては調整が必要になることもあります。

以下のパラメータを確認します。
- max_worker_processes: プロバイダデータベースごとに 1 つ、およびサブスクライバーノードごとに少なくとも 1 つ。このパラメータの標準は少なくとも 10 です。
- max_replication_slots: プロバイダノードごとに 1 つ。
- max_wal_senders: プロバイダノードごとに 1 つ。
- track_commit_timestamp: 最後の更新と最初の更新の競合解決が必要な場合は on に設定します。
- listen_addresses: AlloyDB Omni の IP アドレスを含めるか、対象範囲を CIDR ブロックの形式で指定する必要があります。
（省略可）非 AlloyDB プロバイダが Amazon RDS または Aurora の場合は、pglogical 拡張機能を有効にし、cluster parameter group を使用して必要なパラメータを調整する必要があります。
1. 既存または新しいクラスタのパラメータグループ内で、以下のパラメータを設定します。
  - rds.logical_replication を 1 にする
  - max_replication_slots を 50 にする
  - max_wal_senders を 50 にする
  - max_worker_processes を 64 にする
  - shared_preload_libraries を pg_stat_statements, pglogical にする
2. クラスタパラメータグループの調整を有効にするため、Amazon RDS または Aurora クラスタを再起動します。

すべてのパラメータ値が適切であることを確認します。

SELECT name, setting
FROM pg_catalog.pg_settings
 WHERE name IN ('listen_addresses',
                'wal_level',
                'shared_preload_libraries',
                'max_worker_processes',
                'max_replication_slots',
                'max_wal_senders',
                'track_commit_timestamp')
 ORDER BY name;

非 AlloyDB Omni プロバイダクラスタに対するホストベースの認証の調整

pglogical は、ローカル TCP 接続を使用してプロバイダデータベースに接続します。そのため、ホストサーバーの IP アドレスを AlloyDB Omni の DATA_DIR/pg_hba.conf ファイルに追加する必要があります。ここで、DATA_DIR はデータディレクトリへのファイルシステムパスです（例: /home/$USER/alloydb-data）。

ローカルサーバーにおける新しい pglogical_replication ユーザーに固有の信頼認証エントリを DATA_DIR/pg_hba.conf ファイルに追加します。

重要: パスワード認証を使用する場合は、trust の値を削除して scram-sha-256 に置き換えます。
また、サブスクライバーノードをプロバイダノードに対して認証できる必要があります。各サブスクライバーノードの IP アドレスまたは適切な CIDR ブロック IP 範囲を DATA_DIR/pg_hba.conf ファイルに追加します。
```
echo -e "# pglogical entries:
host all pglogical_replication samehost trust
host all pglogical_replication SERVER_IP_ADDRESS/32 trust
" | column -t | sudo tee -a DATA_DIR/pg_hba.conf
```
SERVER_IP_ADDRESS は、複製元のプライマリ AlloyDB Omni インスタンスの IP アドレスに置き換えます。

注: all ではなく、正確なデータベース名を指定して接続を制限します。また、IP 範囲ではなく /32 のようなサブスクライバーノードの IP アドレスを指定することで、CIDR ブロックの IP 範囲を制限します。
エントリが正しいことを確認します。
```
tail -3 DATA_DIR/pg_hba.conf
```
パラメータの変更を有効にするため、非 AlloyDB クラスタを再起動します。

AlloyDB Omni サブスクライバークラスタのパラメータを調整する

pglogical を使用するには、AlloyDB Omni サブスクライバークラスタでも最小限のパラメータ調整を行う必要があります。DATA_DIR/postgresql.conf ファイル内の shared_preload_libraries パラメータに pglogical を追加する必要があります。クラスタ内のいずれかのデータベースがプロバイダデータベースとなる場合は、プロバイダデータベースに必要なパラメータの変更を行います。

パラメータを調整します。

sudo sed -r -i "s|(shared_preload_libraries\s*=\s*)'(.*)'.*$|\1'\2,pglogical'|" DATA_DIR/postgresql.conf

パラメータが適切に設定されていることを確認します。
```
grep -iE 'shared_preload_libraries' DATA_DIR/postgresql.conf
```
パラメータの変更を有効にするため、AlloyDB Omni を再起動します。
Docker
```
 docker container restart CONTAINER_NAME
```
CONTAINER_NAME は、起動時に AlloyDB Omni コンテナに割り当てた名前に置き換えます。
Podman
```
 podman container restart CONTAINER_NAME
```
CONTAINER_NAME は、起動時に AlloyDB Omni コンテナに割り当てた名前に置き換えます。
他のプロバイダデータベースパラメータに AlloyDB Omni のデフォルト値を設定します。
- max_worker_processes: プロバイダデータベースごとに 1 つ、およびサブスクライバーノードごとに 1 つ。
- track_commit_timestamp: 最後の更新と最初の更新の競合解決が必要な場合は on に設定します。

すべてのパラメータ値が適切であることを確認します。

Docker

docker exec CONTAINER_NAME psql -h localhost -U postgres -c "
SELECT name, setting
  FROM pg_catalog.pg_settings
 WHERE name IN ('listen_addresses',
                'wal_level',
                'shared_preload_libraries',
                'max_worker_processes',
                'max_replication_slots',
                'max_wal_senders',
                'track_commit_timestamp')
     ORDER BY name;
"

Podman

podman exec CONTAINER_NAME psql -h localhost -U postgres -c "
SELECT name, setting
  FROM pg_catalog.pg_settings
 WHERE name IN ('listen_addresses',
                'wal_level',
                'shared_preload_libraries',
                'max_worker_processes',
                'max_replication_slots',
                'max_wal_senders',
                'track_commit_timestamp')
     ORDER BY name;
"

AlloyDB Omni サブスクライバークラスタに対するホストベースの認証の調整

pglogical は、ローカル TCP 接続を使用して AlloyDB Omni サブスクライバーデータベースに接続します。そのため、サブスクライバーのホストサーバーの IP アドレスを AlloyDB Omni の DATA_DIR/pg_hba.conf ファイルに追加する必要があります。

ローカルサーバーにおける新しい pglogical_replication ユーザーに固有の信頼認証エントリを DATA_DIR/pg_hba.conf ファイルに追加します。
```
echo -e "# pglogical entries:
host all pglogical_replication samehost trust
" | column -t | sudo tee -a DATA_DIR/pg_hba.conf
```
注: all ではなく、正確なデータベース名を指定して接続を制限します。
エントリが正しいことを確認します。
```
tail -2 DATA_DIR/pg_hba.conf
```
認証の変更を有効にするため、AlloyDB Omni を再起動します。
```
docker container restart CONTAINER_NAME
```

プロバイダクラスタとサブスクライバークラスタの両方に `pglogical` ユーザーを作成する

プロバイダクラスタとサブスクライバークラスタの両方で新しいユーザーを作成する必要があります。pglogical ユーザーには superuser と replication の両方の属性が必要です。

Google Cloud AlloyDB プロバイダクラスタで、ユーザーロールを作成します。

CREATE USER pglogical_replication LOGIN PASSWORD 'secret';
ALTER USER pglogical_replication WITH replication;
ALTER USER pglogical_replication WITH superuser;

（省略可）非 AlloyDB プロバイダが Amazon RDS または Aurora の場合は、次のロールを付与する必要があります。
```
GRANT rds_superuser TO replication_user;
```
注: 非 AlloyDB データベースがこれら以外のクラウドマネージドサービスに由来する場合は、サービス固有のカスタム権限が必要になる場合があります。

非 AlloyDB プロバイダデータベースに `pglogical` とノードを追加する

必要な権限を付与します。

各データベースに pglogical 拡張機能をインストールし、pglogical データベースユーザーに usage 権限を付与する必要があります。

たとえば、データベースが my_test_db の場合は、次のコマンドを実行します。
```
CREATE EXTENSION IF NOT EXISTS pglogical;
GRANT usage ON SCHEMA pglogical TO pglogical_replication;
```
プロバイダデータベースの pglogical ノードを作成します。node_name の指定は任意で、dsn 文字列には同じデータベースへの有効な TCP 接続を指定する必要があります。

重要: クラウドマネージドサービスデータベースを使用する場合は、パスワード認証が必要です。セルフマネージド PostgreSQL デプロイメントでパスワード認証を使用することを選択できます。その場合は、dsn 文字列にパスワードを含めます。セルフマネージドインストールを使用する場合は、パスワード認証または信頼認証を使用できます。
たとえば、my_test_db データベースの場合は、次のコマンドを実行します。
```
SELECT pglogical.create_node(node_name := 'provider', dsn := 'host=SERVER_IP_ADDRESS port=5432 dbname=my_test_db user=pglogical_replication password=secret');
```
注: 非 AlloyDB プロバイダが Amazon RDS または Aurora の場合は、dsn パラメータにおいて、ホスト IP アドレスではなく指定された AWS エンドポイントを使用します。非 AlloyDB データベースがこれら以外のクラウドマネージドサービスに由来する場合は、サービス固有のエンドポイントまたは IP アドレスが必要です。

テーブルを作成してデフォルトレプリケーションセットに追加する

テーブルを作成し、非 AlloyDB プロバイダデータベースのデフォルトレプリケーションセットに追加します。

プロバイダデータベースに test_table_1 という名前のテストテーブルを作成します。
```
CREATE TABLE test_table_1 (col1 INT PRIMARY KEY);
INSERT INTO test_table_1 VALUES (1),(2),(3);
```
このテストテーブルを手動でデフォルトレプリケーションセットに追加します。カスタムの pglogical レプリケーションセットを作成することも、デフォルトのレプリケーションセットを使用することもできます。拡張機能の作成時に、default、default_insert_only、ddl_sql などのデフォルトレプリケーションセットが作成されています。テーブルとシーケンスをレプリケーションセットに個別に追加することも、指定したスキーマに対応するものをすべて一度に追加することもできます。
```
-- Add the specified table to the default replication set:
SELECT pglogical.replication_set_add_table(set_name := 'default', relation := 'test_table_1', synchronize_data := TRUE);

-- Check which tables have been added to all replication sets:
SELECT * FROM pglogical.replication_set_table;
```

（省略可）指定したスキーマ（public など）内のすべてのテーブルを追加します。

-- Add all "public" schema tables to the default replication set:
SELECT pglogical.replication_set_add_all_tables('default', ARRAY['public']);

-- Check which tables have been added to all replication sets:
SELECT * FROM pglogical.replication_set_table;

-- Add all "public" schema sequences to the default replication:
SELECT pglogical.replication_set_add_all_sequences('default', ARRAY['public']);

-- Check which sequences have been added to all replication sets:
SELECT * FROM pglogical.replication_set_seq;

default レプリケーションセットからテーブルを削除します。主キーまたはレプリカ ID を持たないテーブルがスキーマ内にある場合、複製できるのは INSERT ステートメントのみです。このようなテーブルを replication_set_add_all_tables 関数によって default レプリケーションセットに自動的に追加した場合は、それらのテーブルをそのレプリケーションセットから手動で削除し、default_insert_only セットに追加する必要があります。
```
-- Remove the table from the **default** replication set:
SELECT pglogical.replication_set_remove_table(set_name := 'default', relation := 'test_table_2');

-- Manually add to the **default_insert_only** replication set:
SELECT pglogical.replication_set_add_table(set_name := 'default_insert_only', relation := 'test_table_2');
```
（省略可）新しく作成したテーブルをレプリケーションセットに自動的に追加したい場合は、pglogical のソースに示されている pglogical_assign_repset トリガーを追加します。

データベースを AlloyDB Omni サブスクライバークラスタにコピーする

pg_dump ユーティリティを使用して、ソースデータベースのスキーマのみのバックアップを作成します。
AlloyDB Omni サブスクライバーサーバーから、非 AlloyDB サーバーの IP アドレスまたはエンドポイントを使用して pg_dump コマンドを実行します。

注: pg_dump コマンドは、AlloyDB Omni コンテナの外部から実行する必要があります。PostgreSQL クライアントをインストールできる場合は、AlloyDB Omni ホストサーバーから pg_dump コマンドを実行することをおすすめします。必要に応じて、別のサーバーからこのコマンドを実行することもできます。
```
pg_dump -h SERVER_IP_ADDRESS -U postgres --create --schema-only my_test_db > my_test_db.schema-only.sql
```
注: 非 AlloyDB プロバイダが Amazon RDS または Aurora の場合は、dsn パラメータにおいて、ホスト IP アドレスではなく指定された AWS エンドポイントを使用します。非 AlloyDB データベースがこれら以外のクラウドマネージドサービスに由来する場合は、サービス固有のエンドポイントまたは IP アドレスが必要です。

作成したバックアップを、サブスクライバー AlloyDB Omni サーバーのサブスクライバーデータベースにインポートします。

Docker

docker exec -i CONTAINER_NAME psql -h localhost -U postgres < my_test_db.schema-only.sql

Podman

podman exec -i CONTAINER_NAME psql -h localhost -U postgres < my_test_db.schema-only.sql

これにより、行データのないデータベースとスキーマが作成されます。行データは pglogical 拡張機能によって複製されます。他に必要なユーザーまたはロールがあれば、手動でコピーするか再作成します。

AlloyDB Omni サブスクライバーデータベースにノードとサブスクリプションを作成する

AlloyDB Omni サブスクライバーデータベースにノードを作成します。パスワード認証を使用する場合は、パスワードを dsn に追加します。

Docker

docker exec CONTAINER_NAME psql -h localhost -U postgres -d my_test_db -c "
SELECT pglogical.create_node(node_name := 'subscriber', dsn := 'host=localhost port=5432 dbname=my_test_db user=pglogical_replication');
"

Podman

podman exec CONTAINER_NAME psql -h localhost -U postgres -d my_test_db -c "
SELECT pglogical.create_node(node_name := 'subscriber', dsn := 'host=localhost port=5432 dbname=my_test_db user=pglogical_replication');
"

AlloyDB Omni プロバイダサーバーのプロバイダデータベースを指すサブスクリプションをサブスクライバーデータベースに作成します。

注: クラウドマネージドサービス PostgreSQL データベースでは、信頼認証は使用できません。dsn パラメータにパスワード引数を含める必要があります。
注意: dsn パラメータに指定した接続情報が正しいことを確認してください。
Docker
```
docker exec CONTAINER_NAME psql -h localhost -U postgres -d my_test_db -c "
SELECT pglogical.create_subscription(subscription_name := 'test_sub_1', provider_dsn := 'host=SERVER_IP_ADDRESS port=5432 dbname=my_test_db user=pglogical_replication password=secret');
"
```
Podman
```
podman exec CONTAINER_NAME psql -h localhost -U postgres -d my_test_db -c "
SELECT pglogical.create_subscription(subscription_name := 'test_sub_1', provider_dsn := 'host=SERVER_IP_ADDRESS port=5432 dbname=my_test_db user=pglogical_replication password=secret');
"
```
注: 非 AlloyDB プロバイダが Amazon RDS または Aurora の場合は、dsn パラメータにおいて、ホスト IP アドレスではなく指定された AWS エンドポイントを使用します。非 AlloyDB データベースがこれら以外のクラウドマネージドサービスに由来する場合は、サービス固有のエンドポイントまたは IP アドレスが必要です。
数秒または数分以内に、初期データがプロバイダからサブスクライバーに複製されます。
Docker
```
docker exec CONTAINER_NAME psql -h localhost -U postgres -d my_test_db -c "
SELECT * FROM test_table_1 ORDER BY 1;
"
```
Podman
```
podman exec CONTAINER_NAME psql -h localhost -U postgres -d my_test_db -c "
SELECT * FROM test_table_1 ORDER BY 1;
"
```
プロバイダデータベースに新しく追加された行も、リアルタイムで（数秒以内に）複製されます。

`pglogical` デプロイメントに関するその他の考慮事項

pglogical 拡張機能には、このドキュメントでは取り上げていない高度な機能が多数あります。これらの機能の多くをご使用の環境に実装できます。たとえば、次のような高度な機能があります。

競合の解決
マルチマスターレプリケーションと双方向レプリケーション
シーケンスの包含
スイッチオーバーとフェイルオーバーの手順

次のステップ

Google Cloud AlloyDB と AlloyDB Omni の間でデータを複製する
pglogical レプリケーションによるスイッチオーバーとフェイルオーバー

AlloyDB Omni と他のデータベース間でデータを複製する コレクションでコンテンツを整理 必要に応じて、コンテンツの保存と分類を行います。

サポートされている認証方法

始める前に

非 AlloyDB プロバイダのパラメータを調整する

非 AlloyDB Omni プロバイダ クラスタに対するホストベースの認証の調整

AlloyDB Omni サブスクライバー クラスタのパラメータを調整する

Docker

Podman

Docker

Podman

AlloyDB Omni サブスクライバー クラスタに対するホストベースの認証の調整

プロバイダ クラスタとサブスクライバー クラスタの両方に pglogical ユーザーを作成する

非 AlloyDB プロバイダ データベースに pglogical とノードを追加する

テーブルを作成してデフォルト レプリケーション セットに追加する

データベースを AlloyDB Omni サブスクライバー クラスタにコピーする

Docker

Podman

AlloyDB Omni サブスクライバー データベースにノードとサブスクリプションを作成する

Docker

Podman

Docker

Podman

Docker

Podman

pglogical デプロイメントに関するその他の考慮事項

次のステップ

AlloyDB Omni と他のデータベース間でデータを複製する
コレクションでコンテンツを整理必要に応じて、コンテンツの保存と分類を行います。

非 AlloyDB Omni プロバイダクラスタに対するホストベースの認証の調整

AlloyDB Omni サブスクライバークラスタのパラメータを調整する

AlloyDB Omni サブスクライバークラスタに対するホストベースの認証の調整

プロバイダクラスタとサブスクライバークラスタの両方に `pglogical` ユーザーを作成する

非 AlloyDB プロバイダデータベースに `pglogical` とノードを追加する

テーブルを作成してデフォルトレプリケーションセットに追加する

データベースを AlloyDB Omni サブスクライバークラスタにコピーする

AlloyDB Omni サブスクライバーデータベースにノードとサブスクリプションを作成する

`pglogical` デプロイメントに関するその他の考慮事項