Data Transmission Service:ApsaraDB RDS for PostgreSQL インスタンス間の一方向データ同期の設定

ソースデータベースの要件

• テーブルには PRIMARY KEY または UNIQUE 制約が必要で、すべてのフィールドが一意である必要があります。これらの制約がない場合、ターゲットデータベースに重複レコードが含まれる可能性があります。

  [スキーマ同期] を選択せずに同期タスクを作成する場合、宛先テーブルはソーステーブルと同じ PRIMARY KEY または NOT NULL UNIQUE 制約を持つ必要があります。そうしないと、重複レコードが発生する可能性があります。

• 同期オブジェクトとしてテーブルを選択し、宛先でテーブル名や列名を変更する場合、1 つのタスクでサポートされるテーブルの最大数は 5,000 です。5,000 を超えるテーブルの場合は、複数のタスクにワークロードを分割するか、テーブルレベルではなくデータベースレベルで同期してください。

• DTS は、一時テーブル、内部トリガー、または C 言語で書かれた特定の内部プロシージャや関数を同期できません。DTS は、COMPOSITE、ENUM、RANGE 型のカスタムパラメーターを同期できます。テーブルには PRIMARY KEY、FOREIGN KEY、UNIQUE、または CHECK 制約が必要です。

• DTS は、ソースデータベース上に dts_sync_ というプレフィックスを持つレプリケーションスロットを作成し、過去 15 分間の増分ログにアクセスできるようにします。レプリケーションスロットが蓄積されると、ディスク領域を使い果たす可能性があります。論理レプリケーションがアクティブな場合は、ソースインスタンスにディスク使用率のアラームを設定してください。レプリケーションスロットのクリーンアップ動作：

  • DTS インスタンスがリリースされた後、スロットは自動的に削除されます。ただし、ソースデータベースのパスワードを変更した場合や、IP ホワイトリストから DTS の IP アドレスを削除した場合は、手動でスロットを削除する必要があります。

  • ソースでプライマリ/セカンダリのスイッチオーバーが発生した場合、セカンダリデータベースにログインして手動でスロットを削除してください。

• DTS は、DDL 文、増分テーブルスキーマ、およびハートビート情報をキャプチャするために、ソースデータベースに以下の一次テーブルを作成します。同期が実行中はこれらを削除しないでください。DTS インスタンスがリリースされると自動的に削除されます：public.dts_pg_class、public.dts_pg_attribute、public.dts_pg_type、public.dts_pg_enum、public.dts_postgres_heartbeat、public.dts_ddl_command、public.dts_args_session

• DTS は、同期遅延を正確に追跡するために、dts_postgres_heartbeat という名前のハートビートテーブルをソースデータベースに追加します。

• ソース ApsaraDB RDS for PostgreSQL インスタンスで同期を中断せずにプライマリ/セカンダリ スイッチオーバーを実行するには、まず Logical Replication Slot Failover 機能を有効にしてください。詳細については、「Logical Replication Slot Failover」をご参照ください。

• 単一の増分データ変更が 256 MB を超えると、実行中の同期インスタンスは失敗し、回復できません。タスクを再設定する必要があります。

• スキーマ同期および完全データ同期中は、データベースまたはテーブルスキーマを変更する DDL 文を実行しないでください。実行するとタスクは失敗します。

• 増分データ同期中にソースデータベースで長時間実行トランザクションがあると、それらのトランザクションがコミットされる前に生成された WAL ログが蓄積され、ディスク領域を使い果たす可能性があります。

• 同期インスタンスの実行中にソースデータベースでメジャーバージョンアップが実行されると、インスタンスは失敗し、回復できません。タスクを再設定する必要があります。

その他の要件

• 1 つのタスクは 1 つのデータベースからのみデータを同期します。複数のデータベースを同期するには、それぞれに個別のタスクを作成してください。

• DTS は、スキーマ間で継承関係を持つテーブルを同期できません。

• 同期オブジェクトとしてスキーマを選択した場合、そのスキーマ内の新規または名前変更されたテーブルにデータを書き込む前に、次のステートメントを実行してください：

  ALTER TABLE schema.table REPLICA IDENTITY FULL;

  schema と table を実際の名前で置き換えてください。このステートメントはオフピーク時に実行し、テーブルをロックしないようにしてください。このステートメントの実行中にテーブルをロックすると、デッドロックが発生する可能性があります。

• DTS はシーケンスなどのメタデータを検証しません。シーケンスの有効性は手動で確認してください。

• ワークロードをターゲットデータベースに切り替える前に、宛先のシーケンスの開始値を更新してください。切り替え後、新しく書き込まれたシーケンスはソースの最大値から継続しません。

• 宛先アカウントが特権アカウントまたはスーパーユーザーアカウントで、同期対象のテーブルに外部キー、トリガー、またはイベントトリガーが含まれている場合、DTS はセッションレベルで session_replication_role を一時的に replica に設定します。宛先アカウントに必要な権限がない場合は、このパラメーターを手動で replica に設定してください。この間にソースでカスケード UPDATE または DELETE 操作を行うと、データの不整合が発生する可能性があります。タスクがリリースされた後、パラメーターを origin に戻してください。

• 同期中に他のソースからターゲットデータベースにデータを書き込むと、データの不整合が発生します。たとえば、他のソースがターゲットデータベースに書き込んでいる間に DMS からオンライン DDL 文を実行すると、データ損失が発生する可能性があります。

• タスクが失敗した場合、DTS のテクニカルサポートは 8 時間以内に復旧を試みます。復旧中、タスクが再起動されたり、タスクパラメーター (データベースパラメーターではない) が変更されたりすることがあります。

特定のソースデータベースタイプに関する要件

ApsaraDB RDS for PostgreSQL ソース

同期の実行中にソースインスタンスのエンドポイントやゾーンを変更しないでください。変更するとタスクが失敗します。

自己管理型 PostgreSQL ソース

max_wal_senders と max_replication_slots の値は、それぞれ現在使用中のレプリケーションスロットの数と、このデータベース用に作成する予定の DTS インスタンスの数の合計よりも大きい必要があります。

Cloud SQL for PostgreSQL (Google Cloud) ソース

[データベースアカウント] を cloudsqlsuperuser 権限を持つアカウントに設定してください。同期するオブジェクトを選択する際は、そのアカウントが管理を許可されているオブジェクトのみを選択するか、それらのオブジェクトに対する OWNER 権限をそのアカウントに付与してください。

cloudsqlsuperuser 権限を持つアカウントは、同じ権限を持つ他のアカウントが所有するデータを管理できません。

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

DTS コンソールまたは DMS コンソールのいずれかを使用します。

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

1. [タスクの作成] をクリックします。

2. ページの右上隅に [新しい設定ページ] ボタンが表示されている場合は、それをクリックします。

   代わりに [前のバージョンに戻る] が表示されている場合は、このステップをスキップしてください。新しい設定ページと以前の設定ページは若干異なる場合があります。新しいバージョンを使用してください。

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

ステップ 4：接続テスト

ページ下部の [接続テストと次へ] をクリックします。

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

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

[オブジェクトの設定] ステップで、次のパラメーターを設定します：

ステップ 6：詳細設定

[次へ：詳細設定] をクリックし、以下を設定します：

ステップ 7：データ検証の設定 (オプション)

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

ステップ 8：事前チェックの実行

[次へ：タスク設定を保存して事前チェック] をクリックします。

このタスク設定の API パラメーターをプレビューするには、ボタンにカーソルを合わせ、[OpenAPI パラメーターのプレビュー] をクリックしてから進んでください。

DTS はタスクを開始する前に事前チェックを実行します。事前チェックが失敗した場合：

• 失敗した各項目の横にある [詳細の表示] をクリックし、問題を解決してから [再事前チェック] をクリックします。

• 無視できるアラートが表示された項目がある場合は、[アラート詳細の確認] > [無視] > [OK] をクリックし、[再事前チェック] をクリックします。アラートを無視すると、データの不整合につながる可能性があります。

ステップ 9：インスタンスの購入と開始

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

2. 購入ページで、以下を設定します：

   セクション	パラメーター	説明
   [新しいインスタンスクラス]	課金方法	サブスクリプション：データ同期インスタンスを作成する際にサブスクリプション料金を支払います。サブスクリプション課金方法は、長期利用の場合、従量課金方法よりも費用対効果が高くなります。 従量課金：従量課金インスタンスは時間単位で課金されます。従量課金方法は短期利用に適しています。従量課金のデータ同期インスタンスが不要になった場合は、インスタンスをリリースしてコストを削減できます。
   	リソースグループ設定	データ同期インスタンスが属するリソースグループで、デフォルト値は デフォルトリソースグループ です。 詳細については、「Resource Management とは」をご参照ください。
   	インスタンスクラス	DTS では、同期速度の異なるインスタンスクラスが提供されています。ビジネス要件に基づいてインスタンスクラスを選択できます。詳細については、「データ同期インスタンスのインスタンスクラス」をご参照ください。
   	サブスクリプション期間	サブスクリプション課金方法を選択した場合、サブスクリプション期間と作成したいデータ同期インスタンスの数を指定します。サブスクリプション期間は 1～9 ヶ月、1 年、2 年、3 年、または 5 年です。 注 このパラメーターは、[サブスクリプション] 課金方法を選択した場合にのみ利用可能です。

3. [Data Transmission Service (従量課金) 利用規約] を読み、同意します。

4. [購入して開始] をクリックし、ダイアログで [OK] をクリックします。

タスクリストでタスクの進捗状況を確認します。