Data Transmission Service:PostgreSQL インスタンスと PolarDB for PostgreSQL クラスター間の双方向データ同期の設定

循環同期の防止

変更が無限ループで戻らないようにするため、双方向同期インスタンス実行時に DTS はソースおよびターゲットのデータベース双方に dts という名前のスキーマを作成します。DTS はこのスキーマを使用して、レプリケーションによって発生した変更を追跡し、それらの変更が逆方向に再レプリケーションされないようにします。

タスク実行中は、dts スキーマを変更しないでください。

DDL 同期の方向

DDL 操作は順方向（ソース → ターゲット）のみで同期されます。逆方向では DDL 操作は無視されます。

順方向および逆方向タスクのルール

両タスクが同一のオブジェクトを同期するように設定されている場合：

• 完全データおよび増分データの両方を同期できるのは、通常は順方向タスクのみです。もう一方のタスクは増分データのみを同期します。

• 順方向タスクで同期されたデータは、逆方向タスクのソースデータとして使用されません。

ソースデータベースの制限

その他の制限

ワークロード切り替え前にソースデータベースで最大シーケンス値を照会するには：

do language plpgsql $$
declare
  nsp name;
  rel name;
  val int8;
begin
  for nsp,rel in select nspname,relname from pg_class t2 , pg_namespace t3 where t2.relnamespace=t3.oid and t2.relkind='S'
  loop
    execute format($_$select last_value from %I.%I$_$, nsp, rel) into val;
    raise notice '%',
    format($_$select setval('%I.%I'::regclass, %s);$_$, nsp, rel, val+1);
  end loop;
end;
$$;

返された SQL ステートメントは、ソースデータベース内のすべてのシーケンスをカバーしています。ターゲットデータベースでは、ご要件に関連するステートメントのみを実行してください。

特殊ケース

ステップ 1：データ同期ページを開く

以下のいずれかの方法を使用してください。

ステップ 2：タスクの作成

タスクの作成 をクリックして、タスク設定ページに移動します。

任意: ページに 前のバージョンに戻る と表示されている場合、右上隅の 新しい設定ページ をクリックします。前のバージョンに戻る がすでに表示されている場合は、このステップをスキップしてください。

新しい設定ページと前のバージョンの設定ページでは、一部のパラメーターが異なります。新しいバージョンをご利用ください。

ステップ 3：ソースおよびターゲットデータベースの設定

ステップ 4：接続性のテストと続行

ページ下部の 接続性のテストと続行 をクリックします。

ソースデータベースとターゲットデータベースの両方のセキュリティ設定に、DTS サーバーの CIDR ブロックが追加されていることを確認してください。 詳細については、「DTS サーバーの CIDR ブロックを追加する」をご参照ください。 [Alibaba Cloud インスタンス] に設定されていない自己管理データベースの場合、[DTS サーバーの CIDR ブロック] ダイアログボックスで [接続テスト] をクリックします。

ステップ 5：同期対象オブジェクトの設定

1. オブジェクトの設定 ステップで、以下のパラメーターを設定します。

   パラメーター	説明
   同期タイプ	スキーマ同期、完全データ同期、増分データ同期を選択します。DTS は、まず既存データを同期し、それを後続の増分同期の基礎とします。
   同期トポロジー	双方向同期を選択します。
   DDL 操作を除外	DDL 同期を除外する場合は はい を、含める場合は いいえ を選択します。DDL 操作は転送方向にのみ同期されます。このパラメーターは、転送タスクを設定する場合にのみ表示されます。
   グローバル競合解決ポリシー	競合を処理するためのポリシーを選択します。詳細については、「サポートされている競合検出」をご参照ください。タスクを一時停止して再開した場合、その間の遅延ウィンドウではこのポリシーは適用されず、デフォルトで送信先のデータが上書きされます。
   競合するテーブルの処理モード	事前チェックとエラー報告オブジェクト名のマップ：送信先にソーステーブルと同じ名前のテーブルが存在する場合、事前チェックは失敗します。送信先テーブルを削除または名前変更できない場合は、「」を使用して名前を変更します。エラーを無視して続行：同じテーブル名に対する事前チェックをスキップします。完全データ同期中、プライマリキーまたは一意キーが一致する既存の送信先レコードは保持されます。増分同期中、それらは上書きされます。スキーマが異なる場合、データ初期化が失敗する可能性があります。注意して進めてください。
   ソースオブジェクト	ソースオブジェクト セクションからオブジェクトを選択し、矢印アイコンをクリックして 選択したオブジェクト セクションに移動します。列、テーブル、またはスキーマを選択できます。
   選択したオブジェクト	オブジェクト名のマップオブジェクトを右クリックして、送信先での名前を変更したり (「」をご参照ください)、WHERE フィルター条件を設定したり (「フィルター条件の指定」をご参照ください)、そのオブジェクトに対して同期する SQL 操作を選択したりできます。オブジェクトをクリックしてから削除アイコンをクリックすると、そのオブジェクトを削除できます。オブジェクトの名前を変更すると、依存オブジェクトの同期が失敗する可能性があることにご注意ください。

2. 次へ：高度な設定 をクリックし、以下の内容を設定します。

   パラメーター	説明
   タスクスケジューリング専用クラスター	デフォルトでは、DTS は共有クラスターを使用します。安定性を向上させるには、専用クラスターを購入してください。詳細については、「DTS 専用クラスターとは」をご参照ください。
   接続失敗時のリトライ時間	タスク開始後の接続失敗時のリトライ時間範囲です。有効値：10～1440 分。デフォルト：720 分。30 分を超える値を設定してください。このウィンドウ内で DTS が再接続できた場合、タスクは再開されます。それ以外の場合は、タスクが失敗します。複数のタスクが同一のソースまたはターゲットデータベースを共有する場合、最も短いリトライウィンドウが適用されます。リトライ中は、インスタンスに対して課金されます。
   その他の問題発生時のリトライ時間	失敗した DDL または DML 操作のリトライ時間範囲です。有効値：1～1440 分。デフォルト：10 分。10 分を超える値を設定してください。この値は、接続失敗時のリトライ時間 より小さくする必要があります。
   完全データ同期のスロットリング有効化	完全データ同期中の読み取り／書き込みリソース使用量を制限します。ソースデータベースへのクエリ数（QPS）、完全データ移行の RPS、および 完全移行のデータ移行速度（MB/s） を設定します。完全データ同期 を選択した場合にのみ利用可能です。
   増分データ同期のスロットリング有効化	増分同期中のリソース使用量を制限します。増分データ同期の RPS および 増分同期のデータ同期速度（MB/s） を設定します。
   環境タグ	DTS インスタンスを識別するためのタグです。任意項目です。
   ETL の設定	[はい] を選択して、抽出・変換・書き出し (ETL) を有効にし、データ処理文を入力します。[いいえ] を選択するとスキップされます。詳細については、「ETL とは？」および「データ移行またはデータ同期タスクで ETL を設定する」をご参照ください。
   モニタリングとアラート	タスクが失敗した場合や同期遅延がしきい値を超えた場合に通知を受信するには、[はい] を選択します。アラートのしきい値と通知設定を設定します。詳細については、「DTS タスクを作成するときにモニタリングとアラートを設定する」をご参照ください。スキップするには、[いいえ] を選択します。

3. [次のステップ: データ検証] をクリックして、データ検証を設定します。 「データ検証タスクを設定する」をご参照ください。

ステップ 6：設定の保存と事前チェックの実行

ページ下部の 次へ：タスク設定の保存と事前チェック をクリックします。

このタスクの API パラメーターをプレビューするには、次へ：タスク設定の保存と事前チェック の上にポインターを移動し、OpenAPI パラメーターのプレビュー をクリックしてください。

DTS はタスク開始前に事前チェックを実行します。事前チェックが成功した場合にのみ、タスクが開始されます。

事前チェックが失敗した場合は、各失敗項目の横にある 詳細の表示 をクリックし、問題を解決してから 再び事前チェック をクリックしてください。

事前チェックでアラートが発生した場合：

無視できないアラートの場合は、詳細の表示 をクリックして問題を修正し、再び事前チェックを実行してください。

無視できるアラートの場合は、アラート詳細の確認 ＞ 無視 ＞ OK ＞ 再び事前チェック をクリックしてください。アラートを無視すると、データの不整合が発生する可能性があります。

ステップ 7：同期インスタンスの購入

成功率 が 100% に達するまで待ち、その後 次へ：インスタンスの購入 をクリックします。

購入 ページで、以下の内容を設定します。

Data Transmission Service（従量課金）サービス利用規約 を読み、チェックボックスをオンにしてから、購入して開始 をクリックします。確認ダイアログボックスで、OK をクリックしてください。

タスクはタスクリストに表示されます。そこから進行状況を監視できます。

ステップ 8：順方向同期タスクの実行開始を待機

順方向同期タスクの ステータス が 実行中 に変わり、初期同期が完了するまで待ちます。

ステップ 9：逆方向同期タスクの設定

1. タスクリストで逆方向同期タスクを見つけ、 タスクの設定 をクリックします（操作 列）。

2. ステップ 3～6 を踏んで逆方向タスクを設定します。順方向タスクと逆方向タスクの主な違い に記載された制約を適用してください。

   重要

   - ソースとターゲットを入れ替えます：逆方向タスクのソースは順方向タスクのターゲット（PolarDB for PostgreSQL）であり、ターゲットは順方向タスクのソース（ApsaraDB RDS for PostgreSQL）です。- インスタンスリージョン は固定されており、変更できません。- コンソールに表示されるパラメーターのみを設定してください — 逆方向タスクでは表示されるパラメーターが少なくなります。- 順方向タスクでターゲットに既に同期済みのテーブルは、逆方向の 競合テーブルの処理モード チェックから除外されます。- 順方向タスクで選択したオブジェクトを逆方向タスクで再利用しないでください。- オブジェクト名マッピング機能の使用は避けてください — データの不整合を引き起こす可能性があります。

3. 成功率 が 100% に達するまで待ち、その後 戻る をクリックします。

ステップ 10：双方向同期の実行確認

順方向および逆方向の同期タスクの ステータス がともに 実行中 に変わることを確認します。これで双方向データ同期が有効になります。