Data Transmission Service:ApsaraDB for MongoDB インスタンスから PolarDB for MySQL クラスターへのデータ同期

宛先クラスターの設定

• ソースデータの合計サイズより大きな空きストレージ容量を持つ PolarDB for MySQL クラスターを作成します。（推奨：少なくとも 10 % の余裕を確保）「カスタム購入」および「サブスクリプションクラスターの購入」をご参照ください。

• 宛先クラスターに、プライマリキー列を含むデータベースおよびテーブルを作成します。「データベースの管理」をご参照ください。

必要な権限を持つアカウントの設定

（シャードクラスターのみ）シャードエンドポイントの申請

ソースがシャードクラスターの場合、すべてのシャードノードに対してエンドポイントを申請します。すべてのシャードノードは、同一のアカウントパスワードおよびエンドポイントを共有する必要があります。「シャードのエンドポイント申請」をご参照ください。

ソースデータベースの制限事項

シャードクラスター固有の追加制限事項：

• 各コレクションの _id フィールドは一意である必要があります。_id 値が重複すると、データの不整合が発生します。

• mongos ノードの数は 10 を超えてはなりません。

• インスタンスには孤立ドキュメントを含めてはなりません。MongoDB ドキュメントおよびよくある質問トピックをご参照ください。

• ApsaraDB for MongoDB の balancer が有効化されている場合、インスタンスに遅延が発生する可能性があります。

宛先データベースおよびタスクの制限事項

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

以下のいずれかの方法を使用します。

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

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

2. （任意）右上隅の 新規構成ページ をクリックします。

   - 「以前のバージョンに戻る」が表示されている場合は、このステップはスキップしてください（すでに新バージョンが表示されています）。 - 可能な限り、新バージョンの構成ページをご利用ください。

3. 以下のパラメーターを使用して、ソースおよび宛先データベースを構成します。

一般

ソースデータベース

宛先データベース

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

   ・DTS サーバーの CIDR ブロックを、両方のデータベースのセキュリティ設定に追加する必要があります。DTS により自動的に追加される場合がありますが、手動で追加することもできます。詳細については、「DTS サーバーの CIDR ブロックをオンプレミスデータベースのセキュリティ設定に追加する」をご参照ください。・[アクセス方法] が [Alibaba Cloud インスタンス] でない自己管理データベースの場合、[接続テスト] をクリックし、[DTS サーバーの CIDR ブロック] ダイアログボックスで操作します。

ステップ 3：同期対象オブジェクトの構成

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

パラメーター	説明
同期タイプ	増分データ同期 がデフォルトで選択されています。必要に応じて 完全データ同期 を選択します。スキーマ同期 は選択できません。
競合テーブルの処理モード	事前チェックとエラー報告（デフォルト）：タスク開始前にテーブル名の競合をチェックします。同一のテーブル名が存在する場合、事前チェックは失敗し、タスクは開始できません。競合するテーブルを削除または名前変更できない場合は、「オブジェクト名マッピング」機能を使用してテーブル名を変更してください。<br>エラーを無視して続行：競合チェックをスキップします。 警告 このオプションはデータの不整合を引き起こす可能性があります。完全同期中は、主キーまたは一意キーが一致する既存の宛先レコードが保持されます。増分同期中は、それらのレコードが上書きされます。スキーマが異なる場合、初期化が失敗したり、一部の列のみが同期されたりする可能性があります。
宛先インスタンスにおけるオブジェクト名の大文字小文字の扱い	送信先のデータベース名、テーブル名、および列名の大文字小文字のポリシー。デフォルト: [DTS デフォルトポリシー]。詳細については、「送信先インスタンス内のオブジェクト名の大文字小文字を指定する」をご参照ください。
ソースオブジェクト	ソースオブジェクト セクションから 1 つ以上のコレクションを選択し、 アイコンをクリックして 選択済みオブジェクト セクションに移動します。

1. 選択済みオブジェクト セクションで、オブジェクトマッピングを構成します。（任意）同期不要のフィールドを削除するには、該当行の後に表示される アイコンをクリックします。

   1. データベース名の変更：選択済みオブジェクト 内のデータベースを右クリックし、 スキーマ名 を PolarDB for MySQL のターゲットデータベース名に変更し、 OK をクリックします。

   2. コレクション名の変更：選択済みオブジェクト 内のコレクションを右クリックし、 テーブル名 を PolarDB for MySQL のターゲットテーブル名に変更します。

      • （任意）フィルター条件を指定します。「フィルター条件の指定」をご参照ください。

      • （任意）同期対象の DDL および DML 操作の選択 セクションで、同期対象の増分操作を選択します。

   3. フィールドのマッピング：DTS はコレクションデータを自動的にマッピングし、値の割り当て 列に bson_value() 式を生成します。式が要件を満たすことを確認したうえで、各フィールドについて 列名、型、長さ、精度 を構成します。

      重要

      宛先テーブルのプライマリキー列には bson_value("_id") を割り当てます。各 bson_value() 式では、ドキュメントの階層構造に従ってフィールドおよびそのサブフィールドの両方を指定してください。親フィールドのみ（例：bson_value("person")）を指定しても、そのサブフィールドは宛先に同期されません。

      正しい式を持つフィールド

      1. 列名 を、宛先 PolarDB for MySQL テーブル内の対応する列名に設定します。

      2. 型 を、ソースデータと互換性のある型から選択します。データ型のマッピングについては、「データ型マッピング」セクションをご参照ください。

      3. （任意）長さ および 精度 を設定します。

      4. 各フィールドについて同様の手順を繰り返します。

      誤った式を持つフィールド

      1. 行の [アクション] 列にある アイコンをクリックします。

      2. + 列の追加 をクリックします。

      3. 列名、型、長さ、精度 を設定します。

      4. 値の割り当て に正しい bson_value() 式を入力します。例については、「フィールドマッピングの例」セクションをご参照ください。

      5. 各フィールドについて同様の手順を繰り返します。

      重要

      - 宛先テーブルのプライマリキー列には bson_value("_id") を割り当てます。 - 各 bson_value() 式では、ドキュメントの階層構造に従ってフィールドおよびそのサブフィールドの両方を指定してください。親フィールドのみ（例：bson_value("person")）を指定しても、そのサブフィールドは宛先に同期されません。

   4. OK をクリックします。

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

ステップ 4：設定の保存と事前チェックの実行

• このタスクの API パラメーターをプレビューするには、次へ：タスク設定の保存と事前チェック の上にポインタを合わせ、OpenAPI パラメーターのプレビュー をクリックします。

• 続行するには、次へ：タスク設定の保存と事前チェック をクリックします。

DTS はタスク開始前に事前チェックを実行します。事前チェックに合格した場合のみ、タスクが開始されます。

事前チェックが失敗した場合、各失敗項目の横にある 詳細の表示 をクリックし、問題を修正したうえで 再び事前チェック をクリックしてください。

アラートがトリガーされた場合：無視できない項目については、問題を修正して事前チェックを再実行してください。無視可能な項目については、アラート詳細の確認 > 無視 > OK > 再び事前チェック の順にクリックしてください。アラートを無視すると、データの不整合が発生する可能性があります。

ステップ 5：インスタンスの購入

1. 成功率 が 100% に達するまで待機し、次へ：インスタンスの購入 をクリックします。

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

1. Data Transmission Service（従量課金）サービス利用規約 を読み、同意します。

2. 購入して開始 をクリックし、ダイアログボックスで OK をクリックします。

タスクが開始された後は、タスクリストで進行状況を監視してください。