Data Transmission Service:ApsaraDB for MongoDB レプリカセットインスタンス間の双方向データ同期の設定

仕組み

双方向同期インスタンスは、次の 2 つのタスクで構成されます：

1. フォワードタスク：インスタンス A からインスタンス B にデータを同期します。スキーマ同期、完全データ同期、増分データ同期を処理します。

2. リバースタスク：インスタンス B からインスタンス A にデータを同期します。増分データ同期のみを処理します。

フォワードタスクの設定 --> 事前チェック --> 購入 --> フォワードタスク実行中
                                                         |
                                       リバースタスクの設定 --> 事前チェック --> リバースタスク実行中
                                                                                     |
                                                                   両方のタスクが実行中 = 双方向同期がアクティブ

前提条件

開始する前に、以下を確認してください：

• ソースとターゲットの ApsaraDB for MongoDB レプリカセットインスタンスが作成されていること。詳細については、「レプリカセットインスタンスの作成」をご参照ください。サポートされているデータベースのバージョンについては、「データ同期シナリオの概要」をご参照ください。

• ターゲットインスタンスには、ソースインスタンスの総データサイズよりも少なくとも 10% 多くの利用可能なストレージがあること。

• ソースとターゲットの両方のインスタンスで、replication.oplogGlobalIdEnabled パラメーターが true に設定されていること。詳細については、「インスタンスのデータベースパラメーターの設定」をご参照ください。

ステップ 1：データ同期ページを開く

以下のいずれかの方法でデータ同期ページに移動します：

DTS コンソール

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

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

3. 左上隅で、データ同期タスクが存在するリージョンを選択します。

DMS コンソール

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

2. 上部のナビゲーションバーで、データ + AI にポインターを合わせ、DTS (DTS) > データ同期 を選択します。

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

ステップ 2：フォワード同期タスクの作成と設定

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

2. (オプション) 右上隅の 新しい設定ページ をクリックします。

   説明

   以前のバージョンに戻る ボタンが表示されている場合は、このステップをスキップしてください。新しいバージョンの設定ページを推奨します。

3. 以下のパラメーターでソースデータベースとターゲットデータベースを設定します。

   ソースデータベース

   パラメーター	説明
   タスク名	DTS が自動的に名前を生成します。タスクを簡単に識別できるように、わかりやすい名前を指定してください。一意の名前は必要ありません。
   既存の接続を選択	データベースインスタンスが DTS に登録済みの場合は、ドロップダウンリストから選択してください。DTS により残りのパラメーターが自動的に設定されます。詳細については、「データベース接続の管理」をご参照ください。インスタンスが登録されていない場合は、以下のパラメーターを設定してください。
   データベースタイプ	MongoDB を選択します。
   アクセス方法	Alibaba Cloud インスタンス を選択します。
   インスタンスリージョン	ソース ApsaraDB for MongoDB インスタンスのリージョンを選択します。
   Alibaba Cloud アカウント間でのデータレプリケーション	いいえ を選択します。
   アーキテクチャ	レプリカセット を選択します。
   移行方法	Oplog を選択します。
   インスタンス ID	ソース ApsaraDB for MongoDB インスタンスを選択します。
   認証データベース	アカウントの認証情報を保存するデータベース。デフォルト：admin。
   データベースアカウント	ソースインスタンスのデータベースアカウント。アカウントには、ソースデータベース、config データベース、admin データベース、および local データベースに対する読み取り権限が必要です。詳細については、「DMS を使用したデータベースアカウントの管理」をご参照ください。
   データベースパスワード	データベースアカウントのパスワード。
   暗号化	要件に応じて、非暗号化、SSL 暗号化、または Mongo Atlas SSL を選択します。利用可能なオプションは、アクセス方法 と アーキテクチャ の設定によって異なります。アーキテクチャ が シャードクラスター で、移行方法 が Oplog の場合、SSL 暗号化 は利用できません。

   ターゲットデータベース

   パラメーター	説明
   既存の接続を選択	データベースインスタンスが DTS に登録済みの場合、ドロップダウンリストからそのインスタンスを選択します。DTS により残りのパラメーターが自動的に入力されます。詳細については、「データベース接続の管理」をご参照ください。インスタンスが登録されていない場合は、以下のパラメーターを設定してください。
   データベースタイプ	MongoDB を選択します。
   アクセス方法	Alibaba Cloud インスタンス を選択します。
   インスタンスリージョン	ターゲット ApsaraDB for MongoDB インスタンスのリージョンを選択します。
   Alibaba Cloud アカウント間でのデータレプリケーション	いいえ を選択します。
   アーキテクチャ	レプリカセット を選択します。
   インスタンス ID	ターゲット ApsaraDB for MongoDB インスタンスを選択します。
   認証データベース	アカウントの認証情報を保存するデータベース。デフォルト：admin。
   データベースアカウント	ターゲットインスタンスのデータベースアカウント。アカウントには、dbAdminAnyDatabase 権限、ターゲットデータベースに対する読み取り/書き込み権限、および local データベースに対する読み取り権限が必要です。詳細については、「DMS を使用したデータベースアカウントの管理」をご参照ください。
   データベースパスワード	データベースアカウントのパスワード。
   暗号化	要件に応じて、非暗号化、SSL 暗号化、または Mongo Atlas SSL を選択します。利用可能なオプションは、アクセス方法 と アーキテクチャ の設定によって異なります。ターゲットが アーキテクチャ を シャードクラスター に設定した ApsaraDB for MongoDB インスタンスの場合、SSL 暗号化 は利用できません。

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

   説明

   DTS サーバーの CIDR ブロックが、ソースおよびターゲットデータベースのセキュリティ設定に追加されていることを確認してください。詳細については、「DTS サーバーの CIDR ブロックを追加する」をご参照ください。

ステップ 3：同期オブジェクトの設定

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

   パラメーター	説明
   同期タイプ	増分データ同期 がデフォルトで選択されています。スキーマ同期 および フルデータ同期 も選択してください。
   競合テーブルの処理モード	事前チェックしてエラーを報告：ソースとターゲットに同名のコレクションが存在するかをチェックします。同名のコレクションが存在する場合、エラーが返され、タスクを開始できません。競合を解決するには、オブジェクト名マッピング を使用してコレクション名を変更してください。エラーを無視して続行：同名チェックをスキップします。ターゲットに同じプライマリキーまたはユニークキー値を持つレコードが存在する場合、DTS はそのレコードを同期せず、既存のデータを保持します。この場合、データの初期化に失敗したり、特定の列のみが同期されたり、データ同期インスタンスが失敗したりする可能性があります。
   同期トポロジー	双方向同期 を選択します。
   DDL 操作の除外	はい：DDL 操作を除外します。いいえ：DDL 操作を同期します。安定性を維持するため、DDL 操作は転送方向でのみ同期されます。
   競合解決ポリシー	無視（固定値）に設定します。ターゲットデータベース内の競合レコードは保持されます。詳細については、「競合解決」をご参照ください。
   宛先インスタンスにおけるオブジェクト名の大文字・小文字の扱い	デフォルト：DTS デフォルトポリシー。ソースまたはターゲットデータベースのオブジェクト名の大文字・小文字の扱いに合わせるには、他のオプションを選択します。詳細については、「宛先インスタンスにおけるオブジェクト名の大文字・小文字の扱いの指定」をご参照ください。
   ソースオブジェクト	ソースオブジェクト パネルからデータベースまたはコレクションを選択し、右向き矢印アイコンをクリックして 選択済みオブジェクト パネルに追加します。
   選択済みオブジェクト	オブジェクトを右クリックして、ターゲットデータベースでの名前変更や特定のターゲットオブジェクトへのマッピングを行います。詳細については、「オブジェクト名のマッピング」をご参照ください。オブジェクトを削除するには、該当オブジェクトを選択して左向き矢印アイコンをクリックします。データベースまたはコレクション単位で増分データを同期するには、選択済みオブジェクト を右クリックし、表示されるダイアログボックスで操作を選択します。フルデータ同期中にデータをフィルターするには、コレクションを右クリックしてフィルター条件を設定します。詳細については、「フィルター条件の指定」をご参照ください。オブジェクト名マッピングを使用してデータベースまたはコレクションの名前を変更した場合、依存オブジェクトの同期に失敗する可能性があります。

2. 次へ：詳細設定 をクリックし、以下のパラメーターを設定します。

   パラメーター	説明
   タスクスケジューリング用の専用クラスター	デフォルトでは、タスクは共有クラスターで実行されます。安定性を向上させるには、専用クラスターの購入を推奨します。詳細については、「DTS 専用クラスターとは」をご参照ください。
   接続失敗時のリトライ時間	接続失敗時のリトライ時間範囲。有効値：10～1440 分。デフォルト：720。30 より大きい値を設定してください。DTS が指定時間内に再接続すると、タスクは再開されます。そうでない場合、タスクは失敗します。複数のタスクがソースまたはターゲットデータベースを共有する場合、最も短いリトライ時間が優先されます。DTS はリトライ中のインスタンスに対して課金します。
   その他の問題に対するリトライ時間	失敗した DDL または DML 操作のリトライ時間範囲。有効値：1～1440 分。デフォルト：10。10 より大きい値を設定してください。この値は 接続失敗時のリトライ時間 よりも小さくする必要があります。
   完全データ同期のスロットリングを有効にする	ソースデータベースへの秒間クエリ数 (QPS)、完全データ移行の RPS、および 完全移行のデータ移行速度 (MB/s) を設定して、ターゲットサーバーの負荷を軽減します。完全データ同期 が選択されている場合にのみ利用可能です。
   同期対象データのテーブル内のプライマリキー _id のデータ型は 1 つのみ	各コレクションでプライマリキー _id のデータ型が一意であるかどうか。はい：DTS は _id のデータ型をスキャンせず、コレクションごとに 1 つのデータ型のみを同期します。いいえ：DTS は _id のデータ型をスキャンし、一致するすべてのデータを同期します。データに基づいて設定してください。完全データ同期 が選択されている場合にのみ表示されます。
   増分データ同期のスロットリングを有効にする	増分データ同期の RPS と 増分同期のデータ同期速度 (MB/s) を設定して、ターゲットサーバーの負荷を軽減します。
   環境タグ	DTS インスタンスを識別するための環境タグ。オプション。
   ETL の設定	はい: ETL (抽出・変換・書き出し) を設定します。詳細については、「ETL とは？」および「データ同期タスクで ETL を設定する」をご参照ください。いいえ: ETL を設定しません。
   モニタリングとアラート	[はい]: タスクの失敗または同期遅延に対するアラートしきい値および通知設定を構成します。詳細については、「モニタリングおよびアラート設定の構成」をご参照ください。[いいえ]: アラート機能を有効にしません。

3. [次のステップ：データ検証] をクリックして、データ検証を設定します。詳細については、「データ検証タスクを設定する」をご参照ください。

ステップ 4：事前チェックの実行とインスタンスの購入

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

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

   • 次へ：タスク設定を保存して事前チェック をクリックします。

   説明

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

   • 事前チェックが失敗した場合は、失敗した項目の横にある 詳細の表示 をクリックし、問題をトラブルシューティングして事前チェックを再実行します。

   • アラートがトリガーされた場合：無視できない項目については、トラブルシューティングを行い、事前チェックを再実行します。無視できる項目については、アラート詳細の確認 をクリックし、次に 無視、次に OK をクリックして、事前チェックを再実行します。アラートを無視すると、データの不整合が発生する可能性があります。

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

3. 購入ページで、インスタンスを設定します。

   パラメーター	説明
   課金方法	サブスクリプション：長期利用に向け、事前に料金を支払います。従量課金：1 時間単位で課金されます。短期利用に適しています。不要になった場合は、インスタンスをリリースしてください。
   リソースグループ設定	インスタンスのリソースグループです。デフォルト：デフォルトリソースグループ。詳細については、「What is Resource Management?
   インスタンスクラス	同期速度の要件に基づき、インスタンスクラスを選択します。詳細については、「Instance classes of data synchronization instances」をご参照ください。
   サブスクリプション期間	サブスクリプションでのみ利用可能です。有効値：1～9 か月、または 1 年、2 年、3 年、5 年。

4. Data Transmission Service (従量課金) サービス規約 を読み、選択します。

5. 購入して開始 をクリックします。ダイアログボックスで OK をクリックします。フォワード同期タスクがタスクリストに表示されます。

ステップ 5：リバース同期タスクの設定

1. 初期同期が完了し、フォワード同期タスクのステータスが 実行中 に変わるまで待ちます。

2. タスクリストでリバース同期タスクを見つけ、タスクの設定 をクリックします。

3. ステップ 2 (サブステップ 3 以降)、ステップ 3、およびステップ 4 の事前チェックの設定サブステップを繰り返し、以下の調整を加えてリバース同期タスクを設定します：

   説明

   リバースタスクは、フォワードタスクを購入する際に自動的に作成されます。タスクの作成 (ステップ 2、サブステップ 1) をクリックしたり、新しいインスタンスを購入したり (ステップ 4、サブステップ 3 以降) する必要はありません。

   重要

   - リバース方向のソースインスタンスは、フォワード方向のターゲットインスタンスであり、その逆も同様です。データベース名、アカウント、パスワードがそれに応じて設定されていることを確認してください。 - リバース方向ではオブジェクト名マッピングを使用しないでください。そうしないと、データの不整合が発生する可能性があります。 - インスタンスリージョン はリバース方向では変更できません。コンソールに表示されるパラメーターのみを設定してください。 - 競合するテーブルの処理モード については、フォワードタスクによって既にターゲットに同期されたコレクションが無視されるようにしてください。 - フォワードタスクで使用された 選択したオブジェクト リストから同じオブジェクトを選択することはできません。 - リバースタスクは DDL 操作を無視します。

4. 成功率 が 100% に達するまで待ち、戻る をクリックします。

ステップ 6：同期ステータスの確認

フォワードとリバースの両方の同期タスクが 実行中 状態になると、双方向データ同期がアクティブになります。タスクリストでタスクのステータスを監視します。

課金

制限事項