データ伝送サービス (DTS) を使用して、MySQL から PolarDB for MySQL クラスタにデータを同期できます。
サポートされているソースデータベース
PolarDB for MySQL クラスタにデータを同期する場合、以下の種類の MySQL データベースがソースデータベースとしてサポートされています。このトピックでは、ApsaraDB RDS for MySQL インスタンスを例として使用して、データ同期タスクを構成する方法について説明します。また、この手順に従って、他の種類の MySQL データベースのデータ同期タスクを構成することもできます。
- ApsaraDB RDS for MySQL インスタンス
- Elastic Compute Service (ECS) でホストされている自己管理型データベース
- Express Connect、VPN Gateway、または Smart Access Gateway 経由で接続されている自己管理型データベース
- Database Gateway 経由で接続されている自己管理型データベース
- Cloud Enterprise Network (CEN) 経由で接続されている自己管理型データベース
前提条件
ApsaraDB RDS for MySQL インスタンスが作成されている。
PolarDB for MySQL クラスタが作成されている。詳細については、「クラスタを購入する」および「サブスクリプションクラスタを購入する」をご参照ください。
PolarDB for MySQL クラスタのストレージ容量が、ApsaraDB RDS for MySQL インスタンスで使用されているストレージ容量よりも大きい。
制限事項
スキーマ同期の際、DTS はソースデータベースから宛先データベースに外部キーを同期します。
完全データ同期および増分データ同期の際、DTS はセッションレベルで外部キーに対する制約チェックとカスケード操作を一時的に無効にします。データ同期の際にソースデータベースでカスケード更新および削除操作を実行すると、データの不整合が発生する可能性があります。
種類 | 説明 |
ソースデータベースの制限 |
|
その他 |
|
特別なケース |
|
課金
| 同期タイプ | タスク構成料金 |
| スキーマ同期と完全データ同期 | 無料。 |
| 増分データ同期 | 有料。詳細については、「課金の概要」をご参照ください。 |
サポートされている同期トポロジ
一方向 1 対 1 同期
一方向 1 対多同期
一方向カスケード同期
一方向多対 1 同期
同期トポロジの詳細については、「同期トポロジ」をご参照ください。
サポートされている SQL 操作
操作タイプ | SQL 文 |
DML | INSERT、UPDATE、および DELETE |
DDL |
|
手順
以下のいずれかの方法を使用して データ同期 ページに移動し、データ同期インスタンスが存在するリージョンを選択します。
DTS コンソール
DTS console にログインします。
左側のナビゲーションウィンドウで、データ同期 をクリックします。
ページの左上隅で、データ同期タスクが存在するリージョンを選択します。
DMS コンソール
説明実際の操作は、DMS コンソールのモードとレイアウトによって異なる場合があります。詳細については、「シンプルモード」および「DMS コンソールのレイアウトとスタイルをカスタマイズする」をご参照ください。
DMS console にログインします。
上部のナビゲーションバーで、[データ + AI] にポインタを移動し、 を選択します。
データ同期タスク の右側にあるドロップダウンリストから、データ同期インスタンスが存在するリージョンを選択します。
タスクの作成 をクリックして、タスク構成ページに移動します。
ソースデータベースと宛先データベースを構成します。次の表にパラメータを示します。
警告ソースデータベースと宛先データベースを構成した後、ページに表示される [制限事項] を読むことをお勧めします。そうでない場合、タスクが失敗したり、データの不整合が発生したりする可能性があります。
カテゴリ
パラメータ
説明
該当なし
タスク名
DTS タスクの名前。DTS はタスク名を自動的に生成します。タスクを簡単に識別できる説明的な名前を指定することをお勧めします。一意のタスク名を指定する必要はありません。
移行元データベース
既存の接続情報の選択
DTS に登録されているデータベースインスタンスを使用する場合は、ドロップダウンリストからインスタンスを選択します。DTS は、インスタンスの以下のデータベースパラメータを自動的に入力します。詳細については、「データベース接続を管理する」をご参照ください。
説明DMS コンソールでは、[DMS データベースインスタンスを選択] ドロップダウンリストからデータベースインスタンスを選択できます。
インスタンスを DTS に登録できなかった場合、または DTS に登録されているインスタンスを使用する必要がない場合は、以下のデータベース情報を構成する必要があります。
データベースタイプ
[MySQL] を選択します。
アクセス方法
[クラウドインスタンス] を選択します。
インスタンスリージョン
ソースの ApsaraDB RDS for MySQL インスタンスが存在するリージョンを選択します。
Alibaba Cloudアカウント全体でのデータの複製
この例では、ソースインスタンスと宛先インスタンスは同じ Alibaba Cloud アカウントに属しています。 [いいえ] を選択します。
[RDS インスタンス ID]
ソースの ApsaraDB RDS for MySQL インスタンスの ID を選択します。
データベースアカウント
ソースの ApsaraDB RDS for MySQL インスタンスのデータベースアカウントを入力します。アカウントには、REPLICATION CLIENT、REPLICATION SLAVE、SHOW VIEW、および SELECT の権限が必要です。
データベースパスワード
データベースへのアクセスに使用するパスワード。
暗号化
データベースへの接続を暗号化するかどうかを指定します。ビジネス要件に基づいて、[非暗号化] または [SSL 暗号化] を選択できます。このパラメータを [SSL 暗号化] に設定する場合は、DTS タスクを構成する前に、ApsaraDB RDS for MySQL インスタンスで SSL 暗号化を有効にする必要があります。詳細については、「クラウド証明書を構成して SSL 暗号化を有効にする」をご参照ください。
移行先データベース
既存の接続情報の選択
DTS に登録されているデータベースインスタンスを使用する場合は、ドロップダウンリストからインスタンスを選択します。 DTS は、インスタンスの以下のデータベースパラメータを自動的に入力します。詳細については、「データベース接続を管理する」をご参照ください。
説明DMS コンソールでは、[DMS データベースインスタンスを選択] ドロップダウンリストからデータベースインスタンスを選択できます。
インスタンスを DTS に登録できなかった場合、または DTS に登録されているインスタンスを使用する必要がない場合は、以下のデータベース情報を構成する必要があります。
データベースタイプ
PolarDB for MySQL を選択します。
アクセス方法
[クラウドインスタンス] を選択します。
インスタンスリージョン
宛先の PolarDB for MySQL クラスタが存在するリージョンを選択します。
[PolarDB インスタンス ID]
宛先の PolarDB for MySQL クラスタの ID を選択します。
データベースアカウント
宛先の PolarDB for MySQL クラスタのデータベースアカウントを入力します。アカウントには、読み取りおよび書き込み権限が必要です。
データベースパスワード
データベースへのアクセスに使用するパスワード。
暗号化
宛先 PolarDB for MySQL クラスタへの接続を暗号化するかどうかを指定します。ビジネス要件に基づいてこのパラメータを設定できます。SSL 暗号化機能の詳細については、「SSL 暗号化を構成する」をご参照ください。
ページの下部にある 接続をテストして続行 をクリックします。
説明DTS サーバーの CIDR ブロックをソースデータベースと宛先データベースのセキュリティ設定に自動または手動で追加して、DTS サーバーからのアクセスを許可できることを確認してください。詳細については、「DTS サーバーの CIDR ブロックを追加する」をご参照ください。
ソースデータベースまたは宛先データベースが自己管理型データベースであり、その アクセス方法 が Alibaba Cloud インスタンス に設定されていない場合は、DTS サーバーの CIDR ブロック ダイアログボックスの 接続テスト をクリックします。
同期するオブジェクトを構成します。
オブジェクト設定 ステップで、同期するオブジェクトを構成します。
パラメータ
説明
同期タイプ
同期タイプ。デフォルトでは、[増分データ同期] が選択されています。 [スキーマ同期] と [完全データ同期] も選択する必要があります。事前チェックが完了すると、DTS は選択したオブジェクトの履歴データをソースデータベースから宛先クラスタに同期します。履歴データは、後続の増分同期の基礎となります。
移行元データベースのトリガーを移行する方法
ソースデータベースからトリガーを同期するために使用される方法。ビジネス要件に基づいて同期方法を選択できます。同期するトリガーがない場合は、このパラメータを構成する必要はありません。詳細については、「トリガーを同期または移行するために使用する方法を構成する」をご参照ください。
説明これは、同期タイプ が スキーマ同期 に設定されている場合にのみ構成できます。
同期トポロジ
一方向同期 を選択します。
競合するテーブルの処理モード
エラーの事前チェックと報告: 宛先データベースにソースデータベースのテーブルと同じ名前のテーブルが含まれているかどうかを確認します。ソースデータベースと宛先データベースに同じテーブル名のテーブルが含まれていない場合、事前チェックは合格です。そうでない場合、事前チェック中にエラーが返され、データ同期タスクを開始できません。
説明ソースデータベースと宛先データベースに同じ名前のテーブルが含まれており、宛先データベースのテーブルを削除または名前変更できない場合は、オブジェクト名マッピング機能を使用して、宛先データベースに同期されるテーブルの名前を変更できます。詳細については、「オブジェクト名をマッピングする」をご参照ください。
エラーを無視して続行: ソースデータベースと宛先データベースの同じテーブル名の事前チェックをスキップします。
警告エラーを無視して続行 を選択すると、データの不整合が発生し、ビジネスが潜在的なリスクにさらされる可能性があります。
ソースデータベースと宛先データベースのスキーマが同じで、宛先データベースのデータレコードのプライマリキー値または一意キー値がソースデータベースのデータレコードと同じである場合:
完全データ同期の際、DTS は宛先データベースにデータレコードを同期しません。宛先データベースの既存のデータレコードは保持されます。
増分データ同期の際、DTS は宛先データベースにデータレコードを同期します。宛先データベースの既存のデータレコードは上書きされます。
ソースデータベースと宛先データベースのスキーマが異なる場合、データの初期化に失敗する可能性があります。この場合、一部の列のみが同期されるか、データ同期インスタンスが失敗します。注意して進めてください。
イベントを移行するかどうか
ソースデータベースのイベントを同期するかどうかを指定します。ビジネス要件に基づいてこのパラメータを構成できます。 [はい] を選択した場合は、関連要件を満たし、後続の操作を完了する必要があります。詳細については、「イベントを同期または移行する」をご参照ください。
移行先インスタンスでのオブジェクト名の大文字化
宛先インスタンスにおけるデータベース名、テーブル名、および列名の大文字と小文字の区別です。デフォルトでは、[DTS デフォルト ポリシー] が選択されています。他のオプションを選択して、オブジェクト名の大文字と小文字の使い分けがソースまたはターゲットデータベースと一致するようにすることができます。詳細については、「宛先インスタンスでオブジェクト名の大文字と小文字の区別を指定する」をご参照ください。
ソースオブジェクト
ソースオブジェクト セクションから 1 つ以上のオブジェクトを選択し、
アイコンをクリックして、選択中のオブジェクト セクションにオブジェクトを追加します。説明同期するオブジェクトとしてデータベースまたはテーブルを選択します。
選択中のオブジェクト
宛先インスタンスに同期するオブジェクトの名前を変更するには、選択中のオブジェクト セクションでオブジェクトを右クリックします。詳細については、「オブジェクト名をマッピングする」トピックの「単一オブジェクトの名前をマッピングする」セクションをご参照ください。
複数のオブジェクトの名前を一度に変更するには、選択中のオブジェクト セクションの右上隅にある 一括編集 をクリックします。詳細については、「オブジェクト名をマッピングする」トピックの「一度に複数のオブジェクト名をマッピングする」セクションをご参照ください。
説明データベースレベルまたはテーブルレベルで同期する SQL 操作を選択するには、選択中のオブジェクト セクションでオブジェクトを右クリックします。表示されるダイアログボックスで、同期する SQL 操作を選択します。サポートされている SQL 操作の詳細については、「サポートされている SQL 操作」をご参照ください。
データをフィルタリングする場合は、選択中のオブジェクト セクションでテーブルを右クリックします。表示されるダイアログボックスで、フィルタ条件を設定します。詳細については、「フィルタ条件を構成する」をご参照ください。
オブジェクト名マッピング機能を使用してオブジェクトの名前を変更した場合、そのオブジェクトに依存する他のオブジェクトは同期されない可能性があります。
次へ：詳細設定 をクリックして、詳細設定を構成します。
パラメータ
説明
タスクのスケジュールに使用する専用クラスターの選択
デフォルトでは、専用クラスタを指定しない場合、DTS はタスクを共有クラスタにスケジュールします。データ同期インスタンスの安定性を向上させる場合は、専用クラスタを購入します。詳細については、「DTS 専用クラスタとは」をご参照ください。
移行先データベースのエンジンタイプを選択します。
ターゲットデータベースのエンジンタイプです。ビジネス要件に基づいてエンジンタイプを選択します。有効な値：
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 パラメーターを設定する必要があります。これにより、ターゲットデータベースサーバーの負荷が軽減されます。
環境タグ
インスタンスを識別するために使用される環境タグ。ビジネス要件に基づいて環境タグを選択できます。この例では、環境タグを選択する必要はありません。
順方向および逆方向タスクのハートビートテーブル sql を削除
DTS インスタンスの実行中に、ソースデータベースにハートビートテーブルに対する SQL 操作を書き込むかどうかを指定します。有効な値：
はい: ハートビートテーブルに対する SQL 操作を書き込みません。この場合、DTS インスタンスのレイテンシが表示されることがあります。
いいえ: ハートビートテーブルに対する SQL 操作を書き込みます。この場合、ソースデータベースの物理バックアップやクローニングなどの機能が影響を受ける可能性があります。
ETL の設定
抽出、変換、ロード (ETL) 機能を有効にするかどうかを指定します。詳細については、「ETL とは」をご参照ください。有効な値:
[はい]: ETL 機能を設定します。コードエディターでデータ処理ステートメントを入力できます。詳細については、「データ移行またはデータ同期タスクで ETL を設定する」をご参照ください。
[いいえ]: ETL 機能を設定しません。
監視アラート
データ同期インスタンスのアラートを設定するかどうかを指定します。タスクが失敗した場合、または同期の待機時間が指定されたしきい値を超えた場合、アラート連絡先に通知が送信されます。有効な値：
いいえ: アラートを有効にしません。
はい: アラートを設定します。この場合、アラートのしきい値と アラート通知設定 も設定する必要があります。詳細については、「DTS タスクの作成時にモニタリングとアラートを設定する」セクションのモニタリングとアラートの Topic を設定するをご参照ください。
[次のステップ: データ検証] をクリックして、データ検証を設定します。
詳細については、「データ検証タスクを構成する」をご参照ください。
タスク設定を保存し、事前チェックを実行します。
DTS タスクを設定するために関連 API 操作を呼び出すときに指定するパラメーターを表示するには、次：タスク設定の保存と事前チェック にポインターを移動し、OpenAPI パラメーターのプレビュー をクリックします。
パラメーターを表示する必要がない場合、またはすでに表示済みの場合は、ページ下部にある 次：タスク設定の保存と事前チェック をクリックします。
説明データ同期タスクを開始する前に、DTS は事前チェックを実行します。タスクが事前チェックに合格した後でのみ、データ同期タスクを開始できます。
データ同期タスクが事前チェックに失敗した場合は、失敗した各項目の横にある [詳細の表示] をクリックします。チェック結果に基づいて原因を分析した後、問題をトラブルシューティングします。次に、事前チェックを再実行します。
事前チェック中に項目に対してアラートがトリガーされた場合:
アラート項目を無視できない場合は、失敗した項目の横にある [詳細の表示] をクリックし、問題のトラブルシューティングを行います。次に、事前チェックを再度実行します。
アラート項目を無視できる場合は、[アラート詳細の確認] をクリックします。[詳細の表示] ダイアログボックスで、[無視] をクリックします。表示されるメッセージで、[OK] をクリックします。次に、[再チェック] をクリックして、事前チェックを再度実行します。アラート項目を無視すると、データの不整合が発生し、ビジネスが潜在的なリスクにさらされる可能性があります。
データ同期インスタンスを購入します。
[成功率] が [100%] になるまで待ちます。次に、[次へ: インスタンスの購入] をクリックします。
[購入] ページで、データ同期タスクの課金方式とインスタンスクラスのパラメーターを設定します。次の表でパラメーターについて説明します。
セクション
パラメーター
説明
新しいインスタンスクラス
課金方式
サブスクリプション: データ同期インスタンスを作成するときにサブスクリプションの料金を支払います。サブスクリプション課金方式は、長期利用の場合、従量課金方式よりも費用対効果が高くなります。
従量課金: 従量課金インスタンスは時間単位で課金されます。従量課金方式は短期利用に適しています。従量課金データ同期インスタンスが不要になった場合は、インスタンスをリリースしてコストを削減できます。
リソースグループ設定
データ同期インスタンスが属するリソースグループ。デフォルト値: [デフォルト リソースグループ]。詳細については、「Resource Management とは」をご参照ください。
インスタンスクラス
DTS は、同期速度が異なるインスタンスクラスを提供します。ビジネス要件に基づいてインスタンスクラスを選択できます。詳細については、「データ同期インスタンスのインスタンスクラス」をご参照ください。
サブスクリプション期間
サブスクリプション課金方式を選択した場合は、サブスクリプション期間と作成するデータ同期インスタンスの数を指定します。サブスクリプション期間は、1 ～ 9 か月、1 年、2 年、3 年、または 5 年です。
説明このパラメーターは、サブスクリプション 課金方式を選択した場合にのみ使用できます。
[データ伝送サービス (従量課金) サービス規約] を読んで選択します。
[購入して開始] をクリックします。表示されるダイアログボックスで、OK をクリックします。
タスクの進行状況はタスクリストで確認できます。