Data Transmission Service:RDS for MySQL と PolarDB for MySQL 間の双方向同期

サポートされるソースデータベース

以下の MySQL データベースタイプは、PolarDB for MySQL クラスターとの双方向同期をサポートしています。本トピックでは、ApsaraDB RDS for MySQL インスタンスを例として説明します。他のソースデータベースタイプの場合も手順は同様です。

• ApsaraDB RDS for MySQL インスタンス

• Elastic Compute Service (ECS) 上でホストされている自己管理データベース

• Express Connect、VPN Gateway、または Smart Access Gateway 経由で接続された自己管理データベース

• Database Gateway 経由で接続された自己管理データベース

• Cloud Enterprise Network (CEN) 経由で接続された自己管理データベース

前提条件

• ターゲットとなる PolarDB for MySQL クラスターが作成済みであること。カスタム購入 | サブスクリプションクラスターの購入。

• ソースとなる ApsaraDB RDS for MySQL インスタンスとターゲットとなる PolarDB for MySQL クラスターのストレージ容量が同一であること。

注意事項

課金

競合検出

データ整合性を確保するため、双方向同期中のデータベースインスタンスのいずれか一方でのみ、同じプライマリキー、ビジネスプライマリキー、または一意キーを持つデータレコードを更新してください。両方のデータベースインスタンスでデータレコードが更新された場合、DTS システムはタスクで設定された競合解決ポリシーを適用します。

サポートされる同期トポロジ

DTS は、ApsaraDB RDS for MySQL インスタンスと PolarDB for MySQL クラスター間の双方向同期をサポートしています。

利用可能なトポロジおよび使用上の注意事項については、「同期トポロジ」をご参照ください。

サポートされる SQL

データベースアカウント権限

操作手順

1. ターゲットリージョンの同期タスクリストページに移動します。以下の 2 つの方法のいずれかを使用できます。

   DTS コンソールから

   1. Data Transmission Service (DTS) コンソールにログインします。

   2. 左側のナビゲーションウィンドウで、データ同期 をクリックします。

   3. ページ左上隅で、同期インスタンスが配置されているリージョンを選択します。

   DMS コンソールから

   説明

   実際の操作は、DMS コンソールのモードおよびレイアウトによって異なる場合があります。詳細については、「シンプルモード」および「DMS インターフェイスのレイアウトおよびスタイルのカスタマイズ」をご参照ください。

   1. Data Management (DMS) にログインします。

   2. 上部メニューバーで、Data + AI > Data Transmission (DTS) > データ同期 を選択します。

   3. データ同期タスク の右側で、同期インスタンスが配置されているリージョンを選択します。

2. タスクの作成 をクリックして、タスク設定ページを開きます。

3. ソースおよびターゲットデータベースを設定します。

   警告

   ソースおよびターゲットインスタンスを選択した後、ページ上部に表示される制限事項をよくお読みください。制限事項に従わないと、タスクが失敗したり、データの不整合が発生したりする可能性があります。

   カテゴリ	パラメーター	説明
   該当なし	タスク名	DTS が自動的にタスク名を生成します。識別しやすいように、わかりやすい名前を指定することを推奨します。名前は一意である必要はありません。
   移行元データベース	既存の接続情報の選択	システムに追加済み（新規作成または保存済み）のデータベースインスタンスを使用する場合は、ドロップダウンリストからデータベースインスタンスを選択します。データベース情報が自動的に設定されます。 説明 DMS コンソールでは、この設定項目の名前は DMS データベースインスタンスの選択 です。 データベースインスタンスをシステムに追加していない場合、またはすでに追加済みのインスタンスを使用しない場合は、以下のデータベース情報を手動で設定してください。
   	データベースタイプ	MySQL を選択します。
   	アクセス方法	Alibaba Cloud インスタンス を選択します。
   	インスタンスのリージョン	ソース ApsaraDB RDS for MySQL インスタンスが配置されているリージョンを選択します。
   	Alibaba Cloud アカウント間でデータを複製	この例では、現在の Alibaba Cloud アカウントに属するデータベースインスタンスを使用します。× を選択します。
   	RDS インスタンス ID	ソース ApsaraDB RDS for MySQL インスタンスの ID を選択します。
   	データベースアカウント	ソース ApsaraDB RDS for MySQL インスタンスのデータベースアカウントを入力します。必要な権限は、「データベースアカウントに必要な権限」に記載されています。
   	データベースのパスワード	データベースアカウントに対応するパスワードを入力します。
   	暗号化	必要に応じて、非暗号化 または SSL 暗号化 を選択します。SSL 暗号化 を選択する場合は、事前に RDS for MySQL インスタンスで SSL 暗号化を有効化しておく必要があります。詳細については、「クラウド証明書を使用した SSL 暗号化の迅速な有効化」をご参照ください。
   移行先データベース	既存の接続情報の選択	システムに追加済み（新規作成または保存済み）のデータベースインスタンスを使用する場合は、ドロップダウンリストからデータベースインスタンスを選択します。データベース情報が自動的に設定されます。 説明 DMS コンソールでは、この設定項目の名前は DMS データベースインスタンスの選択 です。 データベースインスタンスをシステムに追加していない場合、またはすでに追加済みのインスタンスを使用しない場合は、以下のデータベース情報を手動で設定してください。
   	データベースタイプ	PolarDB for MySQL を選択します。
   	アクセス方法	Alibaba Cloud インスタンス を選択します。
   	インスタンスのリージョン	ターゲット PolarDB for MySQL クラスターが配置されているリージョンを選択します。
   	Alibaba Cloud アカウント間でデータを複製	この例では、現在の Alibaba Cloud アカウントに属するデータベースインスタンスを使用します。× を選択します。
   	PolarDB クラスター ID	ターゲット PolarDB for MySQL クラスターの ID を選択します。
   	データベースアカウント	ターゲット PolarDB for MySQL クラスターのデータベースアカウントを入力します。必要な権限は、「データベースアカウントに必要な権限」に記載されています。
   	データベースのパスワード	データベースアカウントに対応するパスワードを入力します。
   	暗号化	ビジネス要件に基づいてオプションを選択してください。SSL 暗号化の詳細については、「SSL 暗号化の設定」をご参照ください。

4. 設定が完了したら、ページ下部の 接続をテストして続行 をクリックします。

   説明

   • DTS サーバーからのアクセスを許可するために、ソースおよびターゲットデータベースのセキュリティ設定に DTS サーバーの IP アドレス CIDR ブロックを追加してください。これは自動または手動で行えます。詳細については、「DTS サーバーの IP アドレス CIDR ブロックをホワイトリストに追加」をご参照ください。

   • ソースまたはターゲットデータベースが自己管理データベース（アクセス方法 が Alibaba Cloud インスタンス ではない）の場合、DTS サーバーの CIDR ブロック ダイアログボックスで 接続テスト をクリックする必要があります。

5. タスクオブジェクトを設定します。

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

      パラメーター	説明
      同期タイプ	増分データ同期 が選択されています。デフォルトでは、スキーマ同期 および 完全データ同期 も選択する必要があります。事前チェックが完了すると、DTS は選択したオブジェクトの完全データ同期をソースインスタンスからターゲットクラスターに実行します。これにより、その後の増分データ同期のベースラインデータが作成されます。
      移行元データベースのトリガーを移行する方法	トリガー同期方法を選択します。トリガーが関与しない場合はスキップしてください。「トリガーの同期または移行方法の設定」をご参照ください。 説明 このパラメーターは、同期タイプ で スキーマ同期 が選択されている場合にのみ使用できます。
      同期トポロジ	双方向同期 を選択します。
      DDL 操作を除外	○ を選択すると、DDL 操作を同期しません。 いいえ を選択すると、DDL 操作を同期します。 重要 DDL 同期は方向性があります。転送タスク（ソースからターゲット）でのみ DDL 同期を有効化できます。逆方向タスクでは、DDL 操作が自動的にフィルター処理されます。
      競合解決ポリシー	前述の競合タイプのいずれかが発生した場合、ビジネス要件に基づいて競合解決ポリシーを選択してください。 Taskfailed (競合が発生した場合、エラーが報告されタスクは終了します。) 同期中にデータ競合が発生すると、タスクがエラーを報告して停止します。タスクは「失敗」状態になり、手動での介入が必要です。 Ignore (競合が発生した場合、移行先インスタンスの競合レコードが使用されます。) 同期中にデータ競合が発生すると、現在の同期ステートメントがスキップされ、プロセスが継続します。ターゲットデータベースの競合レコードが保持されます。 Overwrite (競合が発生した場合、移行先インスタンスの競合レコードは上書きされます。) 同期中にデータ競合が発生すると、ターゲットデータベースの競合レコードが上書きされます。 説明 タスクが一時停止、再開、または遅延した場合、これらのポリシーは遅延中には適用されません。DTS はデフォルトでターゲットデータを上書きします。
      競合するテーブルの処理モード	エラーの事前チェックと報告：ターゲットデータベースに同じ名前のテーブルが存在するかどうかをチェックします。同じ名前のテーブルが存在しない場合、事前チェックはパスします。同じ名前のテーブルが存在する場合、事前チェックは失敗し、データ同期タスクは開始されません。 説明 ターゲットデータベースで同じ名前のテーブルを削除または名前変更できない場合は、別のテーブル名にマッピングできます。詳細については、「テーブルおよび列名のマッピング」をご参照ください。 エラーを無視して続行：ターゲットデータベースでの重複テーブル名のチェックをスキップします。 警告 エラーを無視して続行 を選択すると、データの不整合が発生し、ビジネスにリスクが及ぶ可能性があります。たとえば： テーブルスキーマが同一で、ターゲットデータベースのレコードがソースデータベースのレコードと同じプライマリキーまたは一意キー値を持つ場合： 完全同期中は、DTS がターゲットクラスター内のレコードを保持します。ソースデータベースからの対応するレコードは同期されません。 増分同期中は、ソースデータベースからのレコードがターゲットデータベースのレコードを上書きします。 テーブルスキーマが異なる場合、初期データ同期が失敗する可能性があります。これにより、一部の列データのみが同期されるか、完全な同期失敗が発生する可能性があります。慎重に操作してください。
      イベントを移行するかどうか	必要に応じて、ソースデータベースからイベントを同期するかどうかを指定します。○ を選択する場合は、関連要件を満たし、後続の操作を実行する必要があります。詳細については、「イベントの同期または移行」をご参照ください。
      移行先インスタンスでのオブジェクト名の大文字化	ターゲットインスタンスに同期されるデータベース、テーブル、列オブジェクト名の大文字小文字の感度ポリシーを設定できます。デフォルトでは、DTS のデフォルトポリシー が選択されています。ソースおよびターゲットデータベースのデフォルトポリシーを使用することもできます。詳細については、「ターゲットオブジェクト名の大文字小文字の感度ポリシー」をご参照ください。
      ソースオブジェクト	ソースオブジェクト ボックスで、同期するオブジェクトをクリックし、 をクリックして 選択中のオブジェクト ボックスに移動させます。 説明 同期オブジェクトとしてデータベース、テーブル、列を選択できます。テーブルまたは列を選択した場合、ビュー、トリガー、ストアドプロシージャなどの他のオブジェクトはターゲットデータベースに同期されません。
      選択中のオブジェクト	ターゲットインスタンスで単一の同期オブジェクトの名前を変更するには、選択中のオブジェクト ボックスでオブジェクトを右クリックします。オブジェクトの名前変更の詳細については、「単一のデータベース、テーブル、または列のマッピング」をご参照ください。 ターゲットインスタンスで複数の同期オブジェクトの名前を一括で変更するには、選択中のオブジェクト ボックスの右上隅にある 一括編集 をクリックします。詳細については、「データベース、テーブル、列の一括マッピング」をご参照ください。 説明 データベースまたはテーブルレベルで SQL 操作を選択するには、選択中のオブジェクト ボックスでオブジェクトを右クリックし、ダイアログボックスで操作を選択します。 WHERE 句を使用してデータをフィルターするには、選択中のオブジェクト ボックスでテーブルを右クリックし、フィルター条件を設定します。「フィルター条件の設定」をご参照ください。 オブジェクト名マッピングにより、依存オブジェクトの同期が失敗する可能性があります。

   2. 詳細設定へ をクリックして、詳細パラメーターを設定します。

      パラメーター	説明
      タスクのスケジュールに使用する専用クラスターの選択	デフォルトでは、DTS は共有クラスターでタスクをスケジューリングするため、クラスターを選択する必要はありません。より安定したパフォーマンスを求める場合は、DTS 同期タスクを実行するための専用クラスターを購入できます。詳細については、「DTS 専用クラスターとは」をご参照ください。
      移行先データベースのエンジンタイプを選択します。	ターゲットデータベースのエンジンタイプを選択します。 InnoDB：デフォルトのストレージエンジンです。 X-Engine：オンライントランザクション処理 (OLTP) データベース向けのストレージエンジンです。
      移行元テーブルで生成された Online DDL ツールの一時テーブルを移行先データベースにコピーします。	ソースデータベースで Data Management (DMS) または gh-ost を使用してオンライン DDL 変更を実行する場合、オンライン DDL 変更によって生成された一時テーブルのデータを同期するかどうかを選択できます。 重要 DTS タスクは、pt-online-schema-change などのツールを使用したオンライン DDL 変更をサポートしていません。このようなツールを使用すると、DTS タスクが失敗します。 各ステージの処理方法は次のとおりです。スキーマ同期 および 完全データ同期 ステージでは、データベースまたはテーブルスキーマを変更する DDL 操作が許可されていないため、これらのステージはオンライン DDL ポリシーの制御を受けません。 スキーマ同期：このステージはオンライン DDL ポリシーの制御を受けません。関連する一時テーブルが作成されます。 完全データ同期：このステージはオンライン DDL ポリシーの制御を受けません。一時テーブルは完全同期オブジェクトに含まれません。正規表現 (^_(.+)_(?:gho|new)$ または ^_(.+)_(?:ghc|del|old)$) に一致するすべてのテーブルがフィルター処理されます。 増分データ同期：このステージはオンライン DDL ポリシーの制御を受けます。 ○：オンライン DDL 操作によって生成された一時テーブル（例：_table-name_gho）のデータ変更を同期します。 いいえ、DMS オンライン DDL に適応 および いいえ、gh-ost に適応：gh-ost などのツールによって生成された一時テーブル（例：_table-name_gho）のデータ変更を、正規表現ルールに基づいてフィルター処理します。 ○：オンライン DDL 変更によって生成された一時テーブルデータを同期します。 説明 オンライン DDL 変更によって生成された一時テーブルデータが大きすぎると、同期遅延が発生する可能性があります。 いいえ、DMS オンライン DDL に適応：オンライン DDL 操作によって生成された一時テーブルからのデータを同期しません。ソースデータベースで Data Management (DMS) を使用して実行された元の DDL ステートメントのみを同期します。 説明 このオプションにより、ターゲットデータベースでテーブルがロックされます。 いいえ、gh-ost に適応：オンライン DDL 変更によって生成された一時テーブルからのデータを同期しません。カスタムフィルタールールをサポートしています。DTS は、gh-ost などのツールによって生成された一時テーブル（例：_table-name_gho）のデータ変更を、正規表現ルールに基づいてフィルター処理します。シャドウテーブルおよび不要なテーブルに一致させるデフォルトの正規表現は、必要に応じて変更できます。 シャドウテーブル：^_(.+)_(?:gho|new)$ 不要なテーブル：^_(.+)_(?:ghc|del|old)$ 説明 このオプションにより、ターゲットデータベースでテーブルがロックされます。
      アカウントを移行	ソースデータベースからアカウント情報を同期するかどうかを選択します。○ を選択する場合は、アカウントを選択して権限を確認してください。認可方法は、「データベースアカウントの移行」に記載されています。
      失敗した接続の再試行時間	同期タスク開始後、ソースまたはターゲットデータベースへの接続が失敗した場合、DTS はエラーを報告し、直ちに接続の再試行を開始します。デフォルトの再試行時間は 720 分です。10 ～ 1,440 分の範囲でカスタム再試行時間を指定することもできます。30 分以上に設定することを推奨します。指定された時間内に DTS がデータベースへの再接続に成功した場合、同期タスクは自動的に再開されます。それ以外の場合は、タスクが失敗します。 説明 同じソースまたはターゲットを共有する複数の DTS インスタンス（例：インスタンス A およびインスタンス B）があり、インスタンス A のネットワーク再試行時間を 30 分、インスタンス B を 60 分に設定した場合、両方に短い方の 30 分が適用されます。 DTS は接続再試行期間中もタスクランタイムに対して課金するため、ビジネスニーズに基づいて再試行時間をカスタマイズするか、ソースおよびターゲットデータベースインスタンスをリリースした後はできるだけ早く DTS インスタンスをリリースすることを推奨します。
      移行元データベースと移行先データベースで他の問題が発生した場合の、再試行までの待機時間です。	同期タスク開始後、ソースまたはターゲットデータベースで接続以外の問題（DDL または DML 実行例外など）が発生した場合、DTS はエラーを報告し、直ちに継続的な再試行操作を開始します。デフォルトの再試行時間は 10 分です。1 ～ 1,440 分の範囲でカスタム再試行時間を指定することもできます。10 分以上に設定することを推奨します。設定された再試行時間内に関連操作が成功した場合、同期タスクは自動的に再開されます。それ以外の場合は、タスクが失敗します。 重要 移行元データベースと移行先データベースで他の問題が発生した場合の、再試行までの待機時間です。 の値は、失敗した接続の再試行時間 の値より小さくする必要があります。
      完全同期レートを制限するかどうか	完全同期ステージ中、DTS はソースおよびターゲットデータベースの読み取りおよび書き込みリソースを消費するため、データベース負荷が増加します。ソースおよびターゲットデータベースの負荷を軽減するには、1 秒あたりのソースデータベースのクエリ率 QPS、1 秒あたりの完全移行の行数 RPS、および 1 秒あたりの完全移行データ量 (MB) BPS パラメーターを設定して、完全同期タスクのレート制限を設定できます。 説明 この設定項目は、同期タイプ が 完全データ同期 に設定されている場合にのみ使用できます。 同期インスタンス実行後も、完全同期レートを調整 できます。
      増分同期率を制限するかどうか	増分同期タスクのレート制限も設定できます。ターゲットデータベースの負荷を軽減するには、1 秒あたりの増分同期の行数 RPS および 1 秒あたりの増分同期データ量 (MB) BPS を設定してください。
      環境タグ	インスタンスを識別するために環境タグを選択します。この例では任意です。
      順方向および逆方向タスクのハートビートテーブル SQL を削除	DTS インスタンス実行中に、ハートビート SQL 情報をソースデータベースに書き込むかどうかを選択します。 ○：ハートビート SQL 情報をソースデータベースに書き込みません。これにより、DTS インスタンスが遅延を報告する可能性があります。 ×：ハートビート SQL 情報をソースデータベースに書き込みます。これにより、ソースデータベースの物理バックアップやクローンなどの機能に干渉する可能性があります。
      ETL 機能の設定	抽出・変換・書き出し (ETL) 機能を有効化するかどうかを選択します。詳細については、「ETL とは」をご参照ください。有効値： ○：ETL 機能を有効化します。コードエディタでデータ処理ステートメントを入力してください。詳細については、「データ移行またはデータ同期タスクでの ETL の設定」をご参照ください。 ×：ETL 機能を無効化します。
      監視アラート	アラートを設定するかどうかを指定します。同期が失敗した場合や、遅延が指定されたしきい値を超えた場合、アラート連絡先に通知が送信されます。 ×：アラートは設定されません。 ○：アラートのしきい値を設定し、アラート通知を指定してアラートを設定します。詳細については、「タスク設定時のモニタリングとアラートの設定」をご参照ください。

   3. 次へ：データ検証 をクリックして、データ検証タスクを設定します。

      データ検証機能を使用する場合は、「データ検証の設定」をご参照ください。

6. タスクを保存して事前チェックを実行します。

   • このインスタンスを設定するための API パラメーターを表示するには、次：タスク設定の保存と事前チェック ボタンにカーソルを合わせ、バルーン内の OpenAPI パラメーターのプレビュー をクリックします。

   • API パラメーターの確認が完了したら、ページ下部の 次：タスク設定の保存と事前チェック をクリックします。

   説明

   • 同期ジョブ開始前に、DTS が事前チェックを実行します。すべての事前チェック項目が合格した場合にのみ、ジョブを開始できます。

   • 事前チェックが失敗した場合は、失敗した項目の横にある 詳細を表示 をクリックします。指示に従って問題を修正し、再度事前チェックを実行してください。

   • 事前チェックで警告が返された場合：

     • チェック項目が失敗し、無視できない場合は、項目の横にある 詳細を表示 をクリックします。指示に従って問題を修正し、再度事前チェックを実行してください。

     • 無視可能なチェック項目の場合は、アラートの詳細を確認、無視、OK、再度事前チェックを実行 の順にクリックして、警告をスキップして事前チェックを再実行できます。警告項目をマスクすることを選択した場合、データの不整合などの問題が発生し、ビジネスにリスクが及ぶ可能性があります。

7. インスタンスを購入します。

   1. [成功率] が 100 % になったら、次：インスタンスの購入 をクリックします。

   2. 購入 ページで、データ同期インスタンスの課金方法およびリンク仕様を選択します。以下の表に、これらのパラメーターの詳細を示します。

      カテゴリ	パラメーター	説明
      新しいインスタンスクラス	課金方法	サブスクリプション：インスタンス作成時に支払いを行います。長期的なニーズに適しており、従量課金よりもコスト効率が高くなります。サブスクリプション期間が長いほど、割引率が高くなります。 従量課金：1 時間単位で課金されます。短期的なニーズに適しています。使用後すぐにインスタンスをリリースすることで、コストを節約できます。
      	リソースグループ構成	インスタンスが属するリソースグループです。デフォルトはデフォルトリソースグループです。詳細については、「Resource Management とは」をご参照ください。
      	リンク仕様	DTS は、さまざまなパフォーマンスレベルを持つ同期仕様を提供しています。同期リンク仕様は同期レートに影響します。ビジネスシナリオに基づいて仕様を選択できます。詳細については、「データ同期リンク仕様」をご参照ください。
      	サブスクリプション期間	サブスクリプションモードでは、サブスクリプションインスタンスの期間および数量を選択します。1 ～ 9 ヶ月の月額サブスクリプション、または 1 年、2 年、3 年、5 年の年額サブスクリプションを選択できます。 説明 このオプションは、課金方法が サブスクリプション の場合にのみ使用できます。

   3. 設定が完了したら、Data Transmission Service (従量課金) 利用規約 を読み、選択します。

   4. 購入して起動 をクリックします。OK ダイアログボックスで、OK をクリックします。

      データ同期ページでタスクの進行状況を確認できます。

8. 逆方向同期タスクを設定します。

   1. 転送同期タスクの初期化が完了し、[ステータス] が [実行中] に変わることを待ちます。

   2. 逆方向同期タスクを見つけ、タスクの設定 をクリックします。

   3. 手順 3 から 手順 6 に従って、逆方向同期タスクを設定します。

      重要

      • 逆方向タスクのソースおよびターゲットインスタンスを正しく選択してください。ソースは転送タスクのターゲットであり、その逆も同様です。データベース名、アカウント、パスワードが一致していることを確認してください。

      • 逆方向タスクでは、ソースおよびターゲットデータベースの インスタンスのリージョン を変更できません。このタスクではパラメーターが少なくなります。コンソールの指示に従ってください。

      • 逆方向タスクの 競合するテーブルの処理モード を設定する際、転送タスクで同期されたテーブルにはチェックが適用されません。

      • 逆方向同期タスクは、DDL 操作を自動的にフィルター処理します。

      • 逆方向タスクは、転送タスクの 選択中のオブジェクト に含まれるオブジェクトを同期できません。

      • データの不整合を防ぐため、逆方向タスクでオブジェクト名マッピングを使用しないでください。

   4. [成功率] が 100% に達したら、戻る をクリックします。

9. 逆方向タスクの設定後、両方のタスクの [ステータス] が [実行中] になるまで待ちます。これで双方向同期の設定が完了します。