System functions ================ 主にSQLから呼び出すファンクションを使用して、PGD管理を実行します。 PGDのすべてのファンクションは\ ``bdr`` スキーマで公開されています。 ``search_path`` に\ ``bdr`` を配置する代わりに、これらのファンクションへの呼び出しをスキーマ修飾します。 バージョン情報ファンクション ---------------------------- bdr.bdr_version ^^^^^^^^^^^^^^^ このファンクションは、現在使用しているBDR拡張機能のバージョンのテキスト表現を取得します。 bdr.bdr_version_num ^^^^^^^^^^^^^^^^^^^ このファンクションは、現在使用されているBDR拡張機能のバージョン番号を取得します。バージョン番号は単調増加であるため、この値をより小さいおよびより大きい比較に使用できます。 次の式は、メジャーバージョン、マイナーバージョン、およびパッチリリースで構成されるバージョン番号を単一の数値に結果ます。 :: MAJOR_VERSION *10000 + MINOR_VERSION* 100 + PATCH_RELEASE システム情報ファンクション -------------------------- bdr.get_relation_stats ^^^^^^^^^^^^^^^^^^^^^^ リレーション情報を返します。 bdr.get_subscription_stats ^^^^^^^^^^^^^^^^^^^^^^^^^^ 現在のサブスクリプション統計を結果ます。 システムおよび進行状況情報パラメーター -------------------------------------- PGDは、 ``SHOW`` または\ ``current_setting()`` ファンクションなどを使用してSQLで直接照会できるいくつかのパラメーターを公開します。クライアントアプリケーションから\ ``PQparameterStatus`` または同等のものを使用することもできます。 bdr.local_node_id ^^^^^^^^^^^^^^^^^ セッションを初期化すると、これはクライアントが接続しているノードIDに設定されます。これにより、アプリケーションは、透明なプロキシの背後にある場合でも、接続されているノードを認識できます。 :ref:`接続プールとプロキシ <接続プールとプロキシ>` でも使用されます。 bdr.last_committed_lsn ^^^^^^^^^^^^^^^^^^^^^^ 非同期トランザクションの\ ``COMMIT`` ごとに、このパラメーターは更新されて、オリジンノードのコミットレコードの最後を指します。 ``bdr.wait_for_apply_queue`` と組み合わせると、アプリケーションはマルチプルのノードにわたってカウサル読み取りを実行できます。つまり、トランザクションがリモートで可視されるまで待機します。 transaction_id ^^^^^^^^^^^^^^ CAMOトランザクションが進行中の場合、\ ``transaction_id`` が更新されて、割り当てられたトランザクションIDが表示されます。このパラメーターは、 ``PQparameterStatus`` または同等の使用を使用してのみ照会でき、 SQLではアクセスできません。 :ref:`Application use ` を参照 使用例 ノードステータスファンクション ------------------------------ bdr.is_node_connected ^^^^^^^^^^^^^^^^^^^^^ 概要 ^^^^ .. code:: sql bdr.is_node_connected(node_name name) 指定されたピアのワルセンダーがこのノードでアクティブかどうかを確認することにより、ブール値を返します。 bdr.is_node_ready ^^^^^^^^^^^^^^^^^ .. _概要-1: 概要 ^^^^ .. code:: sql bdr.is_node_ready(node_name name, span interval DEFAULT NULL) ラグが指定されたスパンより低いか、それ以外の場合は\ ``TO ASYNC`` の\ ``timeout`` より低いかどうかをチェックすることにより、ブール値を返します。 コンセンサスファンクション -------------------------- bdr.consensus_disable ^^^^^^^^^^^^^^^^^^^^^ .. _概要-2: 概要 ^^^^ .. code:: sql bdr.consensus_disable(node_group_name text DEFAULT NULL) サーバーが再起動するか、\ ``bdr.consensus_enable`` を使用して再有効化されるまで、ローカルノードのコンセンサスワーカーを無効にします。最初に発生した方。 ``node_group_name`` パラメーターは、インターフェイスの一貫性のために受け入れられますが、現在プレースホルダーです。このファンクションは、データベース全体でコンセンサスワーカーを無効にし、渡された値に関係なく、ノード上のすべてのRaftインスタンスに影響を与えます。 .. Warning:: コンセンサスを無効にすると、PGDの一部の機能が無効になり、長時間無効になっているとEDB Postgres分散クラスターの可用性に影響します。この機能は、テクニカルサポートと協力する場合にのみ使用します。 bdr.consensus_enable ^^^^^^^^^^^^^^^^^^^^ .. _概要-3: 概要 ^^^^ .. code:: sql bdr.consensus_enable(node_group_name text DEFAULT NULL) ローカルノードで無効になったコンセンサスワーカーを再度有効にします。 ``node_group_name`` パラメーターは、インターフェイスの一貫性のために受け入れられますが、現在プレースホルダーです。このファンクションは、データベース全体でコンセンサスワーカーを再度有効にし、渡された値に関係なく、ノード上のすべてのRaftインスタンスに影響を与えます。 bdr.consensus_proto_version ^^^^^^^^^^^^^^^^^^^^^^^^^^^ ローカルノードが現在使用しているコンセンサスプロトコルのバージョンを返します。 PGDグループの再構成の内部メカニズムに必要です。 bdr.consensus_snapshot_export ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ .. _概要-4: 概要 ^^^^ .. code:: sql bdr.consensus_snapshot_export(version integer DEFAULT NULL, raft_instance_id integer DEFAULT NULL) ローカルノードの現在コミットおよび適用された状態から新しいPGDコンセンサススナップショットを生成し、byteaとして結果ます。 デフォルトでは、サポートされている最新のRaftバージョンのスナップショットがエクスポートされます。ただし、明示的な\ ``version`` 番号を渡すことにより、それをオーバーライドできます。 ``raft_instance_id`` パラメーターは、スナップショットをエクスポートするRaftインスタンスを識別します。 ``NULL`` デフォルトの場合、トップレベルのRaftインスタンスが使用されます。特定のノードグループのRaftインスタンスをターゲットにするには、そのインスタンスIDを渡します。これは、 ``bdr.raft_instances`` を介してルックアップできます。 エクスポートするノードは現在のRaftリーダーである必要はなく、リーダーの最新の状態で完全に最新の状態である必要はありません。ただし、 ``bdr.consensus_snapshot_import()`` は、このようなスナップショットを受け入れない場合があります。 新しいスナップショットは、ローカルノードの\ ``bdr.local_consensus_snapshot`` テーブルに自動的に保存されません。呼び出し元にのみ返されます。 生成されたスナップショットは、エクスポートノードのRaftログ位置の背後にある同じPGDノードグループ内の他のノードの\ ``bdr.consensus_snapshot_import()`` に渡される場合があります。 この機能が動作するには、ローカルPGDコンセンサスワーカーを無効にする必要があります。一般的な使用法は次のとおりです。 .. code:: sql SELECT bdr.bdr_consensus_disable(); COPY (SELECT * FROM bdr.consensus_snapshot_export()) TO /var/lib/postgresql/my_node_consensus_snapshot.data; SELECT bdr.bdr_consensus_enable(); PGDコンセンサスワーカーが無効になっている間 - ノードでのDDLロックの試行は失敗するか、タイムアウトします。 - gallocシーケンスは新しい値を取得しません。 - EageおよびCAMOトランザクションの一時停止またはエラー。 - 分散コンセンサスシステムを必要とする他の機能が中断されます。必要なダウンタイムは、一般に非常に短時間です。 ユースケースによっては、 ``bdr.local_consensus_snapshot`` テーブルの\ ``snapshot`` フィールドから既に存在するスナップショットを抽出し、代わりにそれを使用することが現実的である場合があります。その際、コンセンサスワーカーを停止する必要はありません。 bdr.consensus_snapshot_import ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ .. _概要-5: 概要 ^^^^ .. code:: sql bdr.consensus_snapshot_import(snapshot bytea, raft_instance_id integer DEFAULT NULL, node_name bdr.regnode DEFAULT NULL) ``bdr.consensus_snapshot_export()`` によって、通常は同じPGDノードグループ内の別のノードからエクスポートされたコンセンサススナップショットをインポートします。 別のノード上の\ ``bdr.local_consensus_snapshot`` テーブルの\ ``snapshot`` フィールドから直接抽出されたスナップショットを使用することもできます。 この機能は、破損またはユーザーエラーが発生した場合に、PGDノードのカタログ状態を既知の良好な状態にリセットするのに役立ちます。 ``raft_instance_id`` パラメーターは、スナップショットをインポートするRaftインスタンスを指定します。 ``NULL`` デフォルトの場合、トップレベルのRaftインスタンスが使用されます。特定のノードグループのRaftインスタンスをターゲットにするには、そのインスタンスIDを渡します。これは、 ``bdr.raft_instances`` を介してルックアップできます。 ``node_name`` パラメーターは、スナップショットを特定のソースノード、通常はスナップショットがエクスポートされたリーダーノードに関連付けます。 ``NULL`` デフォルトの場合、ソースノードは属性されません。 スナップショットが生成されたときに、インポートノードの\ ``apply_index`` がスナップショットエクスポートノードの\ ``commit_index`` 以下の場合、スナップショットをインポートできます。 ``bdr.get_raft_status()`` を参照してください。ログが既に進みすぎているためにスナップショットを受け入れることができないノードは、エラーを発生させ、変更は行いません。スナップショットがインポートされると、ノードは現在のリーダーから残りの変更を取得するため、インポートされたスナップショットは完全に最新の状態である必要はありません。 この機能が動作するには、インポートノードでPGDコンセンサスワーカーを無効にする必要があります。詳細については、 ``bdr.consensus_snapshot_export()`` のノートを参照してください。 この機能を使用して、次のことを実行してローカルノードに新しいRaftスナップショットを生成させることができます。 :: SELECT bdr.consensus_snapshot_import(bdr.consensus_snapshot_export()); このアプローチでは、現在適用されているログの位置までRaftログが切り捨てられる場合があります。 bdr.consensus_snapshot_verify ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ .. _概要-6: 概要 ^^^^ .. code:: sql bdr.consensus_snapshot_verify(snapshot bytea) ``bdr.consensus_snapshot_export()`` によってエクスポートされた指定されたコンセンサススナップショットを確認します。スナップショットヘッダーには、生成されたバージョンが含まれており、ノードは同じバージョンに対して検証しようとします。 スナップショットは、クラスター内の同じノードまたは他のノードでエクスポートされた可能性があります。スナップショットを検証するノードがエクスポートされたスナップショットのバージョンをサポートしていない場合、エラーが発生します。 bdr.get_consensus_status ^^^^^^^^^^^^^^^^^^^^^^^^ 現在のコンセンサスRaftワーカーに関するステータス情報を結果ます。 bdr.get_raft_status ^^^^^^^^^^^^^^^^^^^ 現在のコンセンサスRaftワーカーに関するステータス情報を結果ます。 ``bdr.get_consensus_status`` のエイリアス。 bdr.raft_leadership_transfer ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ .. _概要-7: 概要 ^^^^ .. code:: sql bdr.raft_leadership_transfer(node_name text, wait_for_completion boolean, node_group_name text DEFAULT NULL) ``node_name`` で指定されたノードにRaftリーダーになるように要求します。要求は任意のPGDノードから開始でき、現在のリーダーに内部転送されて、指定されたノードにリーダーシップを転送します。指定されたノードは、完全な投票権を持つACTIVE PGDノードである必要があります。 ``wait_for_completion`` がfalseの場合、要求はベストエフォートベースで提供されます。ノードが\ ``bdr.raft_global_lection_timeout`` 期間にリーダーになることができない場合、他の有効なノードが再びリーダーになります。また、リーダーシップはRaftプロトコルごとに時間の経過とともに変更される場合があります。 ``true`` の戻り結果は、要求が正常に送信されたことのみを示します。 ``wait_for_completion`` が\ ``true`` の場合、ファンクションは指定されたノードが新しいリーダーになるまで待機し、要求されたノードがRaftリーダーになれなかった場合たとえば、ネットワークの問題のため、無限に待機します。したがって、無限ループを防ぐために、常に\ ``statement_timeout`` と\ ``wait_for_completion`` を設定することをお勧めします。 ``node_group_name`` はオプショナルであり、リーダーシップの移転が発生するノードグループの名前を指定するために使用できます。指定しない場合、デフォルトのNULLになり、クラスター内のトップレベルのグループとして解釈されます。 ``node_group_name`` を指定すると、ファンクションは指定されたノードグループ内でのみリーダーシップを譲渡します。 ユーティリティファンクション ---------------------------- bdr.transfer_all_leaderships ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ローカルノードが現在書き込みまたはRaftリーダーシップを保持しているすべてのグループで、書き込みおよびRaftリーダーシップをローカルノードから移転します。この機能を使用して、ノードをオフラインにする前に、ノードからすべてのリーダーシップをドレインします。 .. _概要-8: 概要 ^^^^ .. code:: sql bdr.transfer_all_leaderships(writeleader_timeout interval DEFAULT 10s) パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Name,Type,Default,Description :widths: 15,12,12,20 :align: left :class: longtable `writeleader_timeout`,interval,`'10s'`,各書き込みリーダーシップ転送のタイムアウト。書き込みリーダーは自動選択され、このタイムアウトに到達するまで再試行されます。 戻り値 ^^^^^^ すべての転送が成功した場合、またはノードがリーダーシップを保持していない場合は\ ``true`` を返し、書き込みリーダー転送がタイムアウトした場合は\ ``false`` を返します。 書き込みリーダー転送がタイムアウトすると、ファンクションは残りの書き込みリーダーとRaft転送の処理を継続し、ベストエフォートベースで、他の転送が成功した場合でも\ ``false`` を結果ます。 Raft転送は、 ``statement_timeout`` 構成パラメーターを尊重して、リーダーシップが変更されるか、クエリがキャンセルされるまで、無期限に再試行されます。 ファンクションは\ ``bdr.routing_leadership_transfer`` および\ ``bdr.raft_leadership_transfer`` とロジックを共有し、1回の呼び出しで両方の操作を完了して、結果が速くなります。 bdr.alter_node_kind ^^^^^^^^^^^^^^^^^^^ PGD5は、タスクマネージャーリーダーノードの概念を導入しました。ノードはPGDによって選択されますが、アップグレードされたクラスターの場合、クラスター内のすべてのノードで\ ``node_kind`` を適切に設定することが重要です。これは、最新のPGDバージョンにアップグレードした後、ノードごとに\ ``bdr.alter_node_kind()`` SQLファンクションを呼び出すことにより手動で実行します。 .. _概要-9: 概要 ^^^^ :: bdr.alter_node_kind(node_name text, node_kind text); .. _パラメーター-1: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `node_name`,種類を変更するノードの名前。 `node_kind`,ノードの種類。 bdr.alter_subscription_skip_changes_upto ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 論理レプリケーションはバージョンをまたがってレプリケートでき、ロールのようなグローバル変更をレプリケートせず、選択的にレプリケートできるため、論理レプリケーション適用プロセスでエラーが発生し、変更の適用を停止する場合があります。 可能な場合は、ターゲット側に変更を加えてこのような問題を修正します。 ``CREATE`` レプリケーションをブロックしている欠落テーブル、\ ``CREATE`` 必要なロール、\ ``GRANT`` 必要な権限など。ただし、その方法では問題を修正できない場合があり、トランザクションを完全にスキップする必要がある場合があります。変更はトランザクション全体としてスキップされますオールオアナッシング。スキップする場所を決定するには、次の例のように、ログ出力を使用してコミットLSNを見つけるか、論理デコード機能を使用して変更ストリームをピークにします。 トランザクションが1つの変更のみを行った場合を除き、多くの場合、ターゲット側でトランザクションのエフェクトを手動で適用する必要があります。そのため、以下の例に示すように、可能な限り問題のあるトランザクションを保存することが重要です。 ``pg_catalog.pg_logical_slot_get_binary_changes`` を使用して目的のLSNにスキップすることにより、 ``bdr.alter_subscription_skip_changes_upto`` なしで変更をスキップすることが可能であるため、これは便利なファンクションです。論理デコードにおけるある種のエラーをバイパスする場合がありますが、より速いスキップを行います。 この機能は、無効になっているサブスクリプションでのみ動作します。 通常の手順のシーケンスは次のとおりです。 1. 問題のあるサブスクリプションと問題のあるコミットのLSNを特定します。 2. サブスクリプションを無効にします。 3. 可能であれば、ソースノードで\ ``pg_catalog.pg_logical_slot_peek_changes`` を使用してトランザクションのコピーを保存します。 4. ターゲットノード上の\ ``bdr.alter_subscription_skip_changes_upto`` 。 5. 必要に応じて、修復または同等の変更をターゲットに手動で適用します。 6. サブスクリプションを再度有効にします。 .. Warning:: このファンクションを使用すると、問題を悪化させるのは簡単です。それが唯一のオプションであると確信できない限り、何もしないでください。 .. _概要-10: 概要 ^^^^ :: bdr.alter_subscription_skip_changes_upto( subname text, skip_upto_and_including pg_lsn ); 例 ^^ トランザクションの適用はエラーで失敗し、ターゲット側の変更などのインパクトの低い修正ではこの問題を解決できないと判断しました。トランザクションをスキップする必要があると判断します。 エラーログで、次の例のように、スキップするコミットレコードLSNを見つけます。 :: ERROR: XX000: CONFLICT: target_table_missing; resolver skip_if_recently_dropped returned an error: table does not exist CONTEXT: during apply of INSERT from remote relation public.break_me in xact with commit-end lsn 0/300AC18 xid 131315 committs 2021-02-02 15:11:03.913792+01 (action #2) (effective sess origin id=2 lsn=0/300AC18) while consuming I message from receiver for subscription bdr_regression_bdrgroup_node1_node2 (id=2667578509) on node node2 (id=3367056606) from upstream node node1 (id=1148549230, reporiginid=2) ログのこの部分には、必要な情報があります。the_target_lsn: **0/300AC18** the_subscription: **bdr_regression_bdrgroup_node1_node2** 次に、サブスクリプションを無効にして、適用ワーカーがレプリケーションスロットに接続しようとしないようにします。 :: SELECT bdr.alter_subscription_disable(the_subscription); トランザクションの一部だけをスキップすることはできません。それはオール・オア・ナッシングです。したがって、サブスクリプションのスロット名を使用して、最初にプロバイダー側でコピーして、レコードを保存することを強くお勧めします。 :: \copy (SELECT * FROM pg_catalog.pg_logical_slot_peek_changes(the_slot_name, the_target_lsn, NULL, min_proto_version, 1, max_proto_version, 1, startup_params_format, 1, proto_format, json)) TO transaction_to_drop.csv WITH (FORMAT csv); この例は、読みやすいように複数行に分割されていますが、単一行で発行します。 ``\copy`` は、複数行のコマンドをサポートしていません。 ``peek`` を\ ``get`` に変更することにより、変更をスキップできますが、 ``bdr....skip_changes_upto`` は、すべてのデータのデコードと出力を回避する高速なスキップを行います。 :: SELECT bdr.alter_subscription_skip_changes_upto(subscription_name, the_target_lsn); ダンプされたトランザクションの内容をガイドとして使用して、同じ変更またはその修復バージョンをターゲットノードに手動で適用できます。 最後に、サブスクリプションを再度有効にします。 :: SELECT bdr.alter_subscription_enable(the_subscription); bdr.connection_manager_refresh_pools ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ このファンクションは、 PGD接続マネージャーに接続プールを更新するように指示します。 この機能は、他のツールとの統合、または接続プールの即時の再評価が必要な場合に役立ちます。この機能はローカルノードでのみ動作します。クラスター全体の接続マネージャーを更新するには、各ノードでファンクションを個別に実行する必要があります。実行には\ ``bdr_superuser`` ロールが必要です。コメントを展開する コメント オンラインR861解決済み .. _概要-11: 概要 ^^^^ .. code:: sql SELECT bdr.connection_manager_refresh_pools(); .. Note:: このファンクションは、ルーティングの変更が検出された場合たとえば、書き込みリーダーの変更、ルーティングターゲットからのノードの追加/削除、またはコンセンサスが失われた場合、既存のクライアント接続を終了する場合があります。 bdr.get_node_sub_apply_lsn ^^^^^^^^^^^^^^^^^^^^^^^^^^ サブスクライバーでこのファンクションを使用して、特定のオリジンから受信および適用された最後のLSNを取得できます。 .. _概要-12: 概要 ^^^^ :: bdr.get_node_sub_apply_lsn(node_name name) .. _パラメーター-2: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `node_name`,LSNが取得されるレプリケーションストリームのソースであるノードの名前。 bdr.get_node_sub_receive_lsn ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ サブスクライバーでこのファンクションを使用して、特定のオリジンから受信した最後のLSNを取得できます。適用されるトランザクションに関連するLSNインクリメントのみを考慮して、フィルタリングしないか、フィルタリングすることができます。 このファンクションの出力と\ ``bdr.get_node_sub_apply_lsn()`` の出力の差は、対応する適用キューのサイズを測定します。 .. _概要-13: 概要 ^^^^ :: bdr.get_node_sub_receive_lsn(node_name name, committed bool default true) .. _パラメーター-3: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `node_name`,LSNが取得されるレプリケーションストリームのソースであるノードの名前。 `committed`,デフォルトtrueでは、このファンクションは、最後のLSN全体ではなく、受信したトランザクションのコミットのみを考慮します。これには、サブスクライバノードに影響を与えないアクションが含まれます。 bdr.global_lock_table ^^^^^^^^^^^^^^^^^^^^^ このファンクションは、指定されたテーブルのグローバルDMLロックを取得します。 :ref:`DDL locking details ` を参照 グローバルDMLロックの詳細については、 .. _概要-14: 概要 ^^^^ :: bdr.global_lock_table(relation regclass) .. _パラメーター-4: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `relation`,ロックへの関係の名前またはoid。 注 ^^ このファンクションは、\ ``ddl_locking`` 設定とは無関係にグローバルDMLロックを取得します。 ``bdr.global_lock_table`` ファンクションには、 ``bdr.backwards_compatibility`` が30618以下に設定されていない限り、ロックされた\ ``relation`` に対する\ ``UPDATE`` 、\ ``DELETE`` 、または\ ``TRUNCATE`` 特権が必要です。 .. _例-1: 例 ^^ :: pgddb=# SELECT bdr.local_group_slot_name(); local_group_slot_name - ---------------------- bdr_pgddb_bdrgroup bdr.group_lease_override ^^^^^^^^^^^^^^^^^^^^^^^^ ノードグループのリース所有権を手動で譲渡またはキャンセルします。通常の動作条件では、 PGDノードはリースを自動的に転送します。ただし、リース所有者がクラッシュ、停止、またはコンセンサスから切断された場合、他のノードは、現在のリースの有効期限が切れるまでリースを取得できません。このファンクションは、その待機期間をバイパスします。 .. Danger:: このファンクションは、以前のリース所有者がリソースにアクセスしていないことが確実な場合にのみ使用します。たとえば、古いリーダーがコンセンサスから切断されているがまだアクティブなときに分析リースを手動で転送すると、両方のノードが同じストアに書き込み、データの重複が発生する可能性があります。 .. _パラメーター-5: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `node_group`,リースオーバーライドが適用されるグループの名前。 `node`,リースを保持するノードの名前。 `duration`,秒単位のリース期間。 `0`以下の値を指定すると、現在のリースがキャンセルされます。 `kind`,リース種類たとえば `analytics` 。 `local_only`,`false`デフォルトの場合、オーバーライドはコンセンサスを介してすべてのノードに送信されます。 `true`の場合、オーバーライドはローカルノードにのみ影響します。コンセンサスが失われた場合にのみ`true`を使用します。 bdr.local_group_slot_name ^^^^^^^^^^^^^^^^^^^^^^^^^ ローカルノードのグループスロットの名前を返します。 bdr.node_group_type ^^^^^^^^^^^^^^^^^^^ 指定されたノードグループのタイプを返します。戻り値は、ノードグループの作成時に\ ``bdr.create_node_group()`` に渡されたものと同じですが、グループの作成時に\ ``node_group_type`` がNULLとして渡された場合、 ``global`` が返されます。 .. _例-2: 例 ^^ :: pgddb=# SELECT bdr.node_group_type(bdrgroup); node_group_type - ---------------- global bdr.replicate_ddl_command ^^^^^^^^^^^^^^^^^^^^^^^^^ ノードのグループにDDLコマンドを複製する機能。 .. _概要-15: 概要 ^^^^ :: bdr.replicate_ddl_command(ddl_cmd text, replication_sets text[], ddl_locking text, execute_locally bool) .. _パラメーター-6: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `ddl_cmd`,実行するDDLコマンド。 `replication_sets`,`ddlcommand`を適用するレプリケーションセット名の配列。 NULLの場合、またはファンクションに`ddlcommand`のみが渡される場合、このパラメーターはアクティブなPGDグループのデフォルトレプリケーションセットに設定されます。 `ddl_locking`,レプリケート中に :ref:`pg_upgrade ` 値を設定する文字列。 `replicate_ddl_command`を実行しているローカルシステム上の`bdr.ddl_locking`のGUC値のデフォルト。 `execute_locally`,DDLコマンドをローカルで実行するかどうかを決定するブール値。デフォルトtrue。 .. _注-1: 注 ^^ このファンクションの唯一の必須パラメーターは\ ``ddl_cmd`` です。 ``bdr.replicate_ddl_command()`` は常にコマンドをレプリケートし、 :ref:`bdr.ddl_replication ` の設定の影響を受けません。 。 bdr.run_on_all_nodes ^^^^^^^^^^^^^^^^^^^^ すべてのノードでクエリを実行するファンクション。 .. Warning:: このファンクションは、ノードのDSNで指定されたノード間接続に使用されるユーザーの権限を使用して、リモートノードで任意のクエリーを実行します。この機能に特権を付与するときは注意してください。 .. _概要-16: 概要 ^^^^ :: bdr.run_on_all_nodes(query text) .. _パラメーター-7: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `query`,実行する任意のクエリー。 .. _注-2: 注 ^^ このファンクションは、他のノードに接続してクエリーを実行し、各ノードからJSON形式で結果を返します。複数の行が各ノードから返され、JSON配列としてエンコードされる場合があります。ノードがダウンしているため接続できないなどのエラーは、応答フィールドに表示されます。明示的なstatement_timeoutまたはその他のランタイムパラメーターが設定されていないため、デフォルトが使用されます。 このファンクションは、通常のレプリケーションを経由しません。すべての既知のノードへの直接クライアント接続を使用します。デフォルトでは、コマンドはクラスター内のすべてのノードに既に送信されているため、\ ``bdr.ddl_replication = off`` で接続が作成されます。 PGD 6以降では、このファンクションは接続で\ ``bdr.xact_replication=off`` も設定して、コマンドが別のノードで実行された場合にのみトランザクションがローカルで実行されるようにします。 レプリケーションが中断され、ノード間で不一致が発生する危険があるため、この機能を使用する場合は注意してください。透過的DDLレプリケーションまたは\ ``bdr.replicate_ddl_command()`` を使用してDDLをレプリケートします。 DDLは、将来のリリースでブロックされる可能性があります。 .. _例-3: 例 ^^ 例、次のクエリのように、モニタリングでこのファンクションを使用すると便利です。 :: SELECT bdr.run_on_all_nodes($$ SELECT local_slot_name, origin_name, target_name, replay_lag_size FROM bdr.node_slots WHERE origin_name IS NOT NULL $$); このクエリは、2ノードクラスターで次のような結果を返します。 :: [ { "dsn": "host=node1 port=5432 dbname=pgddb user=postgres ", "node_id": "2232128708", "response": { "command_status": "SELECT 1", "command_tuples": [ { "origin_name": "node1", "target_name": "node2", "local_slot_name": "bdr_pgddb_bdrgroup_node2", "replay_lag_size": "0 bytes" } ] }, "node_name": "node1" }, { "dsn": "host=node2 port=5432 dbname=pgddb user=postgres ", "node_id": "2058684375", "response": { "command_status": "SELECT 1", "command_tuples": [ { "origin_name": "node2", "target_name": "node1", "local_slot_name": "bdr_pgddb_bdrgroup_node1", "replay_lag_size": "0 bytes" } ] }, "node_name": "node2" } ] bdr.run_on_group ^^^^^^^^^^^^^^^^ ノードのグループでクエリを実行する機能。 .. Warning:: このファンクションは、ノードのDSNで指定されたノード間接続に使用されるユーザーの権限を使用して、リモートノードで任意のクエリーを実行します。この機能に特権を付与するときは注意してください。 .. _概要-17: 概要 ^^^^ :: bdr.run_on_group(node_group_name text, query text) .. _パラメーター-8: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `node_group_name`,クエリが実行されるノードグループの名前。 `query`,実行する任意のクエリー。 .. _注-3: 注 ^^ このファンクションは、他のノードに接続してクエリーを実行し、各ノードからJSON形式で結果を返します。複数の行を各ノードから返すことができ、JSON配列としてエンコードされます。ノードがダウンしているため接続できないなどのエラーは、応答フィールドに表示されます。明示的なstatement_timeoutまたはその他のランタイムパラメーターが設定されていないため、デフォルトが使用されます。 このファンクションは、通常のレプリケーションを経由しません。すべての既知のノードへの直接クライアント接続を使用します。デフォルトでは、接続は\ ``bdr.ddl_replication = off`` で作成され、同じレプリケートされたDDLコマンドが複数のノードに送信される場合のレプリケーションの問題を回避します。 PGD 6以降では、このファンクションは接続で\ ``bdr.xact_replication=off`` も設定して、コマンドが別のノードで実行された場合にのみトランザクションがローカルで実行されるようにします。 レプリケーションが中断され、グループ内のノード間で不一致が発生する危険があるため、この機能を使用する場合は注意してください。グローバルスキーマ変更の場合、 DDLをレプリケートするには、透過的DDLレプリケーションまたは\ ``bdr.replicate_ddl_command()`` のいずれかを使用します。 bdr.run_on_nodes ^^^^^^^^^^^^^^^^ 指定されたノードのリストでクエリを実行するファンクション。 .. Warning:: このファンクションは、ノードのDSNで指定されたノード間接続に使用されるユーザーの権限を使用して、リモートノードで任意のクエリーを実行します。この機能に特権を付与するときは注意してください。 .. _概要-18: 概要 ^^^^ :: bdr.run_on_nodes(node_names text[], query text) .. _パラメーター-9: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `node_names`,クエリが実行されるノード名のテキストARRAY。 `query`,実行する任意のクエリー。 .. _注-4: 注 ^^ このファンクションは、他のノードに接続してクエリーを実行し、各ノードからJSON形式で結果を返します。複数の行を各ノードから返すことができ、JSON配列としてエンコードされます。ノードがダウンしているため接続できないなどのエラーは、応答フィールドに表示されます。明示的なstatement_timeoutまたはその他のランタイムパラメーターが設定されていないため、デフォルトが使用されます。 このファンクションは、通常のレプリケーションを経由しません。すべての既知のノードへの直接クライアント接続を使用します。デフォルトでは、接続は\ ``bdr.ddl_replication = off`` で作成され、同じレプリケートされたDDLコマンドが複数のノードに送信される場合のレプリケーションの問題を回避します。 PGD 6以降では、このファンクションは接続で\ ``bdr.xact_replication=off`` も設定して、コマンドが別のノードで実行された場合にのみトランザクションがローカルで実行されるようにします。 レプリケーションが中断され、ノード間で不一致が発生する危険があるため、この機能を使用する場合は注意してください。グローバルスキーマ変更の場合、 DDLをレプリケートするには、透過的DDLレプリケーションまたは\ ``bdr.replicate_ddl_command()`` のいずれかを使用します。 bdr.stat_reset ^^^^^^^^^^^^^^ 指定されたカテゴリの統計をリセットします。このファンクションを実行すると、 :ref:`bdr.stat_reconcile_commit_scope ` ビューの\ ``stats_reset`` 列の値がクリアされます。 ``bdr_superuser`` 権限が必要です。 .. _パラメーター-10: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable stats_tupe,リセットする統計のカテゴリ。有効な値は`commit_scope`および`reconcile_commit_scope`です。 `NULL`の場合、ファンクションのデフォルトは`commit_scope`になります。 bdr.wait_for_apply_queue ^^^^^^^^^^^^^^^^^^^^^^^^ ファンクション\ ``bdr.wait_for_apply_queue`` を使用すると、PGDノードは、特定のPGDノードから発生した特定のトランザクションのローカルアプリケーションを待機できます。そのピアノードからのすべてのトランザクションがローカルに適用された後にのみ返されます。アプリケーションまたはプロキシはこの機能を使用して、古い読み取りを防止できます。 便宜上、PGDはCAMOおよびCAMOパートナーノードにこのファンクションのバリアントを提供します。 :ref:`bdr.wait\_for\_camo\_partner\_queue ` を参照してください 。 特定のLSNが指定された場合、それは、ピアが待機するリカバリストリームのポイントです。これは、以前のまたは同時接続でそのピアノードから取得した\ ``bdr.last_committed_lsn`` と使用できます。 指定された\ ``target_lsn`` がNULLの場合、このファンクションはローカル受信バッファをチェックし、指定されたピアノードから受け取った最後のトランザクションのLSNを使用し、既に受信したすべてのトランザクションが適用されるのを効果的に待機します。これは、ピアノードに障害が発生し、どのトランザクションが送信されたかが不明な場合に特に役立ちます。この場合、送信者側でまだ転送中またはバッファリングされているトランザクションは待機されません。 .. _概要-19: 概要 ^^^^ :: bdr.wait_for_apply_queue(peer_node_name TEXT, target_lsn pg_lsn) .. _パラメーター-11: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `peer_node_name`,着信トランザクションがキューに入れられて待機するピアノードの名前。 NULLの場合、すべてのピアノードの適用キューが使用されるまで待機します。 `target_lsn`,待機するピアノードからのレプリケーションストリームのLSN。通常、ピアノードから`bdr.last_committed_lsn`を介して学習します。 bdr.wait_for_xid_progress ^^^^^^^^^^^^^^^^^^^^^^^^^ このファンクションを使用して、特定のノードノードIDで識別される特定のトランザクションXIDで識別されるが、クラスターで十分な進行を行うのを待機できます。進行状況は、ノードに適用されているトランザクションとして定義され、このノードは、トランザクションが適用される前に行われた他のすべてのレプリケーション変更を確認しています。 .. _概要-20: 概要 ^^^^ :: bdr.wait_for_xid_progress(origin_node_id oid, origin_topxid int4, allnodes boolean DEFAULT true) .. _パラメーター-12: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `origin_node_id`,トランザクションが発生したノードのノードID。 `origin_topxid`,トランザクションのXID。 `allnodes`,`true`の場合、すべてのノードでトランザクションが進行するまで待機します。それ以外の場合、現在のノードのみを待機します。 .. _注-5: 注 ^^ 現在、これらのトランザクションのみが追跡されるため、 DDLコマンドをレプリケートしたトランザクションにのみファンクションを使用できます。誤った\ ``origin_node_id`` または\ ``origin_topxid`` が指定された場合、ファンクションは永久にまたは\ ``statement_timeout`` が発生するまで待機する場合があります。 bdr.wait_node_confirm_lsn ^^^^^^^^^^^^^^^^^^^^^^^^^ ノードが特定のLSNを通過するまで待機します。 この機能を使用すると、このセッションの最後の書き込みが1つまたはすべてのノードで再生されるまで待機できます。 ファンクションは、呼び出されると、ノードが特定のLSNを渡すのを待機します。 LSNが指定されない場合、現在のwal_flush_lsn ``pg_current_wal_flush_lsn()`` ファンクションを使用しての位置がローカルノードで使用されます。ノード名パラメーターを指定すると、そのノードがLSNを渡すのを待機するようにファンクションに指示します。ノード名がNULLを渡すことにより指定されない場合、ファンクションはすべてのノードがLSNを渡すまで待機します。 :ref:`Optimizing subscriber-only groups ` を使用している場合、このファンクションの使用をお勧めします :ref:`bdr.wait_slot_confirm_lsn ` の代わりに 。 これは、最適化されたトポロジでは、すべてのノードにレプリケーションスロットがあるわけではないため、ファンクション ``bdr.wait_slot_confirm_lsn`` が予想通りに動作しない場合があるためです。 ``bdr.wait_node_confirm_lsn`` は、レプリケーションスロットのないノードで動作するように設計されており、代替戦略を使用してノードの進行状況を判断します。 ノードが現在ダウンしているか、更新していない場合、または単に接続できない場合、待機は無期限に継続されます。この状態を回避するには、statement_timeoutを待機する準備ができている最大時間に設定します。 .. _概要-21: 概要 ^^^^ :: bdr.wait_node_confirm_lsn(node_name text DEFAULT NULL, target_lsn pg_lsn DEFAULT NULL) .. _パラメーター-13: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `node_name`,待機するノードの名前。 NULLの場合、すべてのノードを待機します。 `target_lsn`,待機するLSN。 NULLの場合、ローカルノードで現在のwal\_flush\_lsnを使用します。 .. _注-6: 注 ^^ 使用するには\ ``bdr_application`` 権限が必要です。 bdr.wait_slot_confirm_lsn ^^^^^^^^^^^^^^^^^^^^^^^^^ このセッションの最後の書き込みが1つまたはすべてのノードで再生されるまで待機できます。 スロットが特定のLSNを通過するまで待機します。位置が指定されない場合、現在の書き込み位置がローカルノードで使用されます。 スロット名が渡されない場合、すべてのPGDスロットがLSNを通過するまで待機します。 ファンクションは、他のノードからの変更を1000ミリ秒ごとにポーリングします。 スロットが同時にドロップされた場合、そのスロットの待機は終了します。ノードが現在ダウンしており、スロットを更新していない場合、待機は継続されます。その場合、 ``statement_timeout`` をより早く完了するように設定することができます。 :ref:`Optimizing subscriber-only groups ` を使用している場合 、 `bdr.wait_node_confirm_lsn `_ の使用をお勧めします 代わりに。 .. _概要-22: 概要 ^^^^ :: bdr.wait_slot_confirm_lsn(slot_name text DEFAULT NULL, target_lsn pg_lsn DEFAULT NULL) .. _注-7: 注 ^^ 使用するには\ ``bdr_application`` 権限が必要です。 .. _パラメーター-14: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `slot_name`,待機するレプリケーションスロットの名前。 NULLの場合、すべてのPGDスロットを待機します。 `target_lsn`,待機するLSN。 NULLの場合、ローカルノードの現在の書き込みLSNを使用します。 グローバルアドバイザリーロック ------------------------------ PGDは、グローバルアドバイザリーロックをサポートしています。これらのロックは、 PGDでサポートされている勧告ロックがグローバルであることを除き、 PostgreSQLで使用可能な勧告ロックと似ています。これらはDDLロックと同様のセマンティクスに従います。したがって、アドバイザリロックはマジョリティコンセンサスによって取得され、すべてのノードの大部分が連携できる限り、1つ以上のノードがダウンまたは遅延している場合でも使用できます。 現在、EXCLUSIVEロックのみがサポートされています。したがって、別のノードまたは同じノード上の別のバックエンドがオブジェクトの勧告ロックを既に取得している場合、他のノードまたはバックエンドはロックが解放されるまで待機する必要があります。 アドバイザリーロックはトランザクション的な性質を持っています。したがって、トランザクションが終了する前に明示的に解放しない限り、トランザクションの終了時にロックは解放されます。この場合、リリースされるとすぐに利用可能になります。セッションレベルの勧告ロックは現在サポートされていません。 グローバル勧告ロックは再入可能です。したがって、同じリソースが3回ロックされている場合、3回ロックを解除して、他のセッションで使用できるように解放する必要があります。 bdr.global_advisory_lock ^^^^^^^^^^^^^^^^^^^^^^^^ このファンクションは、提供されたオブジェクトのEXCLUSIVEロックを取得します。ロックが利用できない場合、ロックが利用可能になるか、\ ``bdr.global_lock_timeout`` に到達するまで待機します。 .. _概要-23: 概要 ^^^^ .. code:: sql bdr.global_advisory_lock(key bigint) .. _パラメーター-15: パラメーター ^^^^^^^^^^^^ - ``key`` — アドバイザリーロックが取得されるオブジェクト。 .. _概要-24: 概要 ^^^^ .. code:: sql bdr.global_advisory_lock(key1 integer, key2 integer) .. _パラメーター-16: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `key1`,複合キーの最初の部分。 `key2`,複合キーの2番目の部分。 bdr.global_advisory_unlock ^^^^^^^^^^^^^^^^^^^^^^^^^^ このファンクションは、アプリケーション定義のソースで以前に取得したロックを解放します。ロックは、アプリケーションによって同じトランザクションで取得されている必要があります。それ以外の場合、エラーが発生します。 .. _概要-25: 概要 ^^^^ .. code:: sql bdr.global_advisory_unlock(key bigint) .. _パラメーター-17: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `key`,アドバイザリロックが取得されるオブジェクト。 .. _概要-26: 概要 ^^^^ .. code:: sql bdr.global_advisory_unlock(key1 integer, key2 integer) .. _パラメーター-18: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `key1`,複合キーの最初の部分。 `key2`,複合キーの2番目の部分。 モニタリング機能 ---------------- bdr.monitor_group_versions ^^^^^^^^^^^^^^^^^^^^^^^^^^ クラスター全体のバージョンチェックを提供するために、このファンクションはビュー ``bdr.group_version_details`` から返されたPGDバージョン情報を使用します。 .. _概要-27: 概要 ^^^^ .. code:: sql bdr.monitor_group_versions() .. _注-8: 注 ^^ :ref:`モニタリング パラレル 適用 <モニタリング パラレル 適用>` で説明しているように、このファンクションは、フィールド ``status`` および\ ``message`` を持つレコードを結果ます。 このファンクションは\ ``bdr.run_on_all_nodes()`` を呼び出します。 bdr.monitor_group_raft ^^^^^^^^^^^^^^^^^^^^^^ クラスター全体のRaftチェックを提供するために、このファンクションはビュー\ ``bdr.group_raft_details`` から返されたPGD Raft情報を使用します。 .. _概要-28: 概要 ^^^^ .. code:: sql bdr.monitor_group_raft() .. _パラメーター-19: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `node_group_name`,確認するノードグループ名。 .. _注-9: 注 ^^ :ref:`モニタリング パラレル 適用 <モニタリング パラレル 適用>` で説明しているように、このファンクションは、フィールド ``status`` および\ ``message`` を持つレコードを結果ます。 このファンクションは\ ``bdr.run_on_all_nodes()`` を呼び出します。 bdr.monitor_local_replslots ^^^^^^^^^^^^^^^^^^^^^^^^^^^ このファンクションは、ビュー\ ``pg_replication_slots`` スロットアクティブまたは非アクティブから返されたレプリケーションスロットステータス情報を使用して、PGDグループスロットを除くすべてのレプリケーションスロットを考慮したローカルチェックを提供します。 この機能は、 :ref:`Optimizing subscriber-only groups ` が有効になっているときにPGDクラスターでサブスクライバ専用グループリーダーとして動作しているサブスクライバ専用ノードのステータス情報も提供します。 .. _概要-29: 概要 ^^^^ .. code:: sql bdr.monitor_local_replslots() .. _注-10: 注 ^^ このファンクションは、フィールド\ ``status`` および\ ``message`` を持つレコードを結果ます。 .. csv-table:: :header: Status,Message :widths: 10,30 :align: left :class: longtable UNKNOWN,This node is not part of any BDR group OK,All BDR replication slots are working correctly OK,This node is part of a subscriber-only group CRITICAL,There is at least 1 BDR replication slot which is inactive CRITICAL,There is at least 1 BDR replication slot which is missing :ref:`レプリケーションスロットの監視 <レプリケーションスロットの監視>` で詳細な説明が得られます。 bdr.ts_metrics ^^^^^^^^^^^^^^ このファンクションは、登録されたすべての時系列メトリック定義をリストします。 PGD Monitorは、このレジストリを使用して、 SQL、そのREST API、Web UI、およびPrometheus ``/metrics`` エンドポイント全体で同じメトリック名と説明を与えます。 .. _概要-30: 概要 ^^^^ .. code:: sql bdr.ts_metrics() 出力列 ^^^^^^ .. csv-table:: :header: Column name,Description :widths: 10,30 :align: left :class: longtable `metric_id`,メトリックの内部数値識別子。 `metric_name`,メトリックの名前。同じ名前は、REST API、Web UI、およびPrometheus `/metrics`エンドポイントで使用されます。 `kind`,メトリックの種類、`gauge`または`histogram`。 `value_type`,サンプリング値の保存に使用されるタイプ `int8`または`float8`。 `display_kind`,PGD Monitor Web UIチャートが、より粗い時間範囲平均、最小/最大バンドを使用した平均、最小、または最大にズームアウトしたときにメトリックを要約する方法。 `unit`,メトリックの単位たとえば、バイト、パーセント、秒。 `description`,メトリックの説明。 .. _注-11: 注 ^^ ``bdr_superuser`` 、\ ``bdr_read_all_stats`` 、または\ ``bdr_monitor`` メンバーシップを持つロールによって実行可能。 :ref:`Monitoring metrics reference ` を参照 登録されたメトリックの完全なリストの場合は、 :ref:`Using the PGD Monitor ` それらを公開するインターフェイスの場合。 bdr.ts_latest ^^^^^^^^^^^^^ このファンクションは、名前付けの時系列メトリックの最新のサンプリング値を読み取ります。 .. _概要-31: 概要 ^^^^ .. code:: sql bdr.ts_latest(metric_name text) .. _パラメーター-20: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `metric_name`,`bdr.ts_metrics()`からの`metric_name`値と一致する、読み取るメトリック。 .. _出力列-1: 出力列 ^^^^^^ .. csv-table:: :header: Column name,Description :widths: 10,30 :align: left :class: longtable `ts`,サンプルのタイムスタンプ。 `value_int`,メトリックの`value_type`が`int8`の場合のサンプリング値。 `value_float`,メトリックの`value_type`が`float8`の場合のサンプリング値。 .. _注-12: 注 ^^ ``bdr_superuser`` 、\ ``bdr_read_all_stats`` 、または\ ``bdr_monitor`` メンバーシップを持つロールによって実行可能。 bdr.ts_errors ^^^^^^^^^^^^^ このファンクションは、時系列エラーリングバッファによってキャプチャされた最近のエラーを読み取ります。これは、PGD Monitor Web UIのError Logページをサポートします。 .. _概要-32: 概要 ^^^^ .. code:: sql bdr.ts_errors(max_entries int DEFAULT 50) .. _パラメーター-21: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `max_entries`,返されるエラーエントリの最大数。デフォルト50 .. _出力列-2: 出力列 ^^^^^^ .. csv-table:: :header: Column name,Description :widths: 10,30 :align: left :class: longtable `ts`,エラーのタイムスタンプ。 `sqlerrcode`,エラーのSQLSTATEコード。 `message`,エラーメッセージ。 `detail`,エラーの追加の詳細がある場合。 .. _注-13: 注 ^^ ``bdr_superuser`` 、\ ``bdr_read_all_stats`` 、または\ ``bdr_monitor`` メンバーシップを持つロールによって実行可能。 bdr.ts_samples ^^^^^^^^^^^^^^ このファンクションは、モニタのバックグラウンドワーカーからIPCを介して取得された、特定のダウンサンプリング周波数レベルでメトリックの履歴時系列サンプルを読み取ります。 PGD Monitor Web UIの時系列チャートをバックアップします。 .. _概要-33: 概要 ^^^^ .. code:: sql bdr.ts_samples(metric_name text, level int DEFAULT 0) .. _パラメーター-22: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `metric_name`,`bdr.ts_metrics()`からの`metric_name`値と一致する、読み取るメトリック。 `level`,`0` 最も細かい `4` 最も粗いまでのダウンサンプリング周波数レベル。デフォルト`0` .. _出力列-3: 出力列 ^^^^^^ .. csv-table:: :header: Column name,Description :widths: 10,30 :align: left :class: longtable `ts`,サンプルのタイムスタンプ。 `value`,サンプリング値、またはダウンサンプリングされたウィンドウの平均値。 `min`,ダウンサンプリングされたウィンドウの場合、サンプルウィンドウの最小値。 `max`,ダウンサンプリングされたウィンドウのサンプルウィンドウの最大値。 .. _注-14: 注 ^^ ``bdr_superuser`` 、\ ``bdr_read_all_stats`` 、または\ ``bdr_monitor`` メンバーシップを持つロールによって実行可能。 bdr.ts_histogram ^^^^^^^^^^^^^^^^ ``pgd_commit_latency_milliseconds`` などのヒストグラム種類のメトリックの場合、このファンクションは、指定されたダウンサンプリング周波数レベルでパーセンタイルサマリーp50、p90、p99を読み取ります。 .. _概要-34: 概要 ^^^^ .. code:: sql bdr.ts_histogram(metric_name text, level int DEFAULT 3) .. _パラメーター-23: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `metric_name`,読み取るヒストグラムメトリック。`bdr.ts_metrics()`からの`metric_name`値と一致します。 `level`,読み取るダウンサンプリング周波数レベル、`3`から`4`まで。デフォルト`3` .. _出力列-4: 出力列 ^^^^^^ .. csv-table:: :header: Column name,Description :widths: 10,30 :align: left :class: longtable `ts`,サンプルウィンドウのタイムスタンプ。 `p50`,ウィンドウ内の50パーセンタイル値。 `p90`,ウィンドウ内の90パーセンタイル値。 `p99`,ウィンドウ内の99パーセンタイル値。 `count`,ウィンドウ内の観測値の数。 `sum`,ウィンドウ内の観測値の合計。 `overflow_count`,ヒストグラムの最大バケット境界を超えた観測値。 .. _注-15: 注 ^^ ``bdr_superuser`` 、\ ``bdr_read_all_stats`` 、または\ ``bdr_monitor`` メンバーシップを持つロールによって実行可能。 bdr.ts_histogram_distribution ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ヒストグラム種類のメトリックの場合、このファンクションは、特定のダウンサンプリング周波数レベルですべてのサンプルにわたって集計されたバケットごとの観測数を結果ます。 .. _概要-35: 概要 ^^^^ .. code:: sql bdr.ts_histogram_distribution(metric_name text, level int DEFAULT 3) .. _パラメーター-24: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `metric_name`,読み取るヒストグラムメトリック。`bdr.ts_metrics()`からの`metric_name`値と一致します。 `level`,読み取るダウンサンプリング周波数レベル、`3`から`4`まで。デフォルト`3` .. _出力列-5: 出力列 ^^^^^^ .. csv-table:: :header: Column name,Description :widths: 10,30 :align: left :class: longtable `bucket_upper_ms`,バケットの上限ミリ秒単位。 `count`,バケット内の観測値の数。 .. _注-16: 注 ^^ ``bdr_superuser`` 、\ ``bdr_read_all_stats`` 、または\ ``bdr_monitor`` メンバーシップを持つロールによって実行可能。 bdr.ts_histogram_cumulative ^^^^^^^^^^^^^^^^^^^^^^^^^^^ ヒストグラム種類のメトリックの場合、このファンクションは、\ ``+Inf`` で終わるバケット境界ごとに1行の累積以降開始バケットカウンターを結果ます。これは、Prometheusヒストグラムが公開する\ ``_bucket`` 、\ ``_sum`` 、および\ ``_count`` シリーズと同等のSQLです。 .. _概要-36: 概要 ^^^^ .. code:: sql bdr.ts_histogram_cumulative(metric_name text) .. _パラメーター-25: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `metric_name`,読み取るヒストグラムメトリック。`bdr.ts_metrics()`からの`metric_name`値と一致します。 .. _出力列-6: 出力列 ^^^^^^ .. csv-table:: :header: Column name,Description :widths: 10,30 :align: left :class: longtable `bucket_le_ms`,ミリ秒単位のバケット境界バケットは、この境界以下の値をカバーします。 `cumulative_count`,境界またはそれ以下の観測値の累積数。 `sum_ms`,すべての観測値のミリ秒単位の合計。 `total_count`,すべてのバケットの観測値の合計数。 .. _注-17: 注 ^^ ``bdr_superuser`` 、\ ``bdr_read_all_stats`` 、または\ ``bdr_monitor`` メンバーシップを持つロールによって実行可能。バケットは累積モノトーンカウンターであり、PromQLで予想される規則\ ``histogram_quantile()`` および\ ``rate()`` と一致します。 bdr.wal_sender_stats ^^^^^^^^^^^^^^^^^^^^ :ref:`Decoding worker ` が有効になっている場合、このファンクションは、デコーダースロットと、各WAL送信者によって読み取られている現在の論理変更レコードLCRセグメントファイルに関する情報を表示します。 .. _概要-37: 概要 ^^^^ .. code:: sql bdr.wal_sender_stats() .. _出力列-7: 出力列 ^^^^^^ .. csv-table:: :header: Column name,Description :widths: 10,30 :align: left :class: longtable `pid`,WAL送信者のPID。 `pg_stat_replication`の`pid`列に対応します。 `is_using_lcr`,WAL送信者がLCRファイルを送信しているかどうか。 `decoder_slot_name`,デコーダーレプリケーションスロットの名前。 `lcr_file_name`,現在のLCRファイルの名前。 bdr.get_decoding_worker_stat ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ :ref:`Decoding worker ` が有効になっている場合、このファンクションは、現在のデータベースに関連付けられているデコードワーカーの状態に関する情報を表示します。これは、ワーカーの進行状況のデコードに関するより詳細な情報も提供します ``pg_replication_slots`` を介して利用可能な情報。 .. _概要-38: 概要 ^^^^ .. code:: sql bdr.get_decoding_worker_stat() .. _出力列-8: 出力列 ^^^^^^ .. csv-table:: :header: Column name,Description :widths: 10,30 :align: left :class: longtable `pid`,デコードワーカーのPID。 `pg_replication_slots`の`active_pid`列に対応します。 `decoded_upto_lsn`,デコードワーカーがトランザクションログを読み取るLSN。 `waiting`,デコードワーカーが新しいWALを待機しているかどうか。 `waiting_for_lsn`,次に予想されるWALのLSN。 .. _注-18: 注 ^^ 詳細については、 :ref:`LCRを使用したWAL送信者のモニタリング ` を参照してください。 bdr.lag_control ^^^^^^^^^^^^^^^ :ref:`Lag Control ` が有効になっている場合、このファンクションは、ローカルノードと現在のデータベースの構成された遅延対策に適合するノードの数とコミット遅延に関する情報を表示します。 .. _概要-39: 概要 ^^^^ .. code:: sql bdr.lag_control() .. _出力列-9: 出力列 ^^^^^^ .. csv-table:: :header: Column name,Description :widths: 10,30 :align: left :class: longtable `commit_scope_id`,コミットスコープのOID :ref:``bdr.commit_scopes` 列<`bdr.commit_scopes` 列>` を参照してください。 `sessions`,遅延制御エントリを参照するセッションの数。 `current_commit_delay`,現在のランタイムコミット遅延ミリ秒単位。 `maximum_commit_delay`,構成された最大コミット遅延ミリ秒単位。 `commit_delay_adjust`,サンプルインターバル中に発生する可能性のあるランタイムコミット遅延の変更ミリ秒単位。 `current_conforming_nodes`,遅延対策に適合しているノードの現在の実行時数。 `minimum_conforming_nodes`,遅延対策に適合するために必要なノードの構成済みの最小数。これを下回ると、コミット遅延調整が適用されます。 `lag_bytes_threshold`,コミット遅延が適用される遅延サイズキロバイト単位。 `maximum_lag_bytes`,キロバイト単位の構成された最大遅延サイズ。 `lag_time_threshold`,ミリ秒単位のコミット遅延が適用される遅延時間。 `maximum_lag_time`,設定された最大遅延時間ミリ秒単位。 `sample_interval`,ミリ秒単位の遅延サンプル間の構成された最小時間と考えられるコミット遅延調整。 ルーティング機能 ---------------- bdr.routing_leadership_transfer ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ルーティングリーダーを変更すると、ノードグループのリーダーシップが別のノードに転送されます。 ``leader_name`` が\ ``NULL`` の場合、システムは書き込みリーダーの進行状況に基づいて、最も適切なノードを自動的に選択します。 .. _概要-40: 概要 ^^^^ .. code:: sql bdr.routing_leadership_transfer(node_group_name text, leader_name text DEFAULT NULL, transfer_method text DEFAULT strict, transfer_timeout interval DEFAULT 10s); .. _パラメーター-26: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Name,Type,Default,Description :widths: 15,12,12,20 :align: left :class: longtable `node_group_name`,text,"",リーダーシップの譲渡が要求されたグループの名前。 `leader_name`,text,`NULL`,書き込みリーダーになるノードの名前。 NULLの場合、システムは書き込みリーダーの進行状況に基づいて、最も適切な候補を自動的に選択します。 `transfer_method`,text,`'strict'`,転送の種類。 `'fast'`またはデフォルトの`'strict'`で、最大遅延をチェックします。 `transfer_timeout`,interval,`'10s'`,リーダーシップ転送のタイムアウト。デフォルトは10秒です。自動選択を使用する場合 `leader_name`がNULLの場合、システムはタイムアウトに達するまで、最も進行しているノードの選択を再試行します。 .. _注-19: 注 ^^ ``leader_name`` が\ ``NULL`` の場合、ファンクションは、書き込みリーダーが最も遠いノードを特定し、適切な候補が利用できるかタイムアウトに到達するまで選択を再試行することにより、最適な候補ノードを選択します。自動選択は、手動ノード選択が必要ない自動フェイルオーバーシナリオに役立ちます。コミットスコープ種類としてクォーラムコミットを使用する場合、 ``leader_name`` に\ ``NULL`` を渡して、最も適切なノードの自動選択をトリガーします。 候補者の自動選択 ^^^^^^^^^^^^^^^^ 自動リーダー選択時 ``leader_name`` が\ ``NULL`` の場合 - ルートフェンスされたノード :ref:`bdr.alter_node_option ` を介して\ ``route_fence`` が有効になっているノード は、リーダーシップ譲渡の候補とは見なされません。 - ``route_writes`` が\ ``false`` に設定されているノードは、リーダーシップ移行の候補とは見なされません。 - ``route_priority`` オプションは自動選択に影響を与えません。選択は、適格ノード間の書き込みリーダーの進行状況にのみ基づいて行われます。 混合バージョンのクラスターでの実行 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 自動リーダー選択\ ``leader_name`` の\ ``NULL`` を渡すには、PGD 6.4およびRaftプロトコルバージョン6004以上が必要です。 6. 4より前のノードでファンクションを呼び出すと、古いファンクションシグネチャでは非\ ``NULL`` ``leader_name`` パラメーターが必要であるため、ファンクションはアクションを実行せずに終了します。 7. 4ノードでファンクションを呼び出す場合、動作はRaftプロトコルバージョンによって異なります。 - Raftプロトコルバージョンが6004未満で、PGD 6.4以上のノードがRaftリーダーである場合、ファンクションは\ ``ERROR: leadership auto transfer is supported from raft protocol version 6004 and above`` を結果ます。 - 6.4より前のノードがRaftリーダーの場合、オペレーションはタイムアウトし、\ ``ERROR: switchover timed out`` を結果ます。 信頼性の高い自動リーダー選択を行うには、クラスター内のすべてのノードがRaftプロトコルバージョン6004以上でPGD 6.4以降を実行していることを確認します。 CAMOファンクション ------------------ CAMO、クライアントがトランザクションの進行状況を追跡することにより、トランザクションのコミットに積極的に参加する必要があります。ここにリストされているファンクションはそのために使用され、 :ref:`Commit At Most Once ` で説明されています。 bdr.is_camo_partner_connected ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ペアモードで構成されたCAMOパートナーノードの接続ステータスを確認できます。現在、熱心なレプリケーションで使用されるCAMOに相当するものはありません。 .. _概要-41: 概要 ^^^^ .. code:: sql bdr.is_camo_partner_connected() .. _戻り値-1: 戻り値 ^^^^^^ CAMOパートナーが現在ローカルノード上のWAL送信プロセスに接続しているため、トランザクションデータを受信し、確認を送り返すことができるかどうかを示すブール値。 bdr.is_camo_partner_ready ^^^^^^^^^^^^^^^^^^^^^^^^^ ペアモードで構成されたCAMOパートナーノードの準備状況を確認できます。その下で、これはローカルモードへの、またはローカルモードからのスイッチをトリガーします。 .. _概要-42: 概要 ^^^^ .. code:: sql bdr.is_camo_partner_ready() .. _戻り値-2: 戻り値 ^^^^^^ CAMOパートナーがタイムリーに、つまり\ ``TO ASYNC`` の\ ``timeout`` の有効期限が切れる前に、ローカルノードから発生したトランザクションを確認することが合理的に期待できるかどうかを示すブール値。 .. Note:: このファンクションは、過去または現在の状態を照会します。正の戻り値は、 CAMOパートナーが将来のトランザクションを確認できるかどうかを示しません。 bdr.get_configured_camo_partner ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ この機能は、ローカルノードのCAMOパートナーペアモードで構成を表示します。 .. _概要-43: 概要 ^^^^ .. code:: sql bdr.get_configured_camo_partner() bdr.wait_for_camo_partner_queue ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ このファンクションは、 CAMOパートナーノードを照会することがデフォルトの\ ``bdr.wait_for_apply_queue`` のラッパーです。ローカルノードがCAMOペアの一部でない場合、エラーを返します。 .. _概要-44: 概要 ^^^^ .. code:: sql bdr.wait_for_camo_partner_queue() bdr.camo_transactions_resolved ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ このファンクションは、 CAMOトランザクションが完全に解決されるまでの待機を開始します。 .. _概要-45: 概要 ^^^^ .. code:: sql bdr.camo_transactions_resolved() bdr.logical_transaction_status ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ ノードに障害が発生したときにコミットされていたトランザクションのステータスを確認するには、アプリケーションがこのファンクションを使用し、トランザクションが発生したノードのノードIDと元ノードのトランザクションIDをパラメーターとして渡す必要があります。 .. _概要-46: 概要 ^^^^ .. code:: sql bdr.logical_transaction_status(node_id OID, xid OID, require_camo_partner boolean DEFAULT true) .. _パラメーター-27: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `node_id`,トランザクションが発生するPGDノードのノードID。通常、 :ref:`pg_upgrade ` `bdr.local_node_id`から`COMMIT`の前にクライアントによって取得されます。 `xid`,オリジンノードのトランザクションID。通常、`COMMIT`から :ref:`pg_upgrade ` `transaction_id`の前にクライアントによって取得されます。 `require_camo_partner`,デフォルトでtrueで、構成チェックが有効になります。これらのチェックを無効にし、 CAMOトランザクションではないトランザクションのステータスを照会するには、falseに設定します。 .. _戻り値-3: 戻り値 ^^^^^^ ファンクションは、次のいずれかの結果を返します。 - ``'committed'::TEXT`` — トランザクションはコミットされ、 CAMOペアの両方のノードで可視され、最終的に他のすべてのPGDノードにレプリケートされます。クライアントが再試行する必要はありません。 - ``'aborted'::TEXT`` — トランザクションは中止され、他のPGDノードにレプリケートされません。クライアントは再試行するか、トランザクションのコミットの失敗をエスカレートする必要があります。 - ``'in progress'::TEXT`` — トランザクションはこのローカルノードでまだ進行中であり、まだコミットまたは中止されていません。トランザクションはCOMMITフェーズにあり、 CAMOパートナーがコミットを確認または拒否するのを待機している可能性があります。推奨されるクライアントの反応は、元のノードから切断し、 CAMOパートナーに再接続して、代わりにそれを照会することです。間にロードバランサーまたはプロキシがあり、クライアントがどのノードを照会するかを制御できない場合、クライアントはステータスが\ ``'committed'`` または\ ``'aborted'`` に切り替わるまで、繰り返しポーリングのみできます。 熱心な全ノードレプリケーションの場合、ピアノードはまだコミットまたは中止されていないトランザクションに対してこの結果を生成します。この場合、まだレプリケートされていないトランザクション、またはオリジンノードで開始されていないトランザクションでも、ピアPGDノードで\ ``in progress`` 結果を生成する場合があります。ただし、クライアントは、オリジンでコミットする前にトランザクションステータスを照会してはなりません。 - ``'unknown'::TEXT`` — 指定されたトランザクションは、将来であるか、その特定のノードにまだレプリケートされていない、または過去すぎるため不明です。このようなトランザクションのステータスはまだ知られていない、または不明です。この戻り値は、クライアントによる不適切な使用の兆候です。 クライアントは、エラーが発生した場合にファンクション呼び出しを再試行する準備をする必要があります。 コミットスコープファンクション ------------------------------ bdr.add_commit_scope ^^^^^^^^^^^^^^^^^^^^ **非推奨** 。代わりに `bdr.create_commit_scope `_ を使用してください。以前は、この機能を使用してコミットスコープをノードグループに追加しました。現在は非推奨であり、将来のリリースで削除されるまで警告を発し、その時点でエラーが発生します。 bdr.create_commit_scope ^^^^^^^^^^^^^^^^^^^^^^^ ``bdr.create_commit_scope`` は、指定されたコミットスコープ名とオリジンノードグループのルールを作成します。ルールがEDB Postgres分散クラスター内のすべてのノードで同じである場合、トップレベルのノードグループに対してこのファンクションを1回呼び出すだけで、コミットスコープを完全に定義できます。 または、同じ\ ``commit_scope_name`` ではあるが、トランザクションのオリジンによって異なるオリジンノードグループとコミットスコープのルールを使用して、複数回呼び出すこともできます。 .. _概要-47: 概要 ^^^^ .. code:: sql bdr.create_commit_scope( commit_scope_name NAME, origin_node_group NAME, rule TEXT, wait_for_ready boolean DEFAULT true) .. _注-20: 注 ^^ ``bdr.create_commit_scope`` は、非推奨の `bdr.add_commit_scope `_ ファンクションを置き換えます。 ``add_commit_scope`` とは異なり、同じ名前が使用される場合、既存のコミットスコープをサイレントに上書きしません。代わりに、エラーが報告されます。 bdr.alter_commit_scope ^^^^^^^^^^^^^^^^^^^^^^ ``bdr.alter_commit_scope`` を使用すると、コミットスコープ内のシングルオリジンノードグループの特定のルールを変更できます。 .. _概要-48: 概要 ^^^^ .. code:: sql bdr.alter_commit_scope( commit_scope_name NAME, origin_node_group NAME, rule TEXT) bdr.drop_commit_scope ^^^^^^^^^^^^^^^^^^^^^ コミットスコープ内の単一のルールを削除します。コミットスコープに複数のルールを定義する場合、ルールごとに1回このファンクションを呼び出して、コミットスコープ全体を完全に削除する必要があります。 .. _概要-49: 概要 ^^^^ .. code:: sql bdr.drop_commit_scope( commit_scope_name NAME, origin_node_group NAME) .. Note:: ノードグループによってデフォルトとして使用されているコミットスコープを削除することはできません。 bdr.remove_commit_scope ^^^^^^^^^^^^^^^^^^^^^^^ **非推奨** 。代わりに `bdr.drop_commit_scope `_ を使用してください。以前は、このファンクションはノードグループからコミットスコープを削除するために使用されていました。現在は非推奨であり、将来のリリースで削除されるまで警告を発し、その時点でエラーが発生します。 エラーポリシーファンクションの適用 ---------------------------------- これらの機能を使用すると、適用エラーポリシーによって記録されたレプリケーション障害を確認、解決、および分析できます。構成の詳細については、 :ref:`bdr.alter_node_group_option()を使用したグループ構成 ` の\ ``apply_error_policy`` 、\ ``apply_error_max_retries`` 、\ ``apply_error_max_skips`` 、および\ ``apply_error_max_record_size`` オプションを参照してください。ポリシーの構成と障害を解決するためのステップバイステップガイドについては、 :ref:`Handling replication apply errors ` を参照してください。 bdr.skip_failed_change ^^^^^^^^^^^^^^^^^^^^^^ ``bdr.pending_failed_changes`` でキャプチャされた単一の変更をスキップしたとしてマーキングします。変更ステータスは\ ``skipped`` に更新されますが、行は削除されません。 .. _概要-50: 概要 ^^^^ .. code:: sql bdr.skip_failed_change(change_id bigint) .. _パラメーター-28: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `change_id`,`bdr.pending_failed_changes`のスキップする行の主キー。 bdr.skip_failed_transaction ^^^^^^^^^^^^^^^^^^^^^^^^^^^ 失敗したトランザクション内のすべての保留中の変更をスキップとしてマークし、オプションでサブスクリプションを再度有効にします。 .. _概要-51: 概要 ^^^^ .. code:: sql bdr.skip_failed_transaction( subscription_name name, remote_xid xid, remote_commit_lsn pg_lsn, dry_run boolean DEFAULT false, re_enable boolean DEFAULT false ) bdr.skip_failed_transaction( failed_txn_id uuid, dry_run boolean DEFAULT false, re_enable boolean DEFAULT false ) .. _パラメーター-29: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `subscription_name`,サブスクリプションの名前。 `remote_xid`,元ノードのトランザクションID。 `remote_commit_lsn`,元ノードで失敗したトランザクションのコミットLSN。 `failed_txn_id`,`bdr.pending_failed_changes`からの失敗したトランザクションのUUID。 `subscription_name`、`remote_xid`、および`remote_commit_lsn`を指定するための便利な代替として使用します。 `dry_run`,`true`の場合、何も変更せずにスキップされる変更の数を結果ます。デフォルトは`false`です。 `re_enable`,`true`の場合、スキップした後にサブスクリプションを再度有効にします。デフォルトは`false`です。 .. _戻り値-4: 戻り値 ^^^^^^ スキップされた変更の数を返します。トランザクションが既に解決されている場合、エラーは発生しない場合、 ``0`` を返します。 bdr.apply_failed_change ^^^^^^^^^^^^^^^^^^^^^^^ 1つのキャプチャされた変更を適用して再試行します。 .. _概要-52: 概要 ^^^^ .. code:: sql bdr.apply_failed_change(change_id bigint) .. _パラメーター-30: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `change_id`,適用する`bdr.pending_failed_changes`の行の主キー。 bdr.apply_failed_transaction ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 失敗したトランザクションの保留中の変更をすべて再試行します。デフォルトでドライランモードになるため、コミットする前に結果をプレビューできます。 .. _概要-53: 概要 ^^^^ .. code:: sql bdr.apply_failed_transaction( subscription_name name, remote_xid xid, remote_commit_lsn pg_lsn, dry_run boolean DEFAULT true, re_enable boolean DEFAULT false ) bdr.apply_failed_transaction( failed_txn_id uuid, dry_run boolean DEFAULT true, re_enable boolean DEFAULT false ) .. _パラメーター-31: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `subscription_name`,サブスクリプションの名前。 `remote_xid`,元ノードのトランザクションID。 `remote_commit_lsn`,元ノードで失敗したトランザクションのコミットLSN。 `failed_txn_id`,`bdr.pending_failed_changes`からの失敗したトランザクションのUUID。 `subscription_name`、`remote_xid`、および`remote_commit_lsn`を指定するための便利な代替として使用します。 `dry_run`,`true`デフォルトの場合、実際に変更を適用せずに何が起こるかを示します最後にロールバックします。 `false`を渡して実行します。 `re_enable`,`true`および`dry_run`が`false`の場合、適用後にサブスクリプションを再度有効にします。デフォルトは`false`です。 .. _戻り値-5: 戻り値 ^^^^^^ 次の列を使用して、変更ごとに1行を結果ます。 .. csv-table:: :header: Column,Type,Description :widths: 12,15,25 :align: left :class: longtable `change_num`,`integer`,トランザクション内の変更の順序。 `change_id`,`bigint`,`bdr.pending_failed_changes`の行の主キー。 `operation`,`text`,操作タイプ `INSERT`、`UPDATE`、`DELETE`、`SQL`、`DDL`、または`TRUNCATE` `schema_name`,`text`,ターゲットテーブルのスキーマ。 `table_name`,`text`,ターゲットテーブルの名前。 `status`,`text`,適用試行の結果。 Dry-runモードでは、値は`would_apply`、`would_skip`、または`would_error`です。実行時の値は`apply`、`skip`、または`error`です。 `message`,`text`,変更が失敗した場合はエラーメッセージ、成功した場合は`NULL`。 適用中にエラーが発生した場合、ファンクションは、失敗した変更を含むすべての変更の結果を返します。トランザクションが既に解決されている場合、ファンクションはエラーを発生させずに0行を返します。 bdr.modify_failed_change ^^^^^^^^^^^^^^^^^^^^^^^^ 変更を再試行する前に、キャプチャされた単一の変更の列値を編集します。 ``bdr.pending_failed_changes`` の\ ``modified_values`` 列を更新し、変更ステータスを\ ``modified`` に設定します。 .. _概要-54: 概要 ^^^^ .. code:: sql bdr.modify_failed_change(change_id bigint, new_values jsonb) .. _パラメーター-32: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `change_id`,変更する`bdr.pending_failed_changes`の行の主キー。 `new_values`,変更が再試行されたときに使用する更新された列値を含むJSONBオブジェクト。 bdr.reconstruct_change_sql ^^^^^^^^^^^^^^^^^^^^^^^^^^ キャプチャされた単一の変更の実行可能SQLを生成します。 ``bdr.pending_failed_changes_sql`` ビューは、このファンクションを内部で使用します。 .. _概要-55: 概要 ^^^^ .. code:: sql bdr.reconstruct_change_sql( operation text, schema_name name, table_name name, key_columns jsonb, old_values jsonb, new_values jsonb ) .. _パラメーター-33: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `operation`,操作タイプ。有効な値は`INSERT`、`UPDATE`、`DELETE`、`SQL`、`DDL`、および`TRUNCATE`です。 `schema_name`,ターゲットテーブルのスキーマ。 `table_name`,ターゲットテーブルの名前。 `key_columns`,主キー列値を含むJSONBオブジェクト。 `old_values`,`UPDATE`および`DELETE`操作に使用される、ビフォアイメージ列値を含むJSONBオブジェクト。 `new_values`,`INSERT`および`UPDATE`操作のafter-image列値、または`DDL`および`SQL`操作のSQLテキストを含むJSONBオブジェクト。 .. _戻り値-6: 戻り値 ^^^^^^ 再構成されたSQLステートメントを含む\ ``text`` 文字列を結果ます。元の実行中に検索パスが有効であった場合、 DDL操作には ``SET search_path`` 接頭辞が含まれます。 bdr.reconstruct_failed_transaction ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 失敗したトランザクションでキャプチャされたすべての変更を対象に、\ ``BEGIN`` および\ ``COMMIT`` でラップされた完全なSQLスクリプトを生成します。 .. _概要-56: 概要 ^^^^ .. code:: sql bdr.reconstruct_failed_transaction( subscription_name name, remote_xid xid, remote_commit_lsn pg_lsn ) bdr.reconstruct_failed_transaction(failed_txn_id uuid) .. _パラメーター-34: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `subscription_name`,サブスクリプションの名前。 `remote_xid`,元ノードのトランザクションID。 `remote_commit_lsn`,元ノードで失敗したトランザクションのコミットLSN。 `failed_txn_id`,`bdr.pending_failed_changes`からの失敗したトランザクションのUUID。 `subscription_name`、`remote_xid`、および`remote_commit_lsn`を指定するための便利な代替として使用します。 .. _戻り値-7: 戻り値 ^^^^^^ トランザクション内のすべての変更を含む\ ``text`` SQLスクリプトを結果ます。スクリプトを使用して、完全なトランザクションを確認または手動で再生します。 bdr.resolve_failed_transaction ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 失敗したトランザクションのすべての保留中の変更を解決済みとしてマークし、失敗したトランザクションを超えてサブスクリプションのポジションを進め、オプションでサブスクリプションを再度有効にします。デフォルトでドライランモードになるため、コミットする前に結果をプレビューできます。 .. _概要-57: 概要 ^^^^ .. code:: sql bdr.resolve_failed_transaction( subscription_name name, remote_xid xid, remote_commit_lsn pg_lsn, resolution text DEFAULT skipped, re_enable boolean DEFAULT false, dry_run boolean DEFAULT true ) bdr.resolve_failed_transaction( failed_txn_id uuid, resolution text DEFAULT skipped, re_enable boolean DEFAULT false, dry_run boolean DEFAULT true ) .. _パラメーター-35: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `subscription_name`,サブスクリプションの名前。 `remote_xid`,元ノードのトランザクションID。 `remote_commit_lsn`,元ノードで失敗したトランザクションのコミットLSN。 `failed_txn_id`,`bdr.pending_failed_changes`からの失敗したトランザクションのUUID。 `subscription_name`、`remote_xid`、および`remote_commit_lsn`を指定するための便利な代替として使用します。 `resolution`,適用する解決アクション。有効な値は`skipped`、`applied`、および`discarded`です。デフォルトは`skipped`です。 `re_enable`,`true`の場合、解決後にサブスクリプションを再度有効にします。デフォルトは`false`です。 `dry_run`,`true`デフォルトの場合、変更を加えずにオペレーションが何を行うかの詳細なプレビューを結果ます。 `false`を渡して実行します。 .. _戻り値-8: 戻り値 ^^^^^^ ドライランモードでは、計画的な変更を説明する\ ``text`` レポートを結果ます。 ``dry_run`` が\ ``false`` の場合、適用された解像度の\ ``text`` 確認を結果ます。 .. _注-21: 注 ^^ このファンクションを呼び出すと、概要レコードが\ ``bdr.resolved_transactions`` に挿入されます。解決したら、 ``bdr.pending_failed_changes`` を切り詰めて、解決の履歴を保持しながら領域を再利用できます。 トランザクションが既に解決されている場合、ファンクションは以前の解決に関する詳細を記載したエラーを発生させます。 bdr.analyze_skip_impact ^^^^^^^^^^^^^^^^^^^^^^^ 単一のキャプチャされた変更をスキップした場合の安全性と潜在的なデータへの影響を分析します。エラータイプ、操作、およびオプションで現在のローカルデータベースの状態に基づいて、リスク評価を結果ます。 .. _概要-58: 概要 ^^^^ .. code:: sql bdr.analyze_skip_impact( change_id bigint, verify_state boolean DEFAULT true, include_transaction_analysis boolean DEFAULT true ) .. _パラメーター-36: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `change_id`,分析する`bdr.pending_failed_changes`の行の主キー。 `verify_state`,`true`デフォルトの場合、安全性を評価する前にローカルデータベースを照会して現在の状態を確認します。エラーコードと操作タイプのみに基づいて、より高速な静的分析を行うには `false` を渡します。 `include_transaction_analysis`,`true`デフォルトの場合、同じトランザクション内の他のすべての変更を調べて、依存関係を検出し、警告を生成します。 .. _戻り値-9: 戻り値 ^^^^^^ 次の列を含む行を結果ます。 .. csv-table:: :header: Column,Type,Description :widths: 12,15,25 :align: left :class: longtable `skip_safety`,`text`,安全性分類 `safe`、`caution`、または`risky` `recommendation`,`text`,人間が読める推奨事項。 `explanation`,`text`,エラーコンテキストと状態検証結果を含む詳細な説明。 `data_impact`,`text`,データインパクトレベル `none`、`possible_divergence`、または`certain_divergence`。 `suggested_action`,`text`,推奨されるアクション `skip`、`apply_modified`、または`manual_review`。 `dependency_warnings`,`text[]`,影響を受けるトランザクションの関連変更に関する警告の配列、またはない場合は`NULL`。 安全分類 ^^^^^^^^ .. csv-table:: :header: Safety,Description :widths: 10,30 :align: left :class: longtable `safe`,変更をスキップしても、ノード間でデータの相違が発生する可能性は低いです。 `caution`,軽微な潜在的な問題が存在します。スキップする前に変更を確認します。 `risky`,変更をスキップすると、ノード間でデータの相違が発生する可能性があります。 bdr.analyze_transaction_skip_impact ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ 失敗したトランザクションの保留中のすべての変更のスキップ安全性を分析し、変更ごとに1行を結果ます。 .. _概要-59: 概要 ^^^^ .. code:: sql bdr.analyze_transaction_skip_impact( subscription_name name, remote_xid xid, remote_commit_lsn pg_lsn ) .. _パラメーター-37: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `subscription_name`,サブスクリプションの名前。 `remote_xid`,元ノードのトランザクションID。 `remote_commit_lsn`,元ノードで失敗したトランザクションのコミットLSN。 .. _戻り値-10: 戻り値 ^^^^^^ トランザクション内の変更ごとに1行、次の列を返します。 .. csv-table:: :header: Column,Type,Description :widths: 12,15,25 :align: left :class: longtable `change_seq`,`integer`,トランザクション内の変更の順序。 `operation`,`text`,操作タイプ `INSERT`、`UPDATE`、`DELETE`、`SQL`、`DDL`、または`TRUNCATE` `qualified_table`,`text`,スキーマ修飾テーブル名。 `skip_safety`,`text`,安全性分類 `safe`、`caution`、または`risky` `recommendation`,`text`,人間が読める変更の推奨事項。 `has_dependents`,`boolean`,トランザクションの他の変更がこの変更の結果によって異なるかどうか。 bdr.format_skip_anarise ^^^^^^^^^^^^^^^^^^^^^^^ キャプチャされた単一の変更のスキップセーフティのフォーマット化された人間が判読可能な分析を結果ます。 .. _概要-60: 概要 ^^^^ .. code:: sql bdr.format_skip_analysis(change_id bigint) .. _パラメーター-38: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `change_id`,分析する`bdr.pending_failed_changes`の行の主キー。 .. _戻り値-11: 戻り値 ^^^^^^ 安全性分類、推奨事項、説明、および状態検証結果を含む\ ``text`` レポートを返します。 bdr.alter_subscription_reset_error_counters ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ サブスクリプションのエラーリトライおよびスキップカウンターを初期値にリセットします。レプリケーション障害を解決した後にリセットを使用して、サブスクリプションのエラーポリシーしきい値を新しく適用できるようにします。 .. _概要-61: 概要 ^^^^ .. code:: sql bdr.alter_subscription_reset_error_counters(subscription_name name) .. _パラメーター-39: パラメーター ^^^^^^^^^^^^ .. csv-table:: :header: Parameter,Description :widths: 10,30 :align: left :class: longtable `subscription_name`,サブスクリプションの名前。