Data Transmission Service:PolarDB-X 2.0 インスタンスから AnalyticDB for MySQL 3.0 クラスターへのデータ同期

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

その他の制限事項

DTS は、バイナリログ位置を進めるために、ソースデータベースの dts_health_check.ha_health_check テーブルに定期的に書き込みを行います。

スキーマ同期中は外部キーは同期されません。完全同期および増分同期中は、DTS がセッションレベルで外部キー制約チェックおよびカスケード操作を無効化します。同期中にソースでカスケード UPDATE または DELETE 操作を実行した場合、データの不整合が発生する可能性があります。

ステップ 1：データ同期ページへ移動

DTS コンソールまたは DMS コンソールを使用します。

ステップ 2：ソースおよびターゲットデータベースの構成

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

2. ソースデータベースのパラメーターを構成します。

   パラメーター	説明
   タスク名	タスクを識別するための記述的な名前を指定します。この名前は一意である必要はありません。未入力の場合、DTS がデフォルト名を生成します。
   既存接続の選択	利用可能な場合は、ドロップダウンリストから事前登録済みのデータベースインスタンスを選択します。DTS が残りのパラメーターを自動的に設定します。詳細については、「データベース接続の管理」をご参照ください。事前登録済みのインスタンスを使用しない場合は、以下のパラメーターを手動で設定します。
   データベースタイプ	PolarDB-X 2.0 を選択します。
   アクセス方法	Alibaba Cloud インスタンス を選択します。
   インスタンスリージョン	ソース PolarDB-X 2.0 インスタンスが配置されているリージョンを選択します。
   Alibaba Cloud アカウント間でのデータ複製	同一アカウント内での同期の場合は、いいえ を選択します。
   インスタンス ID	ソース PolarDB-X 2.0 インスタンスを選択します。
   データベースアカウント	データベースアカウントを入力します。このアカウントは、同期対象のオブジェクトに対して SELECT、REPLICATION CLIENT、および REPLICATION SLAVE 権限を有している必要があります。
   データベースパスワード	データベースアカウントのパスワードを入力します。

3. ターゲットデータベースのパラメーターを構成します。

   パラメーター	説明
   既存接続の選択	利用可能な場合は、ドロップダウンリストから事前に登録済みのクラスターを選択します。DTS が残りのパラメーターを自動的に設定します。事前に登録済みのインスタンスを使用しない場合は、以下のパラメーターを手動で構成してください。
   データベースタイプ	AnalyticDB MySQL 3.0 を選択します。
   アクセス方法	Alibaba Cloud インスタンス を選択します。
   インスタンスリージョン	ターゲット AnalyticDB for MySQL V3.0 クラスターが配置されているリージョンを選択します。
   Alibaba Cloud アカウント間でのデータ複製	同一アカウント内での同期の場合は、いいえ を選択します。
   インスタンス ID	ターゲット AnalyticDB for MySQL V3.0 クラスターを選択します。
   データベースアカウント	データベースアカウントを入力します。このアカウントは、ターゲットクラスターに対して読み取りおよび書き込み権限を有している必要があります。
   データベースパスワード	データベースアカウントのパスワードを入力します。

4. 接続テストと続行 をクリックします。

   DTS サーバーの CIDR ブロックを、ソースおよび送信先のセキュリティ設定に追加する必要があります。これにより、DTS が接続できるようになります。DTS が自動的に追加することもできますし、手動で追加することもできます。詳細については、「DTS サーバーの CIDR ブロックをセキュリティ設定に追加する」をご参照ください。

ステップ 3：同期対象の構成

オブジェクトの構成 ステップで、以下のパラメーターを設定します。

同期タイプ

以下の 3 種類すべてを選択します：スキーマ同期、完全データ同期、および 増分データ同期。

これら 3 種類は以下の順序で実行されます：

1. スキーマ同期：テーブル構造をソースからターゲットへレプリケーションします。

2. 完全データ同期：既存のすべてのデータをターゲットへコピーします。このフェーズは増分同期の開始前に完了し、継続的な同期のベースラインとなります。

3. 増分データ同期（デフォルトで選択）：ソースからの継続的な変更をキャプチャして適用します。このフェーズは課金対象です — スキーマ同期および完全同期は無料です。

完全データ同期 を選択した場合、DTS は CREATE TABLE 文で作成されたテーブルのスキーマおよびデータもターゲットへ同期します。

競合テーブルの処理モード

ソースと同名のテーブルがターゲットに存在する場合の処理方法を選択します。

• 事前チェックとエラー報告 (デフォルト): DTS は開始前に名前の競合をチェックします。同一のテーブル名が存在する場合、事前チェックは失敗し、タスクは開始できません。これを解決するには、送信先でテーブルの名前を変更するか、オブジェクト名マッピングを使用します。

• エラーを無視して続行：DTS は名前衝突チェックをスキップします。ソースとターゲットのスキーマが同一であり、ターゲットに一致するプライマリキーまたは一意キーを持つレコードが存在する場合、完全同期では既存のレコードを保持し、増分同期では上書きします。スキーマの不一致により、タスクが失敗したり、一部のカラムのみが同期されたりする可能性があります。

マージテーブル

同じスキーマを持つ複数のソーステーブルを 1 つのターゲットテーブルにマージする場合は、はいアラート通知設定 を設定します。これは、シャード化された OLTP テーブルを分析用に集約する OLAP シナリオで有用です。

• マージ時、オブジェクト名マッピング を使用して、各ソーステーブルをターゲット送信先テーブル名に名前を変更します。

• DTS は、各行の出所を追跡するために、ターゲットテーブルに __dts_data_source カラム（TEXT 型）を追加します。このカラムの形式は <同期インスタンス ID>:<ソースデータベース名>:<ソーススキーマ名>:<ソーステーブル名> であり、例： dts********:dtstestdata:testschema:customer1 です。

• タスクで選択されたすべてのソーステーブルが、単一のターゲットテーブルにマージされます。特定のソーステーブルをマージ対象から除外するには、それらのテーブル専用に別途同期タスクを作成してください。

各ソーステーブルが対応するターゲットテーブルにマップされる場合は、いいえ（デフォルト）を設定します。

ソースオブジェクトおよび選択済みオブジェクト

ソースオブジェクト セクションからオブジェクトを選択し、矢印アイコンをクリックして 選択済みオブジェクト へ移動します。

• カラム、テーブル、またはデータベースを選択できます。テーブルまたはカラムを選択した場合、ビュー、トリガー、ストアドプロシージャなどの他のオブジェクトタイプは同期されません。

• データベース全体を選択した場合、DTS が分散キーを自動的に設定します：プライマリキーを持つテーブルは、そのプライマリキー列を分散キーとして使用します。プライマリキーを持たないテーブルは、ターゲット側に自動採番主キー列が追加され、ソースとターゲットの不整合を引き起こす可能性があります。

送信先のオブジェクトの名前を変更するには、[選択されたオブジェクト] でオブジェクトを右クリックして個別に名前を変更するか、[一括編集] をクリックして一括で名前を変更します。詳細については、「データベース、テーブル、および列名のマッピング」をご参照ください。

同期対象の行をフィルターするには、選択済みオブジェクト 内のオブジェクトを右クリックし、WHERE 条件を指定してください。詳細については、「フィルター条件の指定」をご参照ください。

特定のテーブルに対して同期対象の SQL 操作を指定するには、選択済みオブジェクト 内のテーブルを右クリックし、含める操作を選択してください。

ステップ 4：高度な設定の構成

次へ：高度な設定 をクリックし、以下のパラメーターを構成します。

ステップ 5：（任意）データベースおよびテーブルフィールドの構成

次へ：データベースおよびテーブルフィールドの構成 をクリックして、ターゲットテーブルのプロパティを設定します。このステップは、スキーマ同期 が選択されている場合にのみ利用可能です。

定義ステータス を すべて に設定すると、すべてのテーブルを表示および編集できます。各テーブルについて、以下の項目を構成できます：

• タイプ：AnalyticDB for MySQL におけるテーブルのタイプ

• プライマリキー列：1 つ以上のカラムをプライマリキーとして指定します。複合プライマリキーを構成できます。

• 分散キー：ノード間でデータを分散するために使用される 1 つ以上のカラム

• パーティションキー、パーティショニングルール、パーティションライフサイクル：ターゲットテーブルのパーティション構成

AnalyticDB for MySQL のテーブル作成オプションの詳細については、「CREATE TABLE」をご参照ください。

ステップ 6：設定の保存および事前チェックの実行

次へ：タスク設定の保存および事前チェック をクリックします。

このタスク構成の API パラメーターをプレビューするには、ボタンにカーソルを合わせ、保存前に OpenAPI パラメーターのプレビュー をクリックします。

DTS はタスク開始前に事前チェックを実行します。事前チェックが成功した場合にのみ、タスクを開始できます。

• 事前チェックが失敗した場合、各失敗項目の横にある 詳細の表示 をクリックします。問題を修正した後、再チェック をクリックします。

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

ステップ 7：インスタンスの購入および開始

1. 成功率 が 100% と表示されたら、次へ：インスタンスの購入 をクリックします。

2. 購入ページで、インスタンスのパラメーターを構成します。

   パラメーター	説明
   課金方法	サブスクリプション：一定期間（1～9か月、または1年、2年、3年、5年）の前払い方式です。長期間実行されるタスクにコスト効率が優れます。従量課金：時間単位で課金されます。短期利用に適しています。不要になった場合は、ご利用のインスタンスをリリースして課金を停止してください。
   リソースグループ設定項目	Resource Management とは
   インスタンスクラス	データ同期インスタンスのインスタンスクラス必要な同期速度に応じてインスタンスクラスを選択します。詳細については、「」をご参照ください。
   サブスクリプション期間	サブスクリプション課金の場合のみ表示されます。期間の長さおよび作成するインスタンス数を設定します。

3. Data Transmission Service（従量課金）利用規約 をお読みになり、同意してください。

4. 購入および開始 をクリックし、確認ダイアログで OK をクリックします。

タスクはタスク一覧に表示されます。一覧ビューから進行状況を監視できます。