PostgreSQLストリーミングレプリケーション-詳細

送信者（プライマリノード）：

[[email protected] ~]# ps aux |grep postgres
postgres     727  0.0  2.2 917060 47936 ?        Ss   17:45   0:00 /usr/pgsql-14/bin/postmaster -D /var/lib/pgsql/14/data/
postgres     732  0.0  0.2 351904  5280 ?        Ss   17:45   0:00 postgres: 14/main: logger
postgres     734  0.0  0.5 917188 10560 ?        Ss   17:45   0:00 postgres: 14/main: checkpointer
postgres     735  0.0  0.4 917208  9908 ?        Ss   17:45   0:00 postgres: 14/main: background writer
postgres     736  0.0  1.0 917060 22928 ?        Ss   17:45   0:00 postgres: 14/main: walwriter
postgres     737  0.0  0.4 917748  9128 ?        Ss   17:45   0:00 postgres: 14/main: autovacuum launcher
postgres     738  0.0  0.3 917060  6320 ?        Ss   17:45   0:00 postgres: 14/main: archiver last was 00000001000000000000003F
postgres     739  0.0  0.2 354160  5340 ?        Ss   17:45   0:00 postgres: 14/main: stats collector
postgres     740  0.0  0.3 917632  6892 ?        Ss   17:45   0:00 postgres: 14/main: logical replication launcher
postgres     756  0.0  0.6 918252 13124 ?        Ss   17:45   0:00 postgres: 14/main: walsender cmon_replication 10.10.10.137(36684) streaming 0/400001C0

受信者（スタンバイノード）：

[[email protected] ~]# ps aux |grep postgres
postgres     727  0.0  2.2 917060 47576 ?        Ss   17:45   0:00 /usr/pgsql-14/bin/postmaster -D /var/lib/pgsql/14/data/
postgres     732  0.0  0.2 351904  5396 ?        Ss   17:45   0:00 postgres: 14/main: logger
postgres     733  0.0  0.3 917196  6360 ?        Ss   17:45   0:00 postgres: 14/main: startup recovering 000000010000000000000040
postgres     734  0.0  0.4 917060 10056 ?        Ss   17:45   0:00 postgres: 14/main: checkpointer
postgres     735  0.0  0.3 917060  6304 ?        Ss   17:45   0:00 postgres: 14/main: background writer
postgres     736  0.0  0.2 354160  5456 ?        Ss   17:45   0:00 postgres: 14/main: stats collector
postgres     737  0.0  0.6 924532 12948 ?        Ss   17:45   0:00 postgres: 14/main: walreceiver streaming 0/400001C0

レプリケーションがどの程度最新であるかを確認する1つの方法は、プライマリサーバーで生成されたがスタンバイサーバーではまだ適用されていないWALレコードの量を確認することです。

プライマリ：

postgres=# SELECT pg_current_wal_lsn();
 pg_current_wal_lsn
--------------------
 0/400001C0
(1 row)

スタンバイ：

postgres=# SELECT pg_last_wal_receive_lsn();
 pg_last_wal_receive_lsn
-------------------------
 0/400001C0
(1 row)
postgres=# SELECT pg_last_wal_replay_lsn();
 pg_last_wal_replay_lsn
------------------------
 0/400001C0
(1 row)

スタンバイノードで次のクエリを使用して、秒単位でラグを取得できます。

postgres=# SELECT CASE WHEN pg_last_wal_receive_lsn() = pg_last_wal_replay_lsn()
THEN 0
ELSE EXTRACT (EPOCH FROM now() - pg_last_xact_replay_timestamp())
END AS log_delay;
 log_delay
-----------
         0
(1 row)

また、最後に受信したメッセージを確認することもできます：

postgres=# SELECT status, last_msg_receipt_time FROM pg_stat_wal_receiver;
  status   |    last_msg_receipt_time
-----------+------------------------------
 streaming | 2022-04-13 18:32:39.83118+00
(1 row)

ClusterControlを使用したPostgreSQLレプリケーションの監視

PostgreSQLクラスターを監視するには、ClusterControlを使用して、展開、バックアップ、スケールアウトなどのいくつかの追加の管理タスクを監視および実行できます。

概要セクションには、データベースクラスターの全体像が表示されます。現在のステータス。詳細を確認するには、ダッシュボードセクションにアクセスしてください。ダッシュボードセクションには、さまざまなグラフに分けられた多くの役立つ情報が表示されます。

トポロジセクションでは、ユーザーの現在のトポロジを確認できます-使いやすい方法であり、[ノードアクション]ボタンを使用して、ノード上でさまざまなタスクを実行することもできます。

ストリーミングレプリケーションは、WALレコードを送信してスタンバイに適用することに基づいていますサーバーでは、どのファイルにどのバイトを追加または変更するかを指示します。その結果、スタンバイサーバーは実際にはプライマリサーバーのビットごとのコピーになります。ただし、ここにはいくつかのよく知られた制限があります：

• 別のバージョンまたはアーキテクチャに複製することはできません。

• スタンバイサーバーでは何も変更できません。

• 複製する内容の粒度はあまりありません。

したがって、これらの制限を克服するために、PostgreSQL10は論理レプリケーションのサポートを追加しました

論理レプリケーション

論理レプリケーションもWALファイルの情報を使用しますが、論理変更にデコードします。どのバイトが変更されたかを知る代わりに、どのデータがどのテーブルに挿入されたかを正確に知ることができます。

これは、「パブリッシュ」および「サブスクライブ」モデルに基づいており、1人以上のサブスクライバーが次のようなパブリッシャーノード上の1つ以上のパブリケーションをサブスクライブします。