Data Transmission Service:ApsaraDB for MongoDB インスタンスから PolarDB for MySQL クラスタにデータを移行する

前提条件

• ソースデータベースが ApsaraDB for MongoDB シャードクラスタの場合、すべてのシャードノードのエンドポイントを申請する必要があります。 シャードクラスタインスタンス内のシャードノードは、同じアカウントパスワードとエンドポイントを共有する必要があります。 エンドポイントの申請方法の詳細については、「シャードノードまたは ConfigServer ノードのエンドポイントを申請する」をご参照ください。

• 宛先の ApsaraDB RDS for MySQL インスタンスが作成されている。 このインスタンスの使用可能なストレージ容量は、ソースデータベースのデータの合計サイズよりも大きい。 詳細については、「Enterprise Edition クラスタを購入する」および「サブスクリプションクラスタを購入する」をご参照ください。

  説明

  宛先データベースの使用可能なストレージ容量は、ソースデータベースのデータの合計サイズよりも 10% 大きいことが推奨されます。

• データを受信するために、宛先の PolarDB for MySQL クラスタにデータベースとプライマリキー列を持つテーブルが作成されている。 詳細については、「データベースを管理する」をご参照ください。

  重要

  • 宛先テーブルのデータ型がソース ApsaraDB for MongoDB インスタンスのデータと互換性があることを確認してください。 たとえば、ApsaraDB for MongoDB インスタンスの _id フィールドが ObjectId 型の場合、PolarDB for MySQL クラスタのデータ型は varchar である必要があります。

  • PolarDB for MySQL クラスタの宛先テーブルの列に _id または _value という名前を付けないでください。

使用上の注意

課金概要

移行タイプ

データベースアカウントに必要な権限

手順

1. 次のいずれかの方法を使用して、データ移行ページに移動し、データ移行インスタンスが存在するリージョンを選択します。

   DTS コンソール

   1. DTS コンソール にログオンします。

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

   3. ページの左上隅で、データ移行インスタンスが存在するリージョンを選択します。

   DMS コンソール

   説明

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

   1. DMS コンソール にログオンします。

   2. 上部のナビゲーションバーで、ポインタを [データ開発] > DTS (DTS) > データ移行 に移動します。

   3. [データ移行タスク] の右側にあるドロップダウンリストから、データ同期インスタンスが存在するリージョンを選択します。

2. タスクの作成 をクリックして、タスク構成ページに移動します。

3. オプション。 ページの右上隅にある 新バージョンの設定ページを試してみる をクリックします。

   説明

   • ページの右上隅に 旧バージョンの設定ページに戻る ボタンが表示されている場合は、この手順をスキップします。

   • 構成ページの新バージョンと旧バージョンでは、特定のパラメータが異なる場合があります。 新しいバージョンの構成ページを使用することをお勧めします。

4. ソースデータベースと宛先データベースを構成します。 次の表にパラメータを示します。

   カテゴリ	構成	説明
   該当なし	タスク名	DTS タスクの名前。 DTS はタスク名を自動的に生成します。 タスクを簡単に識別できる説明的な名前を指定することをお勧めします。 一意のタスク名を指定する必要はありません。
   移行元データベース	既存の接続情報の選択	使用するインスタンス。 ビジネス要件に基づいて、既存のインスタンスを使用するかどうかを選択できます。 既存のインスタンスを選択すると、DTS はデータベースのパラメータを自動的に入力します。 既存のインスタンスを使用しない場合は、以下のデータベース情報を構成する必要があります。 説明 データベース接続 ページまたは新しい構成ページで、データベースを DTS に登録できます。 詳細については、「データベース接続を管理する」をご参照ください。 DMS コンソールでは、DMS データベースインスタンスの選択 ドロップダウンリストから既存のデータベースを選択できます。 また、DMS データベースインスタンスの追加 をクリックするか、DMS コンソールのホームページに戻ってデータベースを DMS に登録することもできます。 詳細については、「Alibaba Cloud データベースインスタンスを登録する」および「サードパーティクラウドサービスまたは自己管理データベースでホストされているデータベースを登録する」をご参照ください。
   	データベースタイプ	ソースデータベースのタイプ。 MongoDB を選択します。
   	アクセス方法	ソースデータベースのアクセス方法。 Alibaba Cloud インスタンス を選択します。
   	インスタンスのリージョン	ソース ApsaraDB for MongoDB インスタンスが存在するリージョン。
   	Alibaba Cloud アカウント間でデータを複製	この例では、現在の Alibaba Cloud アカウントのデータベースインスタンスが使用されます。 × を選択します。
   	アーキテクチャ	ソース ApsaraDB for MongoDB インスタンスのアーキテクチャ。 この例では、レプリカセット が選択されています。 説明 ソースデータベースが ApsaraDB for MongoDB シャードクラスター インスタンスの場合、Shardアカウント と Shardパスワード を指定する必要があります。
   	移行方法	実際の状況に基づいて、増分データ移行の方法を選択します。 Oplog (推奨): ソースデータベースで Oplog が有効になっている場合、このオプションがサポートされます。 説明 ローカルの自己管理 MongoDB と ApsaraDB for MongoDB では、デフォルトで Oplog が有効になっています。 この方法を使用して増分データを移行する場合、増分移行タスクの遅延は小さくなります (ログのプル速度が速い)。 したがって、Oplog を選択することをお勧めします。 ChangeStream: ソースデータベースで変更ストリーム (変更ストリーム) が有効になっている場合、このオプションがサポートされます。 説明 ソースデータベースが Amazon DocumentDB (非エラスティッククラスタ) の場合、ChangeStream のみがサポートされます。 ソースデータベースの アーキテクチャ が シャードクラスター として選択されている場合、Shardアカウント と Shardパスワード を入力する必要はありません。
   	インスタンス ID	ソース PolarDB for MySQL クラスタの ID。
   	認証データベース	ソース ApsaraDB for MongoDB インスタンスのデータベースアカウントとパスワードを格納する認証データベースの名前。 以前に名前を変更していない場合は、デフォルト値 admin が使用されます。
   	データベースアカウント	ソース ApsaraDB for MongoDB インスタンスのデータベースアカウント。 アカウントに必要な権限の詳細については、このトピックの データベースアカウントに必要な権限 セクションをご参照ください。
   	データベースのパスワード	データベースへのアクセスに使用されるパスワード。
   	暗号化	ソースデータベースへの接続を暗号化するかどうかを指定します。 ビジネス要件に基づいて、非暗号化、SSL 暗号化、または Mongo Atlas SSL を選択できます。 暗号化 パラメータで使用可能なオプションは、アクセス方法 パラメータと アーキテクチャ パラメータで選択された値によって決まります。 DTS コンソールに表示されるオプションが優先されます。 説明 [アーキテクチャ] パラメータが [シャードクラスタ] に設定され、ApsaraDB for MongoDB データベースの [移行方法] パラメータが Oplog に設定されている場合、SSL 暗号化 パラメータは使用できません。 ソースデータベースが レプリカセット アーキテクチャを使用する自己管理 MongoDB データベースで、アクセス方法 パラメータが Alibaba Cloud インスタンス に設定されておらず、[暗号化] パラメータが SSL 暗号化 に設定されている場合、認証局 (CA) 証明書をアップロードして、ソースデータベースへの接続を検証できます。
   移行先データベース	既存の接続情報の選択	使用するインスタンス。 ビジネス要件に基づいて、既存のインスタンスを使用するかどうかを選択できます。 既存のインスタンスを選択すると、DTS はデータベースのパラメータを自動的に入力します。 既存のインスタンスを使用しない場合は、以下のデータベース情報を構成する必要があります。 説明 データベース接続 ページまたは新しい構成ページで、データベースを DTS に登録できます。 詳細については、「データベース接続を管理する」をご参照ください。 DMS コンソールでは、DMS データベースインスタンスの選択 ドロップダウンリストから既存のデータベースを選択できます。 また、DMS データベースインスタンスの追加 をクリックするか、DMS コンソールのホームページに戻ってデータベースを DMS に登録することもできます。 詳細については、「Alibaba Cloud データベースインスタンスを登録する」および「サードパーティクラウドサービスまたは自己管理データベースでホストされているデータベースを登録する」をご参照ください。
   	データベースタイプ	宛先データベースのタイプ。 PolarDB for MySQL を選択します。
   	アクセス方法	宛先データベースのアクセス方法。 Alibaba Cloud インスタンス を選択します。
   	インスタンスのリージョン	宛先 PolarDB for MySQL クラスタが存在するリージョン。
   	Alibaba Cloud アカウント間でデータを複製	この例では、現在の Alibaba Cloud アカウントのデータベースインスタンスが使用されます。 × を選択します。
   	PolarDB クラスター ID	宛先 PolarDB for MySQL クラスタの ID。
   	データベースアカウント	宛先 PolarDB for MySQL クラスタのデータベースアカウント。 アカウントに必要な権限については、このトピックの データベースアカウントに必要な権限 セクションをご参照ください。
   	データベースのパスワード	データベースインスタンスへのアクセスに使用されるパスワード。
   	暗号化	ビジネス要件に基づいてパラメータを指定できます。 SSL 暗号化機能の詳細については、「SSL 暗号化を構成する」をご参照ください。

5. ページの下部にある [接続テストと続行] をクリックします。

   説明

   • DTS サーバーの CIDR ブロックをソースデータベースと宛先データベースのセキュリティ設定に自動または手動で追加して、DTS サーバーからのアクセスを許可できることを確認してください。 詳細については、「DTS サーバーの CIDR ブロックを追加する」をご参照ください。

   • ソースデータベースまたは宛先データベースが自己管理データベースであり、その [アクセス方法] が [alibaba Cloud インスタンス] に設定されていない場合は、[DTS サーバーの CIDR ブロック] ダイアログボックスの [接続テスト] をクリックします。

6. 移行するオブジェクトを構成します。

   1. オブジェクト設定 ページで、移行するオブジェクトを構成します。

      構成	説明
      移行タイプ	完全データ移行のみを実行するには、[完全データ移行] のみを選択します。 データ移行中のサービス継続性を確保するには、[完全データ移行] と [増分データ移行] を選択します。 説明 [増分データ移行] を選択しない場合は、データ移行中にソースデータベースにデータを書き込まないことをお勧めします。 これにより、ソースデータベースと宛先データベース間でデータの整合性が確保されます。
      競合するテーブルの処理モード	エラーの事前チェックと報告: 宛先データベースにソースデータベースのコレクションと同じ名前のコレクションが含まれているかどうかを確認します。 ソースデータベースと宛先データベースに同じ名前のコレクションが含まれていない場合、事前チェックは合格です。 そうでない場合、事前チェック中にエラーが返され、データ移行タスクを開始できません。 説明 ソースデータベースと宛先データベースに同じ名前のコレクションが含まれており、宛先データベースのコレクションを削除または名前変更できない場合は、オブジェクト名マッピング機能を使用して、宛先データベースに移行されるコレクションの名前を変更できます。 詳細については、「オブジェクト名をマッピングする」をご参照ください。 エラーを無視して続行: ソースデータベースと宛先データベースの同じコレクション名の事前チェックをスキップします。 警告 エラーを無視して続行 を選択すると、データの整合性が保証されず、ビジネスが潜在的なリスクにさらされる可能性があります。 DTS は、宛先データベースのデータレコードと同じプライマリキーを持つデータレコードを移行しません。 データの初期化に失敗したり、特定の列のみが移行されたり、データ移行タスクが失敗したりする可能性があります。
      移行先インスタンスでのオブジェクト名の大文字化	宛先インスタンスのデータベース名、テーブル名、および列名の大文字と小文字の区別。 デフォルトでは、[DTS デフォルトポリシー] が選択されています。 オブジェクト名の大文字と小文字の区別がソースデータベースまたは宛先データベースと一致するように、他のオプションを選択できます。 詳細については、「宛先インスタンスのオブジェクト名の大文字と小文字の区別を指定する」をご参照ください。
      ソースオブジェクト	ソースオブジェクト セクションから 1 つ以上のオブジェクトを選択します。 アイコンをクリックして、選択中のオブジェクト セクションにオブジェクトを追加します。 説明 移行対象のオブジェクトとしてコレクションを選択できます。
      選択中のオブジェクト	データベース名を変更します。 選択中のオブジェクト セクションで、移行するコレクションが属するデータベースを右クリックします。 [データベース名] の値を、宛先 PolarDB for MySQL クラスタでデータを受信するために使用されるスキーマの名前に変更します。 [OK] をクリックします。 テーブル名を変更します。 選択中のオブジェクト セクションで、移行するコレクションが属するコレクションを右クリックします。 [テーブル名] の値を、宛先 PolarDB for MySQL クラスタでデータを受信するために使用されるテーブルの名前に変更します。 オプション: データをフィルタリングする条件を指定できます。 詳細については、「フィルタ条件を指定する」をご参照ください。 オプション: 同期する DDL および DML 操作を選択 セクションで、増分データ移行中に移行する操作を選択できます。 ソース ApsaraDB for MongoDB インスタンスから移行するフィールドを指定します。 デフォルトでは、DTS は移行するコレクションのデータをマッピングし、[値の割り当て] 列に式を構成します。 式が要件を満たしているかどうかを確認し、[列名]、[タイプ]、[長さ]、および [精度] パラメータを指定する必要があります。 重要 宛先テーブルのプライマリキー列に bson_value("_id") を割り当てる必要があります。 階層関係に基づいて、対応する bson_value() 式の各列のフィールドとサブフィールドを指定する必要があります。 そうでない場合、データが失われたり、タスクが失敗したりする可能性があります。 bson_value() 式の [値の割り当て] 列で、ApsaraDB for MongoDB インスタンスのデータ行のフィールド名を表示します。 "" 内のフィールドは、ApsaraDB for MongoDB インスタンスのフィールド名です。 たとえば、式が bson_value("age") の場合、age は ApsaraDB for MongoDB インスタンスのデータ行のフィールド名です。 オプション: 移行する必要のないフィールドを削除できます。 説明 移行する必要のないフィールドを削除するには、データ行の後の アイコンをクリックします。 移行するフィールドを指定します。 bson_value() 式が要件を満たしているかどうかに基づいて、次のいずれかの手順を実行します。 式がフィールド要件を満たしている [列名] パラメータを構成します。 説明 宛先 PolarDB for MySQL クラスタでデータを受信するために使用されるテーブルの列名を入力します。 各列のデータ [タイプ] を選択します。 重要 宛先テーブルのデータ型がソース ApsaraDB for MongoDB インスタンスのデータと互換性があることを確認してください。 データ型マッピングの詳細については、このトピックの データ型マッピング セクションをご参照ください。 オプション: 各列のデータ [長さ] と [精度] を指定します。 上記の手順を繰り返して、ソーステーブルの列を宛先テーブルの列にマッピングします。 式がフィールド要件を満たしていない 説明 たとえば、親子構造などの階層関係を持つフィールド。 [操作] 列で、データ行の後の アイコンをクリックします。 [+ 列を追加] をクリックします。 [列名]、[タイプ]、[長さ]、および [精度] パラメータを構成します。 bson_value() 式を [値の割り当て] フィールドに入力します。詳細については、このトピックの「値の割り当ての例」セクションをご参照ください。 上記の手順を繰り返して、ソーステーブルの列を宛先テーブルの列にマッピングします。 [OK] をクリックします。

   2. 次へ：詳細設定 をクリックして詳細設定を行います。

      構成	説明
      タスクのスケジュールに使用する専用クラスターの選択	デフォルトでは、専用のクラスターを指定しない場合、DTS はデータ移行タスクを共有クラスターにスケジュールします。データ移行タスクの安定性を向上させるには、専用のクラスターを購入します。詳細については、「DTS 専用クラスターとは」をご参照ください。
      移行先データベースのエンジンタイプを選択します。	宛先データベースのエンジンタイプです。ビジネス要件に基づいてエンジンタイプを選択します。有効値: InnoDB: デフォルトのストレージエンジン。 X-Engine: オンライントランザクション処理 (OLTP) 用のデータベースストレージエンジン。
      失敗した接続の再試行時間	接続失敗時のリトライ時間の範囲です。データ移行タスクの開始後にソースデータベースまたは宛先データベースへの接続に失敗した場合、DTS はリトライ時間の範囲内で直ちに接続を再試行します。有効値: 10 ～ 1,440。単位: 分。デフォルト値: 720。このパラメーターには 30 より大きい値を設定することをお勧めします。指定されたリトライ時間の範囲内で DTS がソースデータベースと宛先データベースに再接続された場合、DTS はデータ移行タスクを再開します。そうでない場合、データ移行タスクは失敗します。 説明 同じソースデータベースまたは宛先データベースを共有する複数のデータ移行タスクに異なるリトライ時間の範囲を指定した場合、後で指定された値が優先されます。 DTS が接続を再試行すると、DTS インスタンスの料金が発生します。ビジネス要件に基づいてリトライ時間の範囲を指定することをお勧めします。また、ソースデータベースと宛先インスタンスが解放された後、できるだけ早く DTS インスタンスを解放することもできます。
      移行元データベースと移行先データベースで他の問題が発生した場合の、再試行までの待機時間です。	その他の問題のリトライ時間の範囲です。たとえば、データ移行タスクの開始後に DDL または DML 操作の実行に失敗した場合、DTS はリトライ時間の範囲内で直ちに操作を再試行します。有効値: 1 ～ 1440。単位: 分。デフォルト値: 10。このパラメーターには 10 より大きい値を設定することをお勧めします。指定されたリトライ時間の範囲内で失敗した操作が正常に実行された場合、DTS はデータ移行タスクを再開します。そうでない場合、データ移行タスクは失敗します。 重要 移行元データベースと移行先データベースで他の問題が発生した場合の、再試行までの待機時間です。 パラメーターの値は、失敗した接続の再試行時間 パラメーターの値よりも小さくする必要があります。
      完全移行率を制限するかどうか	完全データ移行の調整を有効にするかどうかを指定します。完全データ移行中、DTS はソースデータベースと宛先データベースの読み取りおよび書き込みリソースを使用します。これにより、データベースサーバーの負荷が増加する可能性があります。ビジネス要件に基づいて、完全データ移行の調整を有効にすることができます。調整を構成するには、1 秒あたりのソースデータベースのクエリ率 QPS、1 秒あたりの完全移行の行数 RPS、および 1 秒あたりの完全移行データ量 (MB) BPS パラメーターを構成する必要があります。これにより、宛先データベースサーバーの負荷が軽減されます。 説明 移行タイプ パラメーターで 完全データ移行 を選択した場合にのみ、このパラメーターを構成できます。
      同じテーブル内のプライマリキー_id のデータ型が一意かどうか	移行されるデータの同じコレクション内で、プライマリキー _id のデータ型が一意であるかどうか。 説明 移行タイプ が 完全データ移行 に設定されている場合にのみ構成できます。 ○: 一意です。完全移行フェーズでは、DTS はソースデータベースから移行されるデータのプライマリキーのデータ型をスキャンしません。 ×: 一意ではありません。完全移行フェーズでは、DTS はソースデータベースから移行されるデータのプライマリキーのデータ型をスキャンします。
      増分移行率を制限するかどうか	増分データ移行の調整を有効にするかどうかを指定します。調整を構成するには、1 秒あたりの増分移行の行数 RPS および 1 秒あたりの増分移行データ量 (MB) BPS パラメーターを構成する必要があります。これにより、宛先データベースサーバーの負荷が軽減されます。 説明 移行タイプ パラメーターで 増分データ移行 を選択した場合にのみ、このパラメーターを構成できます。
      環境タグ	ビジネス要件に基づいて環境タグを選択できます。この例では、環境タグは選択されていません。
      ETL の設定	ETL (抽出、変換、書き出し) 機能を有効にするかどうかを指定します。詳細については、「ETL とは」をご参照ください。有効値: はい: ETL 機能を構成します。コードエディターにデータ処理ステートメントを入力できます。詳細については、「データ移行タスクまたはデータ同期タスクで ETL を構成する」をご参照ください。 いいえ: ETL 機能を構成しません。
      監視アラート	データ移行タスクのアラートを構成するかどうかを指定します。タスクが失敗した場合、または移行遅延が指定されたしきい値を超えた場合、アラート連絡先に通知が送信されます。有効値: いいえ: アラートを構成しません。 はい: アラートを構成します。この場合、アラートのしきい値と アラート通知設定 も構成する必要があります。詳細については、「監視とアラートを構成する」トピックの DTS タスクの作成時に監視とアラートを構成する セクションをご参照ください。

7. タスク設定を保存し、事前チェックを実行します。

   • DTS タスクを設定するために関連 API 操作を呼び出すときに指定するパラメーターを表示するには、次：タスク設定の保存と事前チェック にポインターを移動し、OpenAPI パラメーターのプレビュー をクリックします。

   • パラメーターを表示する必要がない場合、またはすでに表示済みの場合は、ページ下部にある 次：タスク設定の保存と事前チェック をクリックします。

   説明

   • データ移行タスクを開始する前に、DTS は事前チェックを実行します。タスクが事前チェックに合格した後にのみ、データ移行タスクを開始できます。

   • タスクが事前チェックに合格しなかった場合は、失敗した各項目の横にある [詳細の表示] をクリックします。チェック結果に基づいて原因を分析し、問題をトラブルシューティングします。その後、再度事前チェックを実行します。

   • 事前チェック中に項目に対してアラートがトリガーされた場合:

     • アラート項目を無視できない場合は、失敗した項目の横にある [詳細の表示] をクリックして、問題をトラブルシューティングします。その後、再度事前チェックを実行します。

     • アラート項目を無視できる場合は、[アラートの詳細の確認] をクリックします。 [詳細の表示] ダイアログボックスで、[無視] をクリックします。表示されるメッセージで、[OK] をクリックします。次に、[再チェック] をクリックして、再度事前チェックを実行します。アラート項目を無視すると、データの不整合が発生し、ビジネスが潜在的なリスクにさらされる可能性があります。

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

   1. [成功率] が [100%] になるまで待ちます。次に、[次へ: インスタンスの購入] をクリックします。

   2. [インスタンスの購入] ページで、データ移行インスタンスのインスタンスクラス パラメーターを構成します。次の表にパラメーターを示します。

      セクション	パラメーター	説明
      新しいインスタンスクラス	リソースグループ	データ移行インスタンスが属するリソースグループ。デフォルト値: [デフォルト リソースグループ]。詳細については、「リソース管理とは」をご参照ください。
      	インスタンスクラス	DTS では、移行速度が異なるインスタンスクラスが提供されています。ビジネス シナリオに基づいてインスタンスクラスを選択できます。詳細については、「データ移行インスタンスのインスタンスクラス」をご参照ください。

   3. チェックボックスをオンにして、[data Transmission Service (従量課金制) サービス規約] を読んで同意します。

   4. [購入して開始] をクリックします。表示されるメッセージで、[OK] をクリックします。

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

データ型マッピング

値の割り当ての例

{
  "_id":"62cd344c85c1ea6a2a9f****",
  "person":{
    "name":"neo",
    "age":26,
    "sex":"male"
  }
}