PolarDB for PostgreSQLクラスター間の一方向同期の設定 - Data Transmission Service

このトピックでは、Data Transmission Service (DTS) を使用して、PolarDB for PostgreSQLクラスター間の一方向の同期を設定する方法について説明します。

前提条件

ソースおよびターゲットのPolarDB for PostgreSQLクラスターが作成されます。詳細については、「クラスターの作成」をご参照ください。
wal_levelパラメーターは、ソースおよびターゲットのPolarDB for PostgreSQLクラスターに対してlogicalに設定されます。詳細は、「クラスターパラメーターの指定」をご参照ください。
ターゲットデータベースの使用可能なストレージ容量は、ソースデータベースのデータの合計サイズよりも大きくなります。

使用上の注意

説明

スキーマ同期中、DTSはソースデータベースからターゲットデータベースに外部キーを同期します。
完全データ同期および増分データ同期中、DTSはセッションレベルで外部キーに対する制約チェックおよびカスケード操作を一時的に無効にします。データ同期中にソースデータベースに対してカスケード更新および削除操作を実行すると、データの不整合が発生する可能性があります。

カテゴリ	説明
ソースデータベースの制限	ソースPolarDB for PostgreSQLクラスターから同期するテーブルには、プライマリキーまたはUNIQUE NOT NULLインデックスが含まれている必要があります。ソースデータベースが1つまたは複数の長期トランザクションを有し、増分データがデータ同期タスクで同期される場合、ソースデータベース内の長期トランザクションがコミットされる前に生成されたライトアヘッドロギング (WAL) ログを蓄積することができる。その結果、ソースデータベースのディスク容量が不足する可能性があります。ソースPolarDB for PostgreSQLクラスターでプライマリ /セカンダリの切り替えを実行する場合は、論理レプリケーションスロットのフェールオーバー機能を有効にする必要があります。これにより、論理サブスクリプションの中断を防ぎ、データ同期タスクを期待どおりに実行できます。詳細については、「論理レプリケーションスロットフェールオーバー」をご参照ください。スキーマ同期および完全データ同期中は、DDL文を実行してデータベースまたはテーブルのスキーマを変更しないでください。それ以外の場合、データ同期タスクは失敗します。
その他の制限	最初の完全データ同期中、DTSはソースデータベースとターゲットデータベースの読み取りおよび書き込みリソースを使用します。これにより、データベースサーバーの負荷が増加します。したがって、データ同期を実行する前に、ソースデータベースとターゲットデータベースのパフォーマンスを評価する必要があります。オフピーク時にデータ同期を実行することを推奨します。初期の完全データ同期中に、同時INSERT操作により、ターゲットデータベースのテーブルが断片化されます。最初の完全データ同期が完了すると、ターゲットデータベースのテーブルスペースはソースデータベースのテーブルスペースよりも大きくなります。データ同期中は、DTSのみを使用してデータをターゲットデータベースに書き込むことをお勧めします。これにより、ソースと宛先間のデータの不一致が防止されます。データ同期中、DTSはソースデータベースにレプリケーションスロットを作成してデータをレプリケートします。レプリケーションスロットの先頭に`dts_sync_` があります。 DTSは、このレプリケーションスロットを使用して、過去15分以内にソースデータベースの増分ログを取得できます。説明データ同期タスクがリリースまたは失敗した場合、DTSは自動的にレプリケーションスロットを削除します。ソースデータベースでプライマリ /セカンダリの切り替えを実行する場合は、セカンダリデータベースにログインして、レプリケーションスロットを手動で削除する必要があります。 DTSは、シーケンスなどのメタデータの有効性をチェックしません。メタデータの有効性を手動で確認する必要があります。ワークロードがターゲットデータベースに切り替えられた後、新しく書き込まれたシーケンスは、ソースデータベースのシーケンスの最大値から増加しません。したがって、ワークロードをターゲットデータベースに切り替える前に、ソースデータベース内のシーケンスの最大値を照会する必要があります。次に、クエリされた最大値をターゲットデータベースのシーケンスの初期値として指定する必要があります。ソースデータベース内のシーケンスの最大値を照会するには、次のステートメントを実行します。 `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; $$;` 完全なデータ同期または増分データ同期を実行するために、特権アカウントまたはスーパーユーザーアカウントを宛先データベースアカウントとして使用し、同期するテーブルに外部キー、トリガー、またはイベントトリガーが含まれている場合、DTSは一時的にsession_replication_roleパラメーターをセッションレベルでレプリカに設定します。移行先データベースアカウントに必要な権限がない場合は、session_replication_roleパラメーターを手動でレプリカに設定する必要があります。 session_replication_roleパラメーターの値がreplicaであり、完全データ同期または増分データ同期中にソースデータベースに対してカスケード更新または削除操作を実行すると、データの不整合が発生する可能性があります。データ同期タスクがリリースされた後、session_replication_roleパラメーターの値を元に戻すことができます。

課金

同期タイプ	タスク設定料金
スキーマ同期と完全データ同期	無料です。
増分データ同期	有料。詳細については、「課金の概要」をご参照ください。

サポートしている同期トポロジ

一方向の 1 対 1 の同期
一方向の 1 対多の同期
一方向の多対 1 の同期

DTSでサポートされている同期トポロジの詳細については、「同期トポロジ」をご参照ください。

同期可能なSQL操作

操作タイプ	SQL文
DML	挿入、更新、および削除説明データがコピー先のAnalyticDB for PostgreSQLインスタンスに書き込まれると、UPDATEステートメントは自動的にREPLACE INTOステートメントに変換されます。 UPDATE文が主キーで実行された場合、UPDATE文はDELETE文とINSERT文に変換されます。
DDL	DDL操作は、2020年10月1日以降に作成されたデータ同期タスクによってのみ同期できます。重要 5月12日より前に作成されたデータ同期タスク2023を使用してDDL操作を同期するには、データ同期タスクを設定する前に、ソースデータベースにトリガーと関数を作成してDDL情報を取得する必要があります。詳細については、「トリガーと関数を使用してPostgreSQLデータベースの増分DDL移行を実装する」をご参照ください。増分データ同期中は、BITタイプのデータを同期できません。ソースデータベースのアカウントが特権アカウントの場合、データ同期タスクは次のDDL操作をサポートします。テーブルとドロップテーブルの作成 ALTER TABLE (RENAME TABLE、ADD COLUMN、ADD COLUMN DEFAULT、ALTER COLUMN TYPE、DROP COLUMN、ADD CONSTRAINT、ADD CONSTRAINT CHECK、およびALTER COLUMN DROP DEFAULTを含む) TRUNCATE TABLE (ソースのPolarDB for PostgreSQLクラスターのメジャーエンジンバージョンは、PostgreSQL 11以降である必要があります) 。テーブルにインデックスを作成する重要 CASCADEやRESTRICTなど、DDLステートメントの追加情報を同期することはできません。 `SET session_replication_role = replica`ステートメントが実行されたセッションからDDLステートメントを同期することはできません。 FUNCTIONなどのメソッドを呼び出すことによって実行されるDDLステートメントは同期できません。ソースデータベースによって同時にコミットされた複数のSQL文にDML文とDDL文の両方が含まれている場合、DTSはDDL文を同期しません。ソースデータベースによって同時にコミットされた複数のSQL文に、同期されていないオブジェクトのDDL文が含まれている場合、DDL文は同期されません。

手順

[データ同期タスク] ページに移動します。
1. データ管理 (DMS) コンソールにログインします。
2. 上部のナビゲーションバーで、DTS をクリックします。
3. 左側のナビゲーションウィンドウで、DTS (DTS) > データ同期を選択します。
説明
- 操作は、DMSコンソールのモードとレイアウトによって異なります。詳細については、「シンプルモード」および「DMSコンソールのレイアウトとスタイルのカスタマイズ」をご参照ください。
- 新しいDTSコンソールのデータ同期タスクページに行くこともできます。
データ同期タスクの右側で、データ同期インスタンスが存在するリージョンを選択します。
説明
新しいDTSコンソールを使用する場合は、上部のナビゲーションバーでデータ同期インスタンスが存在するリージョンを選択する必要があります。
タスクの作成 をクリックして、タスク設定ページに移動します。
(オプションの手順) ページの右上隅にある 新バージョンの設定ページを試してみる をクリックします。
説明
- ページの右上隅に 旧バージョンの設定ページに戻る ボタンが表示されている場合は、この手順をスキップします。
- 構成ページの新しいバージョンと以前のバージョンの特定のパラメータは異なる場合があります。設定ページの新しいバージョンを使用することを推奨します。

ソースデータベースとターゲットデータベースを設定します。下表に、各パラメーターを説明します。

セクション	パラメーター	説明
非該当	タスク名	DTSタスクの名前。タスク名は自動生成されます。タスクを簡単に識別できるように、わかりやすい名前を指定することをお勧めします。一意のタスク名を指定する必要はありません。
ソースデータベース	既存のDMSデータベースインスタンスの選択	使用するデータベースインスタンス。ビジネス要件に基づいて、既存のインスタンスを使用するかどうかを選択できます。既存のインスタンスを選択すると、DTSはデータベースのパラメーターを自動的に入力します。既存のインスタンスを選択しない場合は、次のデータベース情報を設定する必要があります。
	データベースタイプ	移行元ディスクのタイプを設定します。 PolarDB for PostgreSQL を選択します。
	アクセス方法	ソースデータベースのアクセス方法。 [Alibaba Cloudインスタンス] を選択します。
	インスタンスリージョン	ソースPolarDB for PostgreSQLクラスターが存在するリージョン。
	Alibaba Cloudアカウント全体でのデータの複製	Alibaba Cloudアカウント間でデータを同期するかどうかを指定します。この例では、[いいえ] が選択されています。
	インスタンスID	ソースPolarDB for PostgreSQLクラスターのID。
	データベース名	PolarDB for PostgreSQLクラスター内のソースデータベースの名前。
	データベースアカウント	PolarDB for PostgreSQLクラスターのデータベースアカウント。
	データベースパスワード	データベースインスタンスへのアクセスに使用されるパスワード。
宛先データベース	既存のDMSデータベースインスタンスの選択	使用するデータベースインスタンス。ビジネス要件に基づいて、既存のインスタンスを使用するかどうかを選択できます。既存のインスタンスを選択すると、DTSはデータベースのパラメーターを自動的に入力します。既存のインスタンスを選択しない場合は、次のデータベース情報を設定する必要があります。
	データベースタイプ	ターゲットデータベースのタイプ。 PolarDB for PostgreSQL を選択します。
	アクセス方法	ターゲットデータベースのアクセス方法。 [Alibaba Cloudインスタンス] を選択します。
	インスタンスリージョン	移行先のPolarDB for PostgreSQLクラスターが存在するリージョン。
	インスタンスID	移行先のPolarDB for PostgreSQLクラスターのID。
	データベース名	移行先のPolarDB for PostgreSQLクラスターの名前。
	データベースアカウント	移行先PolarDB for PostgreSQLクラスターの特権アカウント。詳細については、「データベースアカウントの作成」をご参照ください。
	データベースパスワード	データベースインスタンスへのアクセスに使用されるパスワード。

ページの下部で、接続性をテストして続行をクリックします。
ソースまたはターゲットデータベースがAlibaba Cloudデータベースインスタンス (ApsaraDB RDS for MySQLインスタンスやApsaraDB for MongoDBインスタンスなど) の場合、DTSは自動的にDTSサーバーのCIDRブロックをインスタンスのホワイトリストに追加します。ソースデータベースまたはターゲットデータベースがElastic Compute Service (ECS) インスタンスでホストされている自己管理データベースの場合、DTSサーバーのCIDRブロックがECSインスタンスのセキュリティグループルールに自動的に追加されます。ECSインスタンスがデータベースにアクセスできるようにする必要があります。ソースデータベースまたはターゲットデータベースが、データセンターにデプロイされているか、サードパーティのクラウドサービスプロバイダーによって提供される自己管理データベースである場合、DTSサーバーのCIDRブロックをデータベースのホワイトリストに手動で追加して、DTSがデータベースにアクセスできるようにする必要があります。詳細については、「DTSサーバーのCIDRブロックの追加」をご参照ください。
警告
DTSサーバーのCIDRブロックがデータベースまたはインスタンスのホワイトリスト、またはECSセキュリティグループルールに自動的または手動で追加されると、セキュリティリスクが発生する可能性があります。したがって、DTSを使用してデータを同期する前に、潜在的なリスクを理解して認識し、次の対策を含む予防策を講じる必要があります。VPNゲートウェイ、またはSmart Access Gateway。

同期するオブジェクトを設定します。

オブジェクト設定 ページで、同期するオブジェクトを設定します。

パラメーター	説明
同期タイプ	同期タイプ。デフォルトでは、増分データ同期が選択されています。 [スキーマ同期] および [完全データ同期] も選択する必要があります。事前チェックが完了すると、DTSは選択したオブジェクトの履歴データをソースデータベースからターゲットクラスターに同期します。履歴データは、その後の増分同期の基礎となる。
同期トポロジ	同期トポロジ。一方向同期を選択します。
競合するテーブルの処理モード	エラーの事前チェックと報告: ターゲットデータベースに、ソースデータベースのテーブルと同じ名前のテーブルが含まれているかどうかを確認します。ソースデータベースとターゲットデータベースに同じテーブル名のテーブルが含まれていない場合は、事前チェックに合格します。それ以外の場合、事前チェック中にエラーが返され、データ同期タスクを開始できません。説明ソースデータベースとターゲットデータベースに同じ名前のテーブルが含まれていて、ターゲットデータベース内のテーブルを削除または名前変更できない場合は、オブジェクト名マッピング機能を使用して、ターゲットデータベースに同期されるテーブルの名前を変更できます。詳細については、「マップオブジェクト名」をご参照ください。エラーを無視して続行: ソースデータベースとターゲットデータベースの同じテーブル名の事前チェックをスキップします。警告エラーを無視して続行を選択すると、データの不整合が発生し、ビジネスが潜在的なリスクにさらされる可能性があります。ソースデータベースとターゲットデータベースが同じスキーマを持ち、ターゲットデータベースのデータレコードがソースデータベースのデータレコードと同じ主キー値または一意キー値を持つ場合: 完全データ同期中、DTSはデータレコードをターゲットデータベースに同期しません。ターゲットデータベースの既存のデータレコードが保持されます。増分データ同期中、DTSはデータレコードをターゲットデータベースに同期します。ターゲットデータベースの既存のデータレコードが上書きされます。ソースデータベースとターゲットデータベースのスキーマが異なる場合、データの初期化に失敗する可能性があります。この場合、一部の列のみが同期されるか、データ同期タスクが失敗します。作業は慎重に行ってください。
移行先インスタンスでのオブジェクト名の大文字化	ターゲットインスタンスのデータベース名、テーブル名、および列名の大文字化。デフォルトでは、DTSデフォルトポリシーが選択されています。他のオプションを選択して、オブジェクト名の大文字化をソースまたはターゲットデータベースの大文字化と一致させることができます。詳細については、「ターゲットインスタンスのオブジェクト名の大文字化の指定」をご参照ください。
ソースオブジェクト	ソースオブジェクトセクションから1つ以上のオブジェクトを選択し、アイコンをクリックして選択中のオブジェクトセクションにオブジェクトを追加します。説明同期するオブジェクトとして、列、テーブル、またはデータベースを選択できます。同期するオブジェクトとしてテーブルまたは列を選択した場合、DTSはビュー、トリガー、ストアドプロシージャなどの他のオブジェクトをターゲットデータベースに同期しません。
選択中のオブジェクト	同期先のインスタンスに同期するオブジェクトの名前を変更するには、選択中のオブジェクトセクションでオブジェクトを右クリックします。詳細については、「オブジェクト名のマップ」トピックの「単一オブジェクトの名前のマップ」セクションをご参照ください。一度に複数のオブジェクトの名前を変更するには、選択中のオブジェクトセクションの右上隅にある一括編集をクリックします。詳細については、「オブジェクト名のマップ」トピックの「一度に複数のオブジェクト名をマップする」セクションをご参照ください。説明特定のデータベースまたはテーブルで実行されたSQL操作を選択するには、[選択済みオブジェクト] セクションでオブジェクトを右クリックします。表示されるダイアログボックスで、同期するSQL操作を選択します。同期できるSQL文の詳細については、このトピックの「同期できるSQL操作」をご参照ください。データをフィルタリングするWHERE条件を指定するには、[選択済みオブジェクト] セクションでテーブルを右クリックします。表示されるダイアログボックスで、条件を指定します。詳細については、「フィルター条件の指定」をご参照ください。

次へ：詳細設定 をクリックして詳細設定を設定します。

パラメーター	説明
タスクのスケジュールに使用する専用クラスターの選択	デフォルトでは、DTSはタスクを共有クラスターにスケジュールします。このパラメーターを設定する必要はありません。データ同期タスクの安定性を向上させたい場合は、専用クラスターを購入してください。詳細については、「DTS専用クラスターの概要」をご参照ください。
失敗した接続の再試行時間	失敗した接続のリトライ時間範囲。データ同期タスクの開始後にソースデータベースまたはターゲットデータベースの接続に失敗した場合、DTSはその時間範囲内ですぐに接続を再試行します。有効な値: 10 ~ 1440 単位は分です。デフォルト値: 720 このパラメーターを30より大きい値に設定することを推奨します。 DTSが指定された時間範囲内にソースデータベースとターゲットデータベースに再接続すると、DTSはデータ同期タスクを再開します。それ以外の場合、データ同期タスクは失敗します。説明ソースまたはターゲットデータベースが同じである複数のデータ同期タスクに対して異なるリトライ時間範囲を指定した場合、最も短いリトライ時間範囲が優先されます。 DTSが接続を再試行すると、DTSインスタンスに対して課金されます。業務要件に基づいて再試行時間範囲を指定することを推奨します。ソースインスタンスとターゲットインスタンスがリリースされた後、できるだけ早くDTSインスタンスをリリースすることもできます。
移行元データベースと移行先データベースで他の問題が発生した場合の、再試行までの待機時間です。	その他の問題の再試行時間範囲。たとえば、データ同期タスクの開始後にDDLまたはDML操作の実行に失敗した場合、DTSはその時間範囲内ですぐに操作を再試行します。有効な値: 1 ~ 1440 単位は分です。デフォルト値は 10 です。このパラメーターを10より大きい値に設定することを推奨します。指定された時間範囲内で失敗した操作が正常に実行されると、DTSはデータ同期タスクを再開します。それ以外の場合、データ同期タスクは失敗します。重要移行元データベースと移行先データベースで他の問題が発生した場合の、再試行までの待機時間です。パラメーターの値は、失敗した接続の再試行時間パラメーターの値よりも小さくする必要があります。
完全移行率を制限するかどうか	完全データ同期中、DTSはソースデータベースとターゲットデータベースの読み取りおよび書き込みリソースを使用します。これにより、データベースサーバーの負荷が増加する可能性があります。 1 秒あたりのソースデータベースのクエリ率 QPS 、1 秒あたりの完全移行の行数 RPS、および1 秒あたりの完全移行データ量 (MB) BPS パラメーターを設定して、ターゲットデータベースサーバーの負荷を軽減できます。説明このパラメーターは、同期タイプパラメーターで完全データ同期が選択されている場合にのみ表示されます。
増分同期率を制限するかどうか	増分データ同期のスロットリングを有効にするかどうかを指定します。ビジネス要件に基づいて、増分データ同期のスロットリングを有効にできます。スロットリングを設定するには、1 秒あたりの増分同期の行数 RPSおよび1 秒あたりの増分同期データ量 (MB) BPS パラメーターを設定する必要があります。これにより、移行先データベースサーバーの負荷が軽減されます。
環境タグ	DTSインスタンスを識別するために使用される環境タグ。ビジネス要件に基づいて環境タグを選択できます。この例では、このパラメーターを設定する必要はありません。
ETL の設定	抽出、変換、および読み込み (ETL) 機能を有効にするかどうかを指定します。詳細については、「ETLとは何ですか?」をご参照ください。有効な値： Yes: ETL機能を設定します。コードエディターでデータ処理ステートメントを入力できます。詳細については、「データ移行またはデータ同期タスクでのETLの設定」をご参照ください。 No: ETL機能を設定しません。
監視アラート	データ同期タスクのアラートを設定するかどうかを指定します。タスクが失敗するか、同期レイテンシが指定されたしきい値を超えると、アラート送信先は通知を受け取ります。有効な値： No: アラートを有効にしません。 Yes: アラートを設定します。この場合、アラートしきい値とアラート通知設定詳細については、「モニタリングとアラートの設定」トピックの「DTSタスクを作成するときのモニタリングとアラートの設定」をご参照ください。

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

タスク設定を保存し、事前チェックを実行します。
- 関連するAPI操作を呼び出してDTSタスクを設定するときに指定するパラメーターを表示するには、ポインターを 次：タスク設定の保存と事前チェック に移動し、OpenAPI パラメーターのプレビュー をクリックします。
- パラメーターを表示または表示する必要がない場合は、ページ下部の 次：タスク設定の保存と事前チェック をクリックします。
説明
- データ同期タスクを開始する前に、DTSは事前チェックを実行します。データ同期タスクは、タスクが事前チェックに合格した後にのみ開始できます。
- データ同期タスクが事前チェックに失敗した場合は、失敗した各項目の横にある [詳細の表示] をクリックします。チェック結果に基づいて原因を分析した後、問題のトラブルシューティングを行います。次に、プレチェックを再実行します。
- 事前チェック中にアイテムに対してアラートがトリガーされた場合:
  アラートアイテムを無視できない場合は、失敗したアイテムの横にある [詳細の表示] をクリックして、問題のトラブルシューティングを行います。次に、もう一度プレチェックを実行します。
  アラート項目を無視できる場合は、[アラート詳細の確認] をクリックします。 [詳細の表示] ダイアログボックスで、[無視] をクリックします。表示されたメッセージボックスで、[OK] をクリックします。次に、[再度事前チェック] をクリックして、事前チェックを再度実行します。アラート項目を無視すると、データの不整合が発生し、ビジネスが潜在的なリスクにさらされる可能性があります。
成功率が100% になるまで待ちます。次に、[次へ: インスタンスの購入] をクリックします。

データ同期インスタンスを購入します。

購入ページで、データ同期インスタンスの課金方法とインスタンスクラスのパラメーターを設定します。下表にパラメーターを示します。

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

データ伝送サービス (従量課金) サービス規約を読んで選択します。
[購入して開始] をクリックします。表示されるダイアログボックスで、OK をクリックします。
タスクリストでタスクの進行状況を確認できます。