Joining additional PGD nodes

Joining additional PGD nodes#

このフェーズでは、PGDクラスターを単一ノードを超えて拡張して、高可用機能を有効にし、最終的なアプリケーションのカットオーバーの前に冗長性を確立します。 BDRは外部論理レプリケーションストリームから到着したデータを自動的に転送しないため、ソースノードは独自の専用論理レプリケーションストリームを介して各PGDノードに個別にフィードする必要があります。このアーキテクチャにより、移行中にクラスター全体でデータの一貫性が保証されます。

この手順には、 物理的結合 と呼ばれる、内部でpg_basebackup を使用する物理コピーを介した高速データ転送が含まれます。このプロセスは、 PGD CLIを介して自動化されています。

PGDパッケージのインストール#

追加ノードには、Postgresディストリビューションとバージョンたとえば、EPAS 17のedb-pgd6-expanded-epas17 などと一致するPGDパッケージが必要です。続行する前に、適切なPGDリポジトリを構成していることを確認してください。詳細は、 Installing the database and pgd を参照してください。

  1. BDR拡張機能を有効にするには、Postgres構成を更新してライブラリをプリロードし、シードノードでコミットタイムスタンプを有効にします。

cat >> ${PGDATA}/postgresql.conf <<EOF
shared_preload_libraries = bdr
track_commit_timestamp = on
EOF

  1. Postgresを再起動してBDR拡張機能をロードします。

su -u enterprisedb --command "pg_ctl restart"

ソースノードでの追加のレプリケーションスロットの作成#

新しいノードを追加するには、ソースノードに専用のレプリケーションスロットを作成する必要があります。新しいノードのデータを調整するには、シードノードをリファレンスポイントとして使用し、そのレプリケーションを一時的に一時停止して、一貫したスイッチオーバーLSNを確立します。

  1. ソースノードで、追加のPGDノードの追加レプリケーションスロットを作成します。

SELECT pg_create_logical_replication_slot(migration_node_${ADD_NODE_PGD_NAME},
    pgoutput);

  1. シードノードで、ソースノードからの論理レプリケーションを一時停止します。

ALTER SUBSCRIPTION migration_seed_sub DISABLE;

  1. レプリケーションが一時停止しているときに、新しいスロットをシードノードのLSNと合わせて、正確なスイッチオーバーポイントをマークします。ソースノードで、次を実行してスロットを進めます

SELECT pg_replication_slot_advance(migration_node_${ADD_NODE_PGD_NAME},
    (SELECT confirmed_flush_lsn
        FROM pg_replication_slots
        WHERE slot_name = migration_node_${SEED_NODE_PGD_NAME}));

  1. ソースノードで、どちらのスロットも進んでいないことを確認しますLSNが静的なままで遅延が増加するはずです。

SELECT slot_name, active, restart_lsn, confirmed_flush_lsn,
    pg_size_pretty(pg_wal_lsn_diff(pg_current_wal_lsn(), restart_lsn)) AS lag_size
FROM pg_replication_slots;

  1. ソースノードで、スタンバイからのアクティブな接続を確認します。シードノードも追加ノードのエントリを表示してはなりません。

SELECT client_addr, state, sent_lsn, write_lsn, flush_lsn, replay_lsn,
    pg_size_pretty(pg_wal_lsn_diff(sent_lsn, replay_lsn)) AS replay_lag
FROM pg_stat_replication;

追加のPGDノードへの参加#

PGD CLIは、物理的結合を介してデータ転送プロセスを自動化します。これは、 pg_basebackup を内部で使用して、新しいノードにシードノードのクローンを作成します。

  1. 追加のPGDノードで、次を実行します。

su postgres -c pgd node ${ADD_NODE_PGD_NAME} setup      \
    --listen-addr="*"                                    \
    --initial-node-count=3                               \
    --pgdata=${PGDATA}                                   \
    --group-name ${PGD_CLUSTER_NAME}                     \
    --cluster-dsn "${SEED_NODE_DSN}"                     \
    --dsn "${ADD_NODE_DSN}"                              \
    --verbose

  1. 完了したら、新しいノードがACTIVE であり、シードノードから可視であることを確認します。

SELECT * FROM bdr.node_summary;

警告

PGDクラスターがアクティブになり、ほとんどのDDL操作を含むすべての変更をレプリケートします。ノード固有の操作を実行する前にDDLレプリケーション`SET bdr.ddl_replication = off` を無効にして、意図しない伝播を防ぎます。アプリケーションがスイッチオーバーするまで、PGDノードにDML変更を直接適用しないでください。

ソースノードからのレプリケーションの再開#

両方のノードが同じLSNに同期すると、論理データフローを再開できます。

  1. シードノードで、ソースノードからの論理レプリケーションを再度有効にします。

SET bdr.ddl_replication = off;
ALTER SUBSCRIPTION migration_seed_sub ENABLE;

  1. 追加ノードでは、サブスクリプションは物理的参加中に意図的にコピーされません。これを手動で作成し、ソースノードの専用スロットを指す必要があります。

SET bdr.ddl_replication = off;
CREATE SUBSCRIPTION migration_add_sub
    CONNECTION ${SOURCE_NODE_DSN}
    PUBLICATION migration_seed_pub    -- same publication, can be used multiple times
    WITH (
        enabled = false,
        copy_data = false,
        create_slot = false,
        slot_name = migration_node_${ADD_NODE_PGD_NAME}
    );

  1. 追加ノードで、サブスクリプションのテーブルリストが シードノードへの論理レプリケーションの有効化 で取得した構成と一致することを確認します。

SELECT n.nspname AS schemaname,
    c.relname AS tablename,
    sr.srsubstate AS state,
    s.subname AS subscription_name
FROM pg_subscription_rel sr
JOIN pg_class c ON sr.srrelid = c.oid
JOIN pg_namespace n ON c.relnamespace = n.oid
JOIN pg_subscription s ON sr.srsubid = s.oid
WHERE s.subname = migration_seed_sub
ORDER BY n.nspname, c.relname;

  1. 追加ノードで、サブスクリプションを有効にしてソースノードからレプリケーションを再開します。

SET bdr.ddl_replication = off;
ALTER SUBSCRIPTION migration_seed_sub ENABLE;

すべてのレプリケーションストリームの検証#

すべてのノードがソースからデータを受信し、PGDクラスター内で通信していることを確認します。データはPGDからソースノードに逆流しないことに注意してください。

  1. ソースノードで、次のクエリーを実行して、非PGD論理サブスクリプションラグを確認します。

SELECT slot_name, active, confirmed_flush_lsn, pg_size_pretty(pg_wal_lsn_diff(pg_current_wal_lsn(), confirmed_flush_lsn)) as lag FROM pg_replication_slots;

PGDノードごとに1つのエントリ、および遅延は最小限であることが予想されます。

  1. 各PGDノードで、 PGDメッシュとレプリケーションのステータスを確認します。 PGDクラスターのアイドル状態のため、トラフィックは非常に少ないと予想されますが、遅延はありません。

SELECT * FROM bdr.node_summary;
SELECT * FROM bdr.subscription_summary;
SELECT * FROM bdr.node_replication_rates;

次のステップ Application cutover 。

目次