PGConf.ASIA 2017 Logical Replication Internal

Transcription

1 PGConf.ASIA 2017 Logical Replication Internals Noriyoshi Shinoda December 8, 2017

2 自己紹介篠田典良 ( しのだのりよし ) 所属 日本ヒューレット パッカード株式会社 Pointnext 事業統括 現在の業務 PostgreSQL をはじめ Oracle Database, Microsoft SQL Server, Vertica, Sybase ASE 等 RDBMS 全般に関するシステムの設計 チューニング コンサルティング Oracle ACE Oracle Database 関連書籍の執筆 オープンソース製品に関する調査 検証 関連する URL PostgreSQL 虎の巻 シリーズ Oracle ACE ってどんな人? 2

3 Agenda Logical Replicationとは? 試してみよう アーキテクチャ 制約 トラブルシューティング 今後に期待 Master / Slave マスター / スレーブ PUB/SUB 表記を統一 3

4 Logical Replication とは? 4

5 Logical Replication とは? Logical Replication とは? IS PostgreSQL 10 の新機能 テーブル単位のレプリケーション テーブルの データ をレプリケーションする機能 トランザクション単位のレプリケーション SQL 文の結果が同一になることを保証 Publish / Subscribe モデルを使用 Slony-I IS NOT SQL の再実行 物理的なページ フォーマットの一致 5

6 Logical Replication とは? 基礎となるテクノロジー Streaming Replication (9.0) Background Worker process (9.3) Logical Decoding (9.3) WAL をデコードする 機能 Replication Slot (9.4) Logical Replication Slot pgoutput plugin Replication Origin (9.5) pglogical Extension (2ndQuadrant) 6

7 Logical Replication とは? 利用シナリオ 部分レプリケーション 拠点間でマスター データだけ同期したい 分析用インスタンスで テーブルにインデックスを追加したい 分析結果を別テーブルに保存したい バージョンアップ PostgreSQL 11 への無停止バージョンアップ 7

8 Logical Replication とは? Streaming Replication との比較 比較項目 Streaming Replication Logical Replication スキーマ名同一同一 テーブル名同一同一 列名同一同一 列データ型同一同一 (*) 列の定義順同一異なっていてもよい 列追加不可可能 追加インデックス作成不可可能 更新 DML すべて伝播する選択可能 DDL 伝播する伝播しない - (*) 暗黙の型変換ができれば異なっていても良い 8

9 Logical Replication とは? Streaming Replication との比較 比較項目 Streaming Replication Logical Replication レプリケーション範囲クラスター全体テーブル単位 System Identifier 同一異なっていてもよい スレーブの動作 Read Only Read Write 文字コード同一異なっていてもよい バージョン同一異なっていてもよい Replication Slot 利用しなくてもよい必須 データベース名同一異なっていてもよい テーブルの所有者同一異なっていてもよい 9

10 試してみよう 10

11 試してみよう PUBLISH インスタンス上の操作 - REPLICATION 属性 /LOGIN 属性を持つロール作成 - ターゲット インスタンスから接続されるロール マニュアル上は REPLICATION のみ pubdb=# CREATE ROLE repusr1 PASSWORD 'Passw0rd' LOGIN REPLICATION ; CREATE ROLE - テーブル所有者にデータベースの CREATE 権限を付与 pubdb=# GRANT CREATE ON DATABASE pubdb TO pubusr ; GRANT - pg_hba.conf ファイルの修正 # TYPE DATABASE USER ADDRESS METHOD host pubdb repusr /32 md5 - DATABASE=replication 項目不要 11

12 試してみよう PUBLISH インスタンス上の操作 - パラメーター wal_level の変更 pubdb=> SHOW wal_level ; wal_level logical (1 row) 12

13 試してみよう PUBLISH データベース (pubdb) 上の操作 レプリケーション対象テーブルの作成 ( アプリケーション要件 ) pubdb=> CREATE TABLE data1 (c1 INT PRIMARY KEY, c2 VARCHAR(5)) ; CREATE TABLE レプリケーション対象テーブルの参照を接続ユーザーに許可 pubdb=> GRANT SELECT ON data1 TO repusr1 ; GRANT PUBLICATION オブジェクトの作成 pubdb=> CREATE PUBLICATION pub1 FOR TABLE data1 ; CREATE PUBLICATION 13

14 試してみよう SUBSCRIBE データベース (subdb) 上の操作 レプリケーション対象テーブルの作成 subdb=> CREATE TABLE data1 (c1 INT PRIMARY KEY, c2 CHAR(5)) ; CREATE TABLE PUBLICATION オブジェクトの作成 (SUPERUSER) subdb=# CREATE SUBSCRIPTION sub1 CONNECTION 'host=srchost1 dbname=srcdb user=repusr1 password=passw0rd' PUBLICATION pub1 ; CREATE SUBSCRIPTION 14

15 試してみようレプリケーション確認 確認 (PUBLISH データベース ) pubdb=# SELECT application_name, state, sync_state FROM pg_stat_replication ; application_name state sync_state sub1 streaming async (1 row) 確認 (SUBSCRIBE データベース ) subdb=# SELECT subname, received_lsn FROM pg_stat_subscription ; subname received_lsn sub1 0/1C8FF738 15

16 試してみようログ PUBLICATION LOG: starting logical decoding for slot "subx" SUBSCRIPTION 作成 LOG: logical replication apply worker for subscription "sub2" has started LOG: logical replication table synchronization worker for subscription "sub2", table "data2" has started LOG: logical replication table synchronization worker for subscription "sub2", table "data2" has finished DETAIL: streaming transactions committing after 0/280718B0, reading WAL from 0/ LOG: logical decoding found consistent point at 0/ DETAIL: There are no running transactions. 16

17 アーキテクチャ 17

18 アーキテクチャ PUBLICATION と SUBSCRIPTION の関係 Publish Instance Publish Database PUBLICATION Tables Tables Subscribe Instance Subscribe Database SUBSCRIPTION Tables Tables WAL decode pgoutput plugin wal sender message logical replication worker 18

19 アーキテクチャプロセス wal sender process {user} {client ip} {state} PUBLICATION インスタンスで起動 WAL デコード メッセージ送信プロセス SUBSCRIPTION からの接続単位に起動 bgworker: logical replication launcher PUBLICATION/SUBSCRIPTION インスタンスで起動 logical replication worker を起動 bgworker: logical replication worker for subscription {oid} SUBSCRIPTION インスタンスで起動 wal sender process に接続 WAL デコード メッセージを受信し テーブルを更新 SUBSCRIPTION 単位に起動 19

20 アーキテクチャー関連パラメーター (PUBLICATION) パラメーター必要な設定 ( デフォルト ) max_wal_senders SUBSCRIPTION + 1 数以上 (8) wal_level logical(replica) max_replication_slots SUBSCRIPTION + 1 数以上 (10) synchronous_standby_names synchronous_commit wal_sender_timeout log_replication_commands 任意 ('') 任意 (on)???? 任意 (1min) 任意 (off) max_worker_processes = 0 にすると logical replication launcher プロセスが起動しません しかしソース インスタンスには影響しません 必要数とパラメーターの説明がごっちゃ? 20

21 アーキテクチャー関連パラメーター (SUBSCRIPTION) パラメーター必要な設定 ( デフォルト ) max_logical_replication_workers SUBSCRIPTION 数 +1(4) max_worker_processes SUBSCRIPTION 数 +1(8) max_sync_workers_per_subscription wal_receiver_timeout wal_writer_delay??? SUBSCRIPTIONで使用するワーカー プロセス数 (2) PUBLICATION の生存確認に使用 (1min) PUBLICATION の生存確認時間のチェック間隔 (200ms) max_sync_workers_per_subscription は動作していない? 説明と必要数がごっちゃになっている 21

22 アーキテクチャー PUBLICATION 作成時の動作 pg_publication カタログに情報格納 伝播する DML(INSERT / UPDATE / DELETE) 全テーブルを対象とするか (FOR ALL TABLES) pg_publication_rel カタログに情報格納 レプリケーション対象のテーブル OID pg_replication_tables カタログはテーブル名を参照できる WITH 句の指定 伝播する DML(INSERT / UPDATE / DELETE) 22

23 アーキテクチャ SUBSCRIPTION 作成時の動作 pg_subscription カタログに情報格納 接続先インスタンスの情報 Replication Slot 名 PUBLICATION 名 同期 / 非同期レプリケーションの情報 PUBLICATION 側インスタンスに接続 接続ユーザーの REPLICATION 権限のチェック Logical Replication Slot 作成 Replication Slot の名前はデフォルトは SUBSCRIPTION 名 PUBLICATION が存在するかはチェックされない pg_subscription_rel カタログにレプリケーション対象テーブルを登録 初期データのロード 非同期に実行される SUBSCRIPTION 側の既存データは削除されない 23

24 アーキテクチャ SUBSCRIPTION 作成時の動作 WITH の説明 PUBLICATION へ接続する 初期データのコピーを行う Replication Slot 名 Replication Slot を作成するか 有効 / 無効 同期コミット設定 24

25 アーキテクチャ初期データのロード Source Instance Backend process 2. Create Replication Slot Target Instance Backend process 1.CREATE SUBSCRIPTION wal sender process 3. Create Temporary Replication Slot logical replication worker Load Initial Data 4. COPY TO STDOUT statement wal sender process logical replication worker Transaction Data 25

26 アーキテクチャ初期データのロード 初期同期ログ (SUBSCRIPTION instance) LOG: logical replication table synchronization worker for subscription "sub1", table "data1" has started LOG: logical replication table synchronization worker for subscription "sub1", table "data1" has finished 26

27 アーキテクチャ Replication Slot Logical Replication Slot SUBSCRIPTION と 1 対 1 で構成 送信済 WAL の管理 プラグインの提供 SUBSCRIPTION 作成時に以下の SQL 文を実行 pg_create_logical_replication_slot ( name, 'pgoutput' ) スロット名 デフォルトでは SUBSCRIPTION 名 CREATE SUBSCRIPTION WITH (slot_name=name) で変更可能 27

28 アーキテクチャ pgoutput プラグイン pgoutput プラグイン Logical Replication 用の標準プラグイン wal sender プロセスから利用 WAL から Logical Replication メッセージを作成 テキスト フォーマット 文字コード変換 バイナリーからテキスト変換 Protocol URL 更新対象列を特定するデータと更新後のデータが送信 Replica Identity 28

29 アーキテクチャメッセージ テキスト フォーマット テキスト変換時にエラーが発生する可能性 Protocol URL Replica Identityの話 更新対象列を特定するデータと更新後のデータが送信 Replica Identity 29

30 アーキテクチャ Replica Identity 比較項目 PUBLICATION SUBSCRIPTION PRIMARY KEY O O REPLICA IDENTITY FULL REPLICA IDENTITY + UNIQUE + NOT NULL O O 主キーまたは REPLICA IDENTITY 設定が無いテーブルに対する UPDATE / DELETE は SQL 実行エラー postgres=> UPDATE data1 SET c2='update' WHERE c1=100 ; ERROR: cannot update table "data1" because it does not have replica identity and publishes updates HINT: To enable updating the table, set REPLICA IDENTITY using ALTER TABLE. O 30

31 アーキテクチャ DML 実行時の動作 ( 非同期 ) wal 1COMMIT backend 3SIGUSR1 sender 4To Slave 4COMMIT 2WAL pgoutput 31

32 アーキテクチャ DML 実行時の動作 ( 同期 ) wal 1COMMIT backend 3SIGUSR1 sender 4To Slave 5COMMIT 4SIGUSR1 2WAL pgoutput 32

33 アーキテクチャ statement_timeout SUBSCRIPTION 側テーブルを LOCK TABLE でロックして検証 wal_sender_timeout のエラーかも Pub error LOG: terminating walsender process due to replication timeout LOG: starting logical decoding for slot "sub1" DETAIL: streaming transactions committing after 0/5600ED48, reading WAL from 0/5600ED10 LOG: logical decoding found consistent point at 0/5600ED :01: JST [7294] DETAIL: There are no running transactions. Sub error ERROR: could not send data to WAL stream: server closed the connection unexpectedly This probably means the server terminated abnormally before or while processing the request. LOG: worker process: logical replication worker for subscription (PID 6911) exited with exit code 1 33

34 アーキテクチャストレージ 論理ログ wal sender プロセスが wal writer プロセスから SIGUSR1 シグナルを受信すると作成 WAL ファイルの読み込みを行いデータを作成 トランザクション単位で作成? ${PGDATA}/pg_logical/snapshots/{LSN 上位 }-{LSN 下位 }.snap スレーブ遅延時の論理ログ スレーブ インスタンスが停止し wal sender が再起動された場合に作成 転送が完了すると削除される ${PGDATA}/pg_replslot/{SLOT_NAME}/xid-{XID}-lsn-{LSN 上位 }-{LSN 下位 }.snap 34

35 アーキテクチャ内部動作 (Snapshot) 1WAL writer WAL sender 2WAL 3Logical Log 4Replication Slot stat 35

36 アーキテクチャ内部動作 FROM wal sender Logical Replication Worker WAL 36

37 設定方法同期レプリケーションの設定方法 デフォルト設定では非同期になる Master synchronous_standby_names Slave CREATE SUBSCRIPTION CONNECTION application_name = ap WITH (SYNCHRONOUS_COMMIT = on) Application_name = subscription_name 37

38 アーキテクチャログ PUBLICATION DOWN ERROR: could not receive data from WAL stream: server closed the connection unexpectedly This probably means the server terminated abnormally before or while processing the request. LOG: worker process: logical replication worker for subscription (PID 10356) exited with exit code 1 LOG: logical replication apply worker for subscription "subt1" has started WARNING: terminating connection because of crash of another server process DETAIL: The postmaster has commanded this server process to roll back the current transaction and exit, because another server process exited abnormally and possibly corrupted shared memory. HINT: In a moment you should be able to reconnect to the database and repeat your command. ERROR: could not receive data from WAL stream: server closed the connection unexpectedly This probably means the server terminated abnormally before or while processing the request. LOG: worker process: logical replication worker for subscription (PID 10354) exited with exit code 1 ERROR: could not connect to the publisher: FATAL: the database system is in recovery mode LOG: worker process: logical replication worker for subscription (PID 10369) exited with exit code 1 LOG: logical replication apply worker for subscription "sub1" has started 38

39 制約 39

40 制約レプリケーションできない SQL TRUNCATE ALTER TABLE 40

41 制約レプリケーションできないオブジェクト PUBLICATION に追加できるのはテーブル (pg_class.relkind='r') のみ レプリケーション対象外 MATERIALIZED VIEW INDEX SEQUENCE FOREIGN TABLE UNLOGGED TABLE INHERIT TABLE = OK (ONLY 句 ) Partition parent table Large Object User Defined Type? Array Json 41

42 制約 SRIAL / GENERATED AS IDENTITY SERIAL 列は内部的に SEQUENCE を使用 シーケンス値が転送されるが シーケンスの操作は行われない 42

43 制約トリガー 統計情報は? 一部だけ実行される ROW TRIGGER のみ STATEMENT TRIGGER は初期データ移行時のみ実行 SUB 側 ALTER TABLE ENABLE ALWAYS REPLICA TRIGGER 文が必要 Bug? BEFORE ROW DELETE トリガーが発行されない b12f6a8e83b で FIX The logical replication apply process currently only fires row triggers, not statement triggers. The initial table synchronization, however, is implemented like a COPY command and thus fires both row and statement triggers for <command>insert</command>. 43

44 制約パラメーター log_statement SQL を再実行しているわけではないので log_statement = all にしてもレプリケーションの更新ログは出ない 44

45 制約双方向レプリケーション 同一テーブルを使った双方向レプリケーション不可 設定はできるが WAL が循環してエラーになる テーブルが別々であればデータベース間の相互レプリケーションは可能 ログ pg_resetlowal すると? pg_replication_origin_advance では解消できなかった ALTER SUB REFRESH では? 45

46 制約インスタンス内レプリケーション インスタンス内レプリケーションには注意が必要 単純に環境を作ろうとすると CREATE SUBSCRIPTION 文がハング SUBSCRIPTION と Replication Slot を別々に作成する必要がある Logical Replication Slot の作成 pubdb=# SELECT pg_create_logical_replication_slot ('sub1', 'pgoutput') ; SUBSCRIPTION の作成 subdb=# CREATE SUBSCRIPTION sub1 CONNECTION 'dbname=pubdb' WITH (CONNECT=off) ; 46

47 制約 Streaming Replication との組み合わせ Streaming Replication 環境との混在可能 スタンバイ インスタンスからの Logical Replication 不可 Replication Slot は Streaming Replication 対象外 Logical Replication Slot はスタンバイ インスタンスでは作成不可 Logical Decoding はスタンバイ インスタンスでは実行不可 スイッチ オーバーを検知できない PUBLICATION 側で pg_create_logical_replication_slot 実行 ALTER SUBSCRIPTION CONNECTION で接続先変更 47

48 制約 Streaming Replication との組み合わせ スレーブ インスタンス上で CREATE PUBLICATION 文はエラー (ERROR: cannot execute CREATE PUBLICATION in a read-only transaction) CREATE SUBSCRIPTION 文はエラー ( 同上 ) マスターで作成した PUBLICATION/SUBSCRIPTION は伝播する スレーブ インスタンスを Logi Rep のマスターに CREATE SUBSCRIPTION 文はエラー (ERROR: could not create replication slot sub1 : ERROR: logical decoding cannot be used while in recovery) マスター上に作成されたレプリケーション スロット ストリーミング レプリケーションのスレーブには伝播しない 48

49 制約 *** カスケード構成 OK 文字コードの変換は OK ただし文字集合には要注意 異なる OS でも OK LOB INHERIT / PARTITION master 列追加 / 削除後も slave 列追加 / 削除すればレプリケーションは継続? 49

50 トラブルシューティング 50

51 トラブルシューティングリソース不足のログ max_replication_slots 不足 (PUBLICATION) ERROR: could not create replication slot "sub1": ERROR: all replication slots are in use max_wal_senders 不足 (PUBLICATION) ERROR: could not create replication slot "sub1": ERROR: all replication slots are in use max_logical_replication_workers 不足 (SUBSCRIPTION) WARNING: out of logical replication worker slots HINT: You might need to increase max_logical_replication_workers. max_worker_processes 不足 (SUBSCRIPTION) ログ無し 51

52 トラブルシューティングその他 初期データコピー時の権限不足 (PUBLICATION) ERROR: could not start initial contents copy for table "public.data1": ERROR: permission denied for relation data1 DROP SUBSCRIPTION 文の実行 ( 正常 ) FATAL: terminating logical replication worker due to administrator command LOG: worker process: logical replication worker for subscription (PID 77332) exited with exit code 1 52

53 トラブルシューティング衝突パターンと動作 SUBSCRIPTION 側で発生する衝突と動作 衝突パターンレプリケーション動作ログ出力 主キー違反 / 一意キー違反停止あり CHECK 制約違反停止あり WAL 変換エラー停止あり 更新データが存在しない継続なし 削除データが存在しない継続なし テーブルが存在しない停止あり 一部の列が存在しない停止あり データ型の変換エラー停止あり テーブル ロック待機なし 更新対象レコード ロック待機なし 53

54 トラブルシューティングエラー発生時の動作とログ エラー発生時の動作 制約違反を検知すると logical replication worker プロセス停止 5 秒後に再起動し ログ適用を再開 制約違反が解消するまで上記を繰り返し SUBSCRIPTION 側のログ ERROR: duplicate key value violates unique constraint "pk_data1" DETAIL: Key (c1)=(500) already exists. LOG: worker process: logical replication worker for subscription (PID 9644) exited with exit code 1 PUBLICATION 側のログ ( レプリケーションの再開 ) LOG: starting logical decoding for slot "sub1" DETAIL: streaming transactions committing after 0/164FED0, reading WAL from 0/164FE98 LOG: logical decoding found consistent point at 0/164FE98 There are no running transactions. 54

55 トラブルシューティングテキスト変換時のメモリー不足エラー bytea 型データの転送時に発生 パラメーター bytea_output に応じてテキスト変換 デフォルトでは レコード サイズ x バイトのメモリーを確保 PUBLICATION ログ ERROR: invalid memory alloc request size CONTEXT: slot "sub1", output plugin "pgoutput", in the change callback, associated LSN 0/2B2543E8LOG: could not send data to client: Broken pipe FATAL: connection to client lost SUBSCRIPTION ログ ERROR: could not receive data from WAL stream: ERROR: invalid memory alloc request size CONTEXT: slot "sub1", output plugin "pgoutput", in the change callback, associated LSN 0/2B2543E8 55

56 トラブルシューティング衝突解消方法 自動的にエラーは解消しない 解消方法は以下の 2 つ (SUBSCRIPTION 側で行う ) 衝突が発生したレコードを削除する ( 制約違反の解消 ) 衝突が発生した WAL をスキップする ( 制約違反の解消 / メモリー不足の解消 ) 56

57 トラブルシューティング衝突解消方法 衝突が発生したトランザクション ログをスキップする SUBSCRIPTION で WAL の適用を開始する LSN を指定する PUBLICATION 側で現在の LSN を確認 postgres=# SELECT pg_current_wal_lsn() ; pg_current_wal_lsn /7200B4F0 (1 row) 57

58 衝突の検知と対策衝突解消方法 Subscription と external_id の関係を入れる SUBSCRIPTION 側で external_id を確認 postgres=# SELECT * FROM pg_replication_origin_status; local_id external_id remote_lsn local_lsn pg_ /7200B068 0/DA0078E8 (1 row) SUBSCRIPTION 側で適用開始 LSN を指定 postgres=# SELECT pg_replication_origin_advance ('pg_16425', '0/7200B4F0') ; pg_replication_origin_advance (1 row) 58

59 衝突の検知と対策衝突解消方法 エラーになることがある postgres=# SELECT pg_replication_origin_advance('pg_16399', '0/ ') ; ERROR: replication origin with OID 1 is already active for PID

60 今後に期待 60

61 今後に期待将来のバージョンに対する期待 TRUNCATE 文対応 衝突発生時の優先順位付け pg_stat_subscription ビューの connection 列のマスキング CREATE SUBSCRIPTION 文と接続情報の分離 例えば CREATE SERVER 文との組み合わせ WAL Buffer から WAL 情報を取得できないか? 現状では書き込まれた WAL を wal sender が再度読んでいる Replication Slot と Plugin の分離 デコードは本来はスレーブ側の仕事では? スタンバイ インスタンスでデコード 61

62 Thank you 62

63 仕様 このスライド以降は今のところ使わない予定 63

64 要調査衝突解消方法 wal_level = replica にした場合は? Wal format の違い Slave に PK が無い場合は? UPDATE / DELETE は伝播しない UNIQUE + NOT NULL があっても Slave に REPLICA IDENTITY USING INDEX が無いと INSERT もエラー? Master に Pk が無い場合は? 異なる OS Wal sender -> receive のプロトコル 64

65 レプリケーション構成 PUBLICATION レプリケーション対象テーブルを決定する マスター側データベースに作成 (CREATE PUBLICATION 文 ) 特徴 データベースに対して CREATE 権限が必要 ( 一部操作は SUPERUSER 属性 ) レプリケーション対象テーブルの所有者のみ作成可能 データベース内に複数作成可能 テーブルの指定は 個別に行うかデータベース内の全テーブルを選択 レプリケーション対象 DML を選択 (INSERT, DELETE, UPDATE) 65

66 レプリケーション構成 SUBSCRIPTION 接続先インスタンスと PUBLICATION を決定する スレーブ側データベースに作成 (CREATE SUBSCRIPTION 文 ) 特徴 データベース内に複数作成可能 SUPERUSER 属性が必要 マスター インスタンス側の Logical Replication Slot とセット 初期データの移行も行うことができる 初期データの移行時は SUBSCRIPTION 側の既存データは削除されない 自動的にテーブルを作る機能は無い 66

67 レプリケーション構成 PUBLICATION と SUBSCRIPTION の関係 PUBLICATION には複数のテーブルを登録可能 Database Database PUBLICATION SUBSCRIPTION TABLE#1 TABLE#2 TABLE#1 TABLE#2 67

68 レプリケーション構成 PUBLICATION と SUBSCRIPTION の関係 テーブルは複数の PUBLICATION に登録可能 Database Database PUBLICATION#1 TABLE#1 PUBLICATION#2 SUBSCRIPTION#1 TABLE#1 Database SUBSCRIPTION#2 TABLE#1 68

69 レプリケーション構成 PUBLICATION と SUBSCRIPTION の関係 PUBRICATION は複数の SUBSCRIPTION にログ送付可能 Database PUBLICATION#1 Database SUBSCRIPTION#1 TABLE#1 TABLE#1 Database SUBSCRIPTION#2 TABLE#1 69

70 レプリケーション構成 PUBLICATION と SUBSCRIPTION の関係 SUBSCRIPTION は複数の PUBLICATION からレプリケーション可能 Database PUBLICATION#1 Database SUBSCRIPTION TABLE#1 PUBLICATION#2 TABLE#1 TABLE#2 TABLE#2 70

71 レプリケーション構成 PUBLICATION と SUBSCRIPTION の関係 カスケード構成も可能 PUBLICATION TABLE#1 SUBSCRIPTION TABLE#1 PUBLICATION SUBSCRIPTION TABLE#1 71

72 設定方法 SUBSCRIPTION オブジェクト 構文 CREATE SUBSCRIPTION name CONNECTION 'conn_info' PUBLICATION publication [, ] [ WITH ( parameter [ = value ], ] パラメーター説明デフォルト copy_data 初期データ移行を行うか on create_slot レプリケーション スロットを作成するか on enabled SUBSCRIPTION は有効 on slot_name レプリケーション スロット名 synchronous_commit 同期コミット設定 off connect PUBLICATION へ接続 on SUBSCRIPTION 名 72

73 設定方法オブジェクト確認方法 SUBSCRIPTION 側 postgres=# SELECT * FROM pg_subscription ; postgres=# SELECT * FROM pg_subscription_rel ; PUBLICATION 側 postgres=# SELECT * FROM pg_publication ; postgres=# SELECT * FROM pg_publication_rel ; postgres=# SELECT * FROM pg_publication_tables ; 73

74 設定方法レプリケーション確認方法 PUBLICATION 側 postgres=# SELECT pid, application_name, state, sync_state FROM pg_stat_replication; -[ RECORD 1 ] pid 5731 application_name sub1 state streaming sync_state async postgres=# SELECT * FROM pg_stat_subscription 74

75 設定方法レプリケーション確認方法 SUBSCRIPTION 側 postgres=# SELECT * FROM pg_subscription; -[ RECORD 1 ] subdbid subname sub1 subowner 10 subenabled t subconninfo port=5433 dbname=demodb host= user=replication password=replication subslotname sub1 subsynccommit off subpublications {pub1} 75