このトピックでは、Data Transmission Service (DTS) を使用して PolarDB for MySQL クラスタ間でデータを同期する方法について説明します。
前提条件
ソースとデスティネーションの PolarDB for MySQL クラスタが作成されていること。詳細については、「カスタム購入」および「サブスクリプション クラスタの購入」をご参照ください。
デスティネーション PolarDB for MySQL クラスタの使用可能なストレージ容量が、ソース PolarDB for MySQL クラスタのデータ総容量よりも大きいこと。
制限事項
スキーマ同期中、DTS はソースデータベースからデスティネーションデータベースに外部キーを同期します。
完全データ同期および増分データ同期中、DTS はセッションレベルで外部キーに対する制約チェックとカスケード操作を一時的に無効にします。データ同期中にソースデータベースでカスケード更新および削除操作を実行すると、データの不整合が発生する可能性があります。
カテゴリ | 説明 |
ソースデータベースの制限 |
|
その他の制限 |
|
特殊なケース | PolarDB for MySQL クラスタ間の双方向データ同期
|
課金
| 同期タイプ | タスク構成料金 |
| スキーマ同期と完全データ同期 | 無料。 |
| 増分データ同期 | 有料。詳細については、「課金の概要」をご参照ください。 |
同期可能な SQL 操作
操作タイプ | SQL 文 |
DML | INSERT、UPDATE、および DELETE |
DDL |
|
手順
[データ同期タスク] ページに移動します。
Data Management (DMS) コンソール にログインします。
上部のナビゲーションバーで、[データ + AI] をクリックします。
左側のナビゲーションウィンドウで、 を選択します。
説明操作は、DMS コンソールのモードとレイアウトによって異なる場合があります。詳細については、「シンプルモード」および「DMS コンソールのレイアウトとスタイルをカスタマイズする」をご参照ください。
新しい DTS コンソールのデータ同期タスクページ に移動することもできます。
[データ同期タスク] の右側で、データ同期インスタンスが存在するリージョンを選択します。
説明新しい DTS コンソールを使用する場合は、上部のナビゲーションバーでデータ同期インスタンスが存在するリージョンを選択する必要があります。
[タスクの作成] をクリックします。[タスクの作成] ウィザードページで、ソースデータベースとデスティネーションデータベースを構成します。
警告ソースデータベースとデスティネーションデータベースを構成した後、ページに表示される [制限事項] を読んでおくことをお勧めします。そうでない場合、タスクが失敗したり、データの不整合が発生したりする可能性があります。
セクション
パラメータ
説明
該当なし
タスク名
DTS タスクの名前。DTS は自動的にタスク名を生成します。タスクを識別しやすい説明的な名前を指定することをお勧めします。一意のタスク名を指定する必要はありません。
ソースデータベース
既存のDMSデータベースインスタンスの選択
使用するデータベース。ビジネス要件に基づいて既存のデータベースを使用するかどうかを選択できます。
既存のデータベースを選択すると、DTS はデータベースのパラメータを自動的に入力します。
既存のデータベースを選択しない場合は、次のデータベース情報を構成する必要があります。
データベースタイプ
ソースデータベースのタイプ。PolarDB for MySQL を選択します。
アクセス方法
ソースデータベースのアクセス方法。[Alibaba Cloud インスタンス] を選択します。
インスタンスリージョン
ソース PolarDB for MySQL クラスタが存在するリージョン。
Alibaba Cloud アカウント間でデータを複製
Alibaba Cloud アカウント間でデータを同期するかどうかを指定します。この例では、× が選択されています。
PolarDB クラスター ID
ソース PolarDB for MySQL クラスタの ID。
説明ソースとデスティネーションの PolarDB for MySQL クラスタは、同じでも異なっていてもかまいません。DTS を使用して、2 つの PolarDB for MySQL クラスタ間または 1 つの PolarDB for MySQL クラスタ内でデータを同期できます。
データベースアカウント
ソース PolarDB for MySQL クラスタのデータベースアカウント。アカウントには、同期対象のオブジェクトに対する読み取り権限が必要です。
データベースパスワード
データベースへのアクセスに使用するパスワード。
暗号化
ソース PolarDB for MySQL クラスタへの接続を暗号化するかどうかを指定します。ビジネス要件に基づいてこのパラメータを設定できます。SSL 暗号化機能の詳細については、「SSL 暗号化を構成する」をご参照ください。
宛先データベース
既存のDMSデータベースインスタンスの選択
使用するデータベース。ビジネス要件に基づいて既存のデータベースを使用するかどうかを選択できます。
既存のデータベースを選択すると、DTS はデータベースのパラメータを自動的に入力します。
既存のデータベースを選択しない場合は、次のデータベース情報を構成する必要があります。
データベースタイプ
デスティネーションデータベースのタイプ。PolarDB for MySQL を選択します。
アクセス方法
デスティネーションデータベースのアクセス方法。[Alibaba Cloud インスタンス] を選択します。
インスタンスリージョン
デスティネーション PolarDB for MySQL クラスタが存在するリージョン。
PolarDB クラスター ID
デスティネーション PolarDB for MySQL クラスタの ID。
データベースアカウント
デスティネーション PolarDB for MySQL クラスタのデータベースアカウント。アカウントには、デスティネーションデータベースに対する読み取り権限が必要です。
重要特権アカウントを使用することをお勧めします。
データベースパスワード
データベースへのアクセスに使用するパスワード。
暗号化
デスティネーション PolarDB for MySQL クラスタへの接続を暗号化するかどうかを指定します。ビジネス要件に基づいてこのパラメータを設定できます。SSL 暗号化機能の詳細については、「SSL 暗号化を構成する」をご参照ください。
[接続テストと続行] をクリックします。
ソースデータベースまたはデスティネーションデータベースが ApsaraDB RDS for MySQL インスタンスや ApsaraDB for MongoDB インスタンスなどの Alibaba Cloud データベースインスタンスの場合、DTS は DTS サーバーの CIDR ブロックをインスタンスのホワイトリストに自動的に追加します。ソースデータベースまたはデスティネーションデータベースが Elastic Compute Service (ECS) インスタンスでホストされている自己管理データベースの場合、DTS は DTS サーバーの CIDR ブロックを ECS インスタンスのセキュリティグループルールに自動的に追加します。ECS インスタンスがデータベースにアクセスできることを確認する必要があります。データベースが複数の ECS インスタンスにデプロイされている場合は、DTS サーバーの CIDR ブロックを各 ECS インスタンスのセキュリティグループルールに手動で追加する必要があります。ソースデータベースまたはデスティネーションデータベースがデータセンターにデプロイされているか、サードパーティのクラウド サービス プロバイダー (CSP) によって提供されている自己管理データベースの場合は、DTS サーバーの CIDR ブロックをデータベースのホワイトリストに手動で追加して、DTS がデータベースにアクセスできるようにする必要があります。詳細については、「DTS サーバーの CIDR ブロックを追加する」トピックの「DTS サーバーの CIDR ブロック」セクションをご参照ください。
警告DTS サーバーの CIDR ブロックがデータベースまたはインスタンスのホワイトリスト、または ECS セキュリティグループルールに自動または手動で追加されると、セキュリティリスクが発生する可能性があります。したがって、DTS を使用してデータを同期する前に、潜在的なリスクを理解し、認識し、次の対策を含むがこれらに限定されない予防措置を講じる必要があります。ユーザー名とパスワードのセキュリティを強化する、公開するポートを制限する、API 呼び出しを認証する、ホワイトリストまたは ECS セキュリティグループルールを定期的にチェックし、許可されていない CIDR ブロックを禁止する、または Express Connect、VPN Gateway、Smart Access Gateway を使用してデータベースを DTS に接続する。
同期対象のオブジェクトと詳細設定を構成します。
パラメータ
説明
同期タイプ
同期タイプ。デフォルトでは、[増分データ同期] が選択されています。[スキーマ同期] と [完全データ同期] も選択する必要があります。事前チェックが完了すると、DTS は選択したオブジェクトの既存データをソースデータベースからデスティネーション クラスタに同期します。既存データは、後続の増分同期の基礎となります。
移行元データベースのトリガーを移行する方法
ソースデータベースからトリガーを同期するために使用する方法。ビジネス要件に基づいて同期方法を選択できます。同期するトリガーがない場合は、このパラメータを設定する必要はありません。詳細については、「ソースデータベースからトリガーを同期または移行する」をご参照ください。
説明同期タイプ として スキーマ同期 を選択した場合にのみ、このパラメータが表示されます。
同期トポロジ
データ同期タスクの同期トポロジ。この例では、一方向同期 が選択されています。
競合するテーブルの処理モード
エラーの事前チェックと報告：デスティネーションデータベースにソースデータベースのテーブルと同じ名前のテーブルが含まれているかどうかをチェックします。ソースデータベースとデスティネーションデータベースに同じテーブル名のテーブルが含まれていない場合、事前チェックは合格です。それ以外の場合、事前チェック中にエラーが返され、データ同期タスクを開始できません。
説明ソースデータベースとデスティネーションデータベースに同じ名前のテーブルが含まれており、デスティネーションデータベースのテーブルを削除または名前変更できない場合は、オブジェクト名マッピング機能を使用して、デスティネーションデータベースに同期されるテーブルの名前を変更できます。詳細については、「オブジェクト名をマッピングする」をご参照ください。
エラーを無視して続行：ソースデータベースとデスティネーションデータベースの同じテーブル名の事前チェックをスキップします。
警告エラーを無視して続行 を選択すると、データの不整合が発生し、ビジネスが潜在的なリスクにさらされる可能性があります。
ソースデータベースとデスティネーションデータベースのスキーマが同じで、デスティネーションデータベースのデータレコードのプライマリキー値または一意キー値がソースデータベースのデータレコードと同じである場合：
完全データ同期中、DTS はデータレコードをデスティネーションデータベースに同期しません。デスティネーションデータベースの既存のデータレコードは保持されます。
増分データ同期中、DTS はデータレコードをデスティネーションデータベースに同期します。デスティネーションデータベースの既存のデータレコードは上書きされます。
ソースデータベースとデスティネーションデータベースのスキーマが異なる場合、データの初期化に失敗する可能性があります。この場合、一部の列のみが同期されるか、データ同期インスタンスが失敗します。注意して進めてください。
ソースオブジェクト
ソースオブジェクト セクションから 1 つ以上のオブジェクトを選択し、
アイコンをクリックして、選択中のオブジェクト セクションにオブジェクトを追加します。説明列、テーブル、またはデータベースを同期対象のオブジェクトとして選択できます。テーブルまたは列を同期対象のオブジェクトとして選択した場合、DTS はビュー、トリガー、ストアドプロシージャなどの他のオブジェクトをデスティネーションデータベースに同期しません。
[選択済みオブジェクト]
デスティネーションインスタンスに同期するオブジェクトの名前を変更するには、選択中のオブジェクト セクションでオブジェクトを右クリックします。詳細については、「オブジェクト名をマッピングする」トピックの「単一オブジェクトの名前をマッピングする」セクションをご参照ください。
複数のオブジェクトの名前を一度に変更するには、選択中のオブジェクト セクションの右上隅にある 一括編集 をクリックします。詳細については、「オブジェクト名をマッピングする」トピックの「一度に複数のオブジェクト名をマッピングする」セクションをご参照ください。
説明特定のデータベースまたはテーブルで実行される SQL 操作を選択するには、[選択済みオブジェクト] セクションでオブジェクトを右クリックします。表示されるダイアログボックスで、同期する SQL 操作を選択します。詳細については、このトピックの「同期可能な SQL 操作」セクションをご参照ください。
データをフィルタリングするための WHERE 条件を指定するには、[選択済みオブジェクト] セクションでテーブルを右クリックします。表示されるダイアログボックスで、条件を指定します。詳細については、「フィルタ条件を指定する」をご参照ください。
[次へ：詳細設定] をクリックして詳細設定を構成します。
データ検証設定
データ検証機能の使用方法の詳細については、「データ検証タスクを構成する」をご参照ください。
詳細設定
パラメータ
説明
タスクのスケジュールに使用する専用クラスターの選択
デフォルトでは、専用クラスタを指定しない場合、DTS は共有クラスタにタスクをスケジュールします。データ同期インスタンスの安定性を向上させるには、専用クラスタを購入します。詳細については、「DTS 専用クラスタとは」をご参照ください。
アラートの設定
データ同期インスタンスのアラートを構成するかどうかを指定します。タスクが失敗した場合、または同期遅延が指定されたしきい値を超えた場合、アラート連絡先に通知が送信されます。有効な値：
[いいえ]：アラートを有効にしません。
[はい]：アラートを構成します。この場合、アラートのしきい値と アラート通知設定 も構成する必要があります。詳細については、「モニタリングとアラートを構成する」トピックの「DTS タスクを作成するときにモニタリングとアラートを構成する」セクションをご参照ください。
移行先データベースのエンジンタイプを選択します。
デスティネーション PolarDB for MySQL クラスタのエンジンタイプ。有効な値：
[InnoDB]：デフォルトストレージエンジン。
[X-Engine]：オンライントランザクション処理 (OLTP) データベース ストレージエンジン。
移行元テーブルで生成された Online DDL ツールの一時テーブルを移行先データベースにコピーします。
DMS または gh-ost ツールを使用してソースデータベースでオンライン DDL 操作を実行する場合、オンライン DDL 操作によって生成された一時テーブルのデータを同期するかどうかを指定できます。
重要pt-online-schema-change などのツールを使用してソースデータベースでオンライン DDL 操作を実行することはできません。実行すると、DTS タスクが失敗します。
[はい]：DTS は、オンライン DDL 操作によって生成された一時テーブルのデータを同期します。
説明オンライン DDL 操作によって大量のデータが生成される場合、データ同期タスクの完了に時間がかかることがあります。
[いいえ、DMS オンライン DDL に適応]：DTS は、オンライン DDL 操作によって生成された一時テーブルのデータを同期しません。DMS を使用して実行される元の DDL 操作のみが同期されます。
説明このオプションを選択すると、デスティネーションデータベースのテーブルがロックされる場合があります。
[いいえ、gh-ost に適応]：DTS は、オンライン DDL 操作によって生成された一時テーブルのデータを同期しません。gh-ost ツールを使用して実行される元の DDL 操作のみが同期されます。デフォルトまたはカスタムの正規表現を使用して、gh-ost ツールのシャドウテーブルと不要なテーブルを除外できます。
説明このオプションを選択すると、デスティネーションデータベースのテーブルがロックされる場合があります。
失敗した接続の再試行時間
接続失敗時のリトライ時間の範囲。データ同期タスクの開始後にソースデータベースまたはデスティネーションデータベースへの接続に失敗した場合、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 とは」をご参照ください。有効な値：
[はい]：ETL 機能を構成します。コードエディタにデータ処理文を入力できます。詳細については、「データ移行またはデータ同期タスクで ETL を構成する」をご参照ください。
[いいえ]：ETL 機能を構成しません。
順方向および逆方向タスクのハートビートテーブル sql を削除
DTS インスタンスの実行中に、ハートビートテーブルに対する SQL 操作をソースデータベースに書き込むかどうかを指定します。
[はい]：ハートビートテーブルに対する SQL 操作を書き込みません。この場合、DTS インスタンスの遅延が表示されることがあります。
[いいえ]：ハートビートテーブルに対する SQL 操作を書き込みます。この場合、ソースデータベースの物理バックアップやクローニングなどの特定の機能が影響を受ける可能性があります。
タスク設定を保存し、事前チェックを実行します。
DTS タスクを構成するために関連 API 操作を呼び出すときに指定するパラメータを表示するには、次：タスク設定の保存と事前チェック にポインタを置き、OpenAPI パラメーターのプレビュー をクリックします。
パラメータを表示する必要がない場合、または既に表示している場合は、ページの下部にある 次：タスク設定の保存と事前チェック をクリックします。
説明データ同期タスクを開始する前に、DTS は事前チェックを実行します。タスクが事前チェックに合格した後でのみ、データ同期タスクを開始できます。
データ同期タスクが事前チェックに失敗した場合は、失敗した各項目の横にある [詳細の表示] をクリックします。チェック結果に基づいて原因を分析した後、問題をトラブルシューティングします。その後、事前チェックを再実行します。
事前チェック中に項目のアラートがトリガーされた場合：
アラート項目を無視できない場合は、失敗した項目の横にある [詳細の表示] をクリックして、問題をトラブルシューティングします。その後、事前チェックを再実行します。
アラート項目を無視できる場合は、[アラート詳細の確認] をクリックします。[詳細の表示] ダイアログボックスで、[無視] をクリックします。表示されるメッセージで、[OK] をクリックします。その後、[再事前チェック] をクリックして、事前チェックを再実行します。アラート項目を無視すると、データの不整合が発生し、ビジネスが潜在的なリスクにさらされる可能性があります。
[成功率] が [100%] になるまで待ちます。その後、[次へ：インスタンスの購入] をクリックします。
[購入] ページで、データ同期タスクの [課金方法] パラメータと [インスタンスクラス] パラメータを構成します。次の表にパラメータを示します。
セクション
パラメータ
説明
新しいインスタンスクラス
課金方法
サブスクリプション：データ同期インスタンスを作成するときにサブスクリプションの料金を支払います。サブスクリプション課金方法は、長期使用の場合、従量課金方法よりも費用対効果が高くなります。
従量課金：従量課金インスタンスは 1 時間単位で課金されます。従量課金方法は、短期使用に適しています。従量課金データ同期インスタンスが不要になった場合は、インスタンスを解放してコストを削減できます。
リソースグループ設定
データ同期インスタンスが属するリソースグループ。デフォルト値：[デフォルトのリソースグループ]。詳細については、「リソース管理とは」をご参照ください。
インスタンスクラス
DTS は、同期速度が異なるインスタンスクラスを提供します。ビジネス要件に基づいてインスタンスクラスを選択できます。詳細については、「データ同期インスタンスのインスタンスクラス」をご参照ください。
サブスクリプション期間
サブスクリプション課金方法を選択した場合は、サブスクリプション期間と作成するデータ同期インスタンスの数を指定します。 サブスクリプション期間は、1～9 か月、1 年、2 年、3 年、または 5 年です。
説明このパラメーターは、サブスクリプション 課金方法を選択した場合にのみ使用できます。
データ伝送サービス（従量課金制）サービス規約を読み、[データ伝送サービス (従量課金制) サービス規約] を選択します。
[購入して開始] をクリックします。表示されるダイアログボックスで、OK をクリックします。
タスクリストでタスクの進捗状況を確認できます。