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

前提条件

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

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

  説明

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

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

  重要

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

  • 宛先 ApsaraDB RDS 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: ソースデータベースで Change Streams (Change Streams) が有効になっている場合、このオプションがサポートされます。 説明 ソースデータベースが Amazon DocumentDB (非エラスティッククラスター) の場合、ChangeStream のみがサポートされます。 ソースデータベースの アーキテクチャ が シャードクラスター として選択されている場合、Shardアカウント と Shardパスワード を入力する必要はありません。
   	インスタンス ID	ソース ApsaraDB for MongoDB インスタンスの 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 データベースインスタンスを登録する」および「サードパーティクラウドサービスまたは自己管理データベースでホストされているデータベースを登録する」をご参照ください。
   	データベースタイプ	ターゲット データベースの種類です。MySQL を選択します。
   	アクセス方法	ターゲットデータベースのアクセス方法です。Alibaba Cloud インスタンス を選択します。
   	インスタンスのリージョン	デスティネーションの ApsaraDB RDS for MySQL インスタンスが存在するリージョンです。
   	Alibaba Cloud アカウント間でデータを複製	この例では、現在の Alibaba Cloud アカウントのデータベースインスタンスが使用されます。× を選択します。
   	RDS インスタンス ID	移行先 ApsaraDB RDS for MySQL インスタンスの ID です。
   	データベースアカウント	ターゲット ApsaraDB RDS for MySQL インスタンスのデータベースアカウント。アカウントに必要な権限については、このトピックの「データベースアカウントに必要な権限」セクションをご参照ください。
   	データベースのパスワード	データベース インスタンスにアクセスするために使用されるパスワードです。
   	暗号化	ソースデータベースインスタンスへの接続を暗号化するかどうかを指定します。ビジネス要件に基づいて、[非暗号化] または [SSL 暗号化] を選択します。このパラメーターを [SSL 暗号化] に設定する場合、DTS タスクを構成する前に、ApsaraDB RDS for MySQL インスタンスで SSL 暗号化を有効にする必要があります。詳細については、「クラウド証明書を使用して SSL 暗号化を有効にする」をご参照ください。

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

   説明

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

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

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

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

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

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

      設定	説明
      タスクのスケジュールに使用する専用クラスターの選択	デフォルトでは、専用のクラスターを指定しない場合、DTS はデータ移行タスクを共有クラスターにスケジュールします。データ移行タスクの安定性を向上させるには、専用のクラスターを購入します。詳細については、「DTS 専用クラスターとは」をご参照ください。
      失敗した接続の再試行時間	接続失敗時のリトライ時間の範囲。データ移行タスクの開始後にソースデータベースまたはターゲットデータベースへの接続に失敗した場合、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] をクリックします。

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

データ型マッピング

値の割り当ての例

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