すべてのプロダクト
Search
ドキュメントセンター

Data Transmission Service:RDS for MySQL インスタンスから ApsaraMQ for RocketMQ インスタンスへのデータ移行

最終更新日:Nov 21, 2025

Data Transmission Service (DTS) は、自己管理 MySQL データベースや RDS for MySQL インスタンスなどの MySQL データベースから ApsaraMQ for RocketMQ インスタンスへのデータ移行をサポートしています。このトピックでは、RDS for MySQL インスタンスからデータを移行する方法について説明します。

前提条件

  • サーバーレスインスタンスではない宛先の ApsaraMQ for RocketMQ インスタンスを作成済みであること。詳細については、「インスタンスの管理」または「インスタンスの管理」をご参照ください。

    説明

    ソースデータベースとターゲットデータベースでサポートされているバージョンの詳細については、「移行ソリューション」をご参照ください。

  • データを受信するために、宛先の ApsaraMQ for RocketMQ インスタンスに Topic を作成済みであること。詳細については、「Topic の管理」または「Topic の管理」をご参照ください。

    重要

    4.x シリーズのインスタンスの場合、[メッセージタイプ][パーティション順序指定メッセージ] に設定します。

    5.x シリーズのインスタンスの場合、[メッセージタイプ][順序指定メッセージ] に設定します。

注意事項

タイプ

説明

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

  • 帯域幅の要件: ソースデータベースをホストするサーバーには、十分なアウトバウンド帯域幅が必要です。そうでない場合、移行速度が影響を受けます。

  • 移行オブジェクト:

    • 移行するテーブルには、プライマリキーまたは一意制約が必要で、フィールドは一意でなければなりません。そうでない場合、ターゲットデータベースに重複データが存在する可能性があります。

    • テーブルレベルでデータを移行し、テーブルを編集する必要がある場合 (列名のマッピングなど)、1 つのデータ移行タスクでサポートされるテーブルは最大 1,000 個です。この制限を超えると、タスクの送信後にエラーが報告されます。この場合、テーブルを複数の移行タスクに分割するか、データベース全体を移行するタスクを構成します。

  • 増分移行を実行する場合、バイナリログに関して次の点に注意してください:

    • バイナリログを有効にする必要があります。`binlog_format` パラメーターは `row` に、`binlog_row_image` パラメーターは `full` に設定する必要があります。そうでない場合、事前チェックが失敗し、データ移行タスクを開始できません。

      重要

      ソースの自己管理 MySQL データベースが、各インスタンスがプライマリであり、もう一方のセカンダリでもあるデュアルプライマリクラスターにある場合は、`log_slave_updates` パラメーターを有効にする必要があります。これにより、DTS がすべてのバイナリログを取得できるようになります。

    • RDS for MySQL インスタンスのバイナリログは、少なくとも 3 日間保持する必要があります。7 日間保持することをお勧めします。自己管理 MySQL データベースのバイナリログは、少なくとも 7 日間保持する必要があります。そうでない場合、DTS はバイナリログを取得できないため失敗する可能性があります。極端な場合、これによりデータの不整合やデータ損失が発生する可能性があります。必要な期間よりも短いバイナリログ保持期間によって引き起こされる問題は、DTS サービスレベルアグリーメント (SLA) の対象外です。

      説明

      RDS for MySQL インスタンスのバイナリログの [保持期間] の設定方法の詳細については、「バイナリログの自動削除」をご参照ください。

  • 移行中にバイナリログに記録されない操作によるデータ変更は、ターゲットデータベースに移行されません。このような操作の例としては、物理バックアップを使用したデータ回復やカスケード操作があります。

    説明

    これが発生した場合、ビジネスが許すときに再度完全なデータ移行を実行できます。

  • ソースデータベースが MySQL 8.0.23 以降で、移行するデータに不可視列が含まれている場合、これらの列のデータは取得できないため、データが失われる可能性があります。

    説明
    • ALTER TABLE <table_name> ALTER COLUMN <column_name> SET VISIBLE; コマンドを実行して、不可視列を可視にすることができます。詳細については、「不可視列」をご参照ください。

    • プライマリキーのないテーブルは、自動的に不可視のプライマリキーを生成します。この不可視のプライマリキーも可視にする必要があります。詳細については、「生成された不可視のプライマリキー」をご参照ください。

その他の制限

  • サーバーレスの ApsaraMQ for RocketMQ インスタンスは宛先として使用できません。

  • データは、宛先の ApsaraMQ for RocketMQ インスタンスの特定の Topic にのみ移行できます。

    • 4.x シリーズのインスタンスの場合、宛先 Topic の [メッセージタイプ][パーティション順序指定メッセージ] である必要があります。

      宛先の ApsaraMQ for RocketMQ インスタンスがソースデータベースの インスタンスのリージョン とは異なるリージョンにある場合、DTS はパブリックエンドポイントを介して宛先の ApsaraMQ for RocketMQ インスタンスにアクセスします。これにより、データ転送コストが発生します。宛先の ApsaraMQ for RocketMQ インスタンスでパブリックアクセスが有効になっていることを確認する必要があります。

      説明
      • ApsaraMQ for RocketMQ コンソールの [インスタンス詳細] ページの [基本情報] タブでインターネットアクセスステータスを確認できます。

      • 宛先の ApsaraMQ for RocketMQ インスタンスのインターネットトラフィックコストの詳細については、「インターネットトラフィックの料金」をご参照ください。

    • 5.x シリーズのインスタンスでは、宛先 Topic の[メッセージタイプ][順序メッセージ]である必要があります。

  • 宛先の ApsaraMQ for RocketMQ インスタンスは、最大 4 MB のメッセージ本文サイズをサポートします。

  • DTS で宛先の ApsaraMQ for RocketMQ インスタンスのクラスをスペックアップまたはスペックダウンする場合、メッセージは以前とは異なる新しいルール構成で配信されます。

  • 完全なデータ移行中、DTS はソースデータベースとターゲットデータベースの読み取りおよび書き込みリソースを一部消費します。これにより、データベースの負荷が増加する可能性があります。データを移行する前に、ソースデータベースとターゲットデータベースのパフォーマンスを評価してください。両方のデータベースの CPU 負荷が 30% 未満の場合など、オフピーク時にデータ移行を実行することをお勧めします。

  • 完全移行では同時 INSERT 操作が行われるため、ターゲットデータベースでテーブルの断片化が発生します。完全移行が完了すると、ターゲットデータベースのテーブルストレージ領域はソースデータベースよりも大きくなります。

  • データ移行中は、pt-online-schema-change などのツールを使用して、ソースデータベースの移行オブジェクトに対してオンライン DDL 操作を実行しないでください。実行すると、移行が失敗します。

  • 移行中に DTS 以外のソースからターゲットデータベースにデータが書き込まれると、データの不整合が発生する可能性があります。

  • RDS for MySQL インスタンスで常時暗号化 (EncDB) 機能が有効になっている場合、完全なデータ移行はサポートされません。

    説明

    TDE (透過的データ暗号化) が有効になっている RDS for MySQL インスタンスは、完全なデータ移行と増分データ移行の両方をサポートします。

  • インスタンスに障害が発生した場合、DTS ヘルプデスクは 8 時間以内にインスタンスの回復を試みます。回復プロセス中に、インスタンスの再起動やパラメーターの調整などの操作が実行される場合があります。

    説明

    パラメーターが調整されるとき、DTS インスタンスのパラメーターのみが変更されます。データベースのパラメーターは変更されません。変更される可能性のあるパラメーターには、インスタンスパラメーターの変更で説明されているパラメーターが含まれますが、これらに限定されません。

特殊なケース

  • ソースデータベースが自己管理 MySQL データベースの場合:

    • 移行中にソースデータベースでプライマリ/セカンダリのスイッチオーバーが発生すると、移行タスクは失敗します。

    • DTS の遅延は、最後に移行されたデータレコードのタイムスタンプと現在のタイムスタンプを比較して計算されます。ソースデータベースで DML 操作が長時間実行されない場合、遅延情報が不正確になることがあります。表示される遅延が長すぎる場合は、ソースデータベースで DML 操作を実行して遅延情報を更新できます。

      説明

      データベース全体を移行することを選択した場合は、ハートビートテーブルを作成することもできます。ハートビートテーブルは、1 秒ごとに更新または書き込みが行われます。

    • DTS は、ソースデータベースで定期的に CREATE DATABASE IF NOT EXISTS `test` コマンドを実行して、バイナリログのオフセットを進めます。

    • ソースデータベースが Amazon Aurora MySQL インスタンスまたは他のクラスター化された MySQL インスタンスである場合、タスクに構成されたドメイン名または IP アドレスとその解決結果が常に読み取り/書き込み (RW) ノードを指すようにしてください。そうでない場合、移行タスクが期待どおりに実行されない可能性があります。

  • ソースデータベースが RDS for MySQL インスタンスの場合:

    • 増分データを移行するために、RDS for MySQL 5.6 の読み取り専用インスタンスなど、トランザクションログを記録しない RDS for MySQL インスタンスは、ソースデータベースとして使用できません。

    • DTS は、ソースデータベースで定期的に CREATE DATABASE IF NOT EXISTS `test` コマンドを実行して、バイナリログのオフセットを進めます。

課金

移行タイプ

インスタンス構成料金

完全なデータ移行

無料。

増分データ移行

有料。詳細については、「課金の概要」をご参照ください。

増分移行可能な SQL 操作

操作タイプ

SQL 文

DML

INSERT、UPDATE、DELETE

DDL

  • CREATE TABLE、ALTER TABLE、DROP TABLE、RENAME TABLE、TRUNCATE TABLE

  • CREATE VIEW、ALTER VIEW、DROP VIEW

  • CREATE PROCEDURE、ALTER PROCEDURE、DROP PROCEDURE

  • CREATE FUNCTION、DROP FUNCTION、CREATE TRIGGER、DROP TRIGGER

  • CREATE INDEX、DROP INDEX

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

データベース

必要な権限

権限の作成と付与の方法

ソース RDS for MySQL

移行オブジェクトに対する読み取り権限。

アカウントの作成 および アカウント権限の変更

説明

ソースデータベースのデータベースアカウントが RDS for MySQL コンソールで作成および承認されていない場合は、そのアカウントに REPLICATION CLIENT、REPLICATION SLAVE、SHOW VIEW、および SELECT 権限があることを確認してください。

手順

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

    DTS コンソール

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

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

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

    DMS コンソール

    説明

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

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

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

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

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

  3. ソースデータベースとターゲットデータベースを構成します。次の表にパラメーターを示します。

    カテゴリ

    構成

    説明

    N/A

    タスク名

    DTS タスクの名前。DTS は自動的にタスク名を生成します。タスクを簡単に識別できるような情報を含む名前を指定することをお勧めします。一意のタスク名を指定する必要はありません。

    移行元データベース

    既存の接続情報の選択

    • DTS に登録されているデータベースインスタンスを使用する場合は、ドロップダウンリストからインスタンスを選択します。DTS は、インスタンスの次のデータベースパラメーターを自動的に入力します。詳細については、「データベース接続の管理」をご参照ください。

      説明

      DMS コンソールでは、[DMS データベースインスタンスの選択] ドロップダウンリストからデータベースインスタンスを選択できます。

    • インスタンスを DTS に登録できない場合、または DTS に登録されているインスタンスを使用する必要がない場合は、次のデータベース情報を構成する必要があります。

    データベースタイプ

    MySQL を選択します。

    アクセス方法

    Alibaba Cloud インスタンス を選択します。

    インスタンスのリージョン

    ソース RDS for MySQL インスタンスが存在するリージョンを選択します。

    Alibaba Cloud アカウント間でデータを複製

    この例では、現在の Alibaba Cloud アカウントのデータベースインスタンスが使用されます。× を選択します。

    RDS インスタンス ID

    ソース RDS for MySQL インスタンスの ID を選択します。

    データベースアカウント

    ソース RDS for MySQL インスタンスのデータベースアカウントを入力します。権限要件については、「データベースアカウントに必要な権限」をご参照ください。

    データベースのパスワード

    データベースインスタンスへのアクセスに使用するパスワード。

    暗号化

    データベースへの接続を暗号化するかどうかを指定します。ビジネス要件に基づいて [非暗号化] または [SSL 暗号化] を選択できます。このパラメーターを [SSL 暗号化] に設定する場合は、DTS タスクを構成する前に ApsaraDB RDS for MySQL インスタンスの SSL 暗号化を有効にする必要があります。詳細については、「クラウド証明書を使用して SSL 暗号化を有効にする」をご参照ください。

    移行先データベース

    既存の接続情報の選択

    • DTS に登録されているデータベースインスタンスを使用する場合は、ドロップダウンリストからインスタンスを選択します。DTS は、インスタンスの次のデータベースパラメーターを自動的に入力します。詳細については、「データベース接続の管理」をご参照ください。

      説明

      DMS コンソールでは、[DMS データベースインスタンスの選択] ドロップダウンリストからデータベースインスタンスを選択できます。

    • インスタンスを DTS に登録できない場合、または DTS に登録されているインスタンスを使用する必要がない場合は、次のデータベース情報を構成する必要があります。

    データベースタイプ

    RocketMQ を選択します。

    アクセス方法

    Alibaba Cloud インスタンス を選択します。

    インスタンスのリージョン

    宛先の ApsaraMQ for RocketMQ インスタンスが存在するリージョンを選択します。

    RocketMQ バージョン

    宛先の ApsaraMQ for RocketMQ インスタンスのバージョンを選択します。

    インスタンス ID

    宛先の ApsaraMQ for RocketMQ インスタンスの ID を選択します。

    データベースアカウント

    宛先の ApsaraMQ for RocketMQ インスタンスのデータベースアカウントとパスワードを入力します。

    説明
    • これらのパラメーターは、RocketMQ バージョン[5.x] に設定した場合にのみ必要です。

    • 認証情報は、ApsaraMQ for RocketMQ コンソールの [アクセス制御] ページの [インテリジェント ID 認識] タブで取得できます。

    データベースのパスワード

    トピック

    ドロップダウンリストから、データを受信する Topic を選択します。

    DDL 情報を格納するトピック

    ドロップダウンリストから、DDL 情報を格納する Topic を選択します。

    説明

    Topic を選択しない場合、DDL 情報は トピック パラメーターで選択された Topic に格納されます。

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

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

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

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

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

      構成

      説明

      移行タイプ

      • 完全なデータ移行のみを実行するには、[完全なデータ移行] のみを選択します。

      • データ移行中のサービス継続性を確保するには、[完全なデータ移行][増分データ移行] を選択します。

      説明

      [増分データ移行] を選択しない場合は、データ移行中にソースデータベースにデータを書き込まないことをお勧めします。これにより、ソースデータベースとターゲットデータベース間のデータ整合性が確保されます。

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

      • エラーの事前チェックと報告: ターゲットデータベースにソースデータベースのテーブルと同じ名前のテーブルが含まれているかどうかをチェックします。ソースデータベースとターゲットデータベースに同じテーブル名のテーブルが含まれていない場合、事前チェックは合格します。それ以外の場合、事前チェック中にエラーが返され、データ移行タスクを開始できません。

        説明

        ソースデータベースとターゲットデータベースに同じ名前のテーブルが含まれており、ターゲットデータベースのテーブルを削除または名前変更できない場合は、オブジェクト名マッピング機能を使用して、ターゲットデータベースに移行されるテーブルの名前を変更できます。詳細については、「オブジェクト名のマッピング」をご参照ください。

      • エラーを無視して続行: ソースデータベースとターゲットデータベースの同一テーブル名の事前チェックをスキップします。

        警告

        エラーを無視して続行 を選択すると、データの不整合が発生し、ビジネスに次の潜在的なリスクが生じる可能性があります。

        • ソースデータベースとターゲットデータベースのスキーマが同じで、データレコードのプライマリキーがターゲットデータベースの既存のデータレコードと同じ場合、次のシナリオが発生する可能性があります。

          • 完全なデータ移行中、DTS はデータレコードをターゲットデータベースに移行しません。ターゲットデータベースの既存のデータレコードは保持されます。

          • 増分データ移行中、DTS はデータレコードをターゲットデータベースに移行します。ターゲットデータベースの既存のデータレコードは上書きされます。

        • ソースデータベースとターゲットデータベースのスキーマが異なる場合、特定の列のみが移行されるか、データ移行タスクが失敗します。注意して進めてください。

      RocketMQ に配信されるデータ形式

      宛先 Topic に書き込まれるデータに必要なストレージフォーマットを選択します。詳細については、「メッセージキューのデータフォーマット」をご参照ください。

      すべてのフィールドを同期する

      ソースオブジェクトから更新されたフィールドのプリイメージのみを宛先 Topic の old フィールドに移行するかどうかを指定します。プリイメージは、レコードが更新される前のデータです。

      説明

      この設定項目は、RocketMQ に配信されるデータ形式[Canal JSON] に設定した場合にのみ利用可能になります。

      • : `UPDATE` 文によって行内のフィールドが更新されたときに、その行全体のプリイメージを移行します。

      • × (デフォルト): `UPDATE` 文で更新されたフィールドのプリイメージのみを移行します。

      RocketMQ に配信されるメッセージ順序のルール

      宛先 Topic にデータを書き込むために必要なメッセージ順序ルールを選択します。詳細については、「RocketMQ のメッセージ順序ルール」をご参照ください。

      DTS プロデューサーグループ名

      宛先 Topic にメッセージを送信する必要なプロデューサーグループ (ProducerGroup) を設定します。詳細については、「プロデューサー」をご参照ください。

      説明

      デフォルト値は dts-producer-group です。

      RocketMQ メッセージ送受信の TPS 制限

      宛先 Topic にデータが書き込まれる際の、1 秒あたりの最大メッセージングトランザクション数 (TPS) を設定できます。メッセージング TPS の詳細については、「コンピューティング仕様」をご参照ください。

      重要
      • 値は、ApsaraMQ for RocketMQ インスタンスの最大 TPS 以下である必要があります。詳細については、「インスタンスタイプの制限」をご参照ください。

      • 移行インスタンスの実行中、ApsaraMQ for RocketMQ インスタンスの実際のメッセージ TPS は、設定値の前後でわずかに変動する場合があります。

      大規模なレコードのフィルタリングを設定するかどうか

      4 MB を超えるメッセージ本文が宛先 Topic に書き込まれるのを防ぐかどうかを選択します。

      重要

      × を選択し、宛先 Topic に書き込まれたメッセージ本文が 4 MB を超えると、移行インスタンスは失敗します。

      移行先インスタンスでのオブジェクト名の大文字化

      宛先インスタンスのデータベース名、テーブル名、列名の大文字/小文字。デフォルトでは、[DTS のデフォルトポリシー] が選択されています。他のオプションを選択して、オブジェクト名の大文字/小文字がソースまたはターゲットデータベースのものと一致するようにすることができます。詳細については、「宛先インスタンスのオブジェクト名の大文字/小文字を指定する」をご参照ください。

      ソースオブジェクト

      ソースオブジェクト セクションから 1 つ以上のオブジェクトを選択します。向右小箭头 アイコンをクリックして、オブジェクトを 選択中のオブジェクト セクションに追加します。

      説明

      オブジェクトはデータベースまたはテーブルレベルで選択できます。

      選択中のオブジェクト

      この例では追加の構成は必要ありません。マッピング機能を使用して、宛先の ApsaraMQ for RocketMQ インスタンスの Topic 名を設定したり、フィルター条件を設定したり、移行する SQL 操作を選択したり、パーティションキーを設定したりできます。詳細については、「マッピング情報」をご参照ください。

    2. 詳細設定へ をクリックして詳細設定を構成します。

      構成

      説明

      タスクのスケジュールに使用する専用クラスターの選択

      専用クラスターを指定しない場合、DTS はデフォルトでデータ移行タスクを共有クラスターにスケジュールします。データ移行タスクの安定性を向上させたい場合は、専用クラスターを購入してください。詳細については、「DTS 専用クラスターとは」をご参照ください。

      失敗した接続の再試行時間

      失敗した接続のリトライ時間範囲。データ移行タスクの開始後にソースまたはターゲットデータベースへの接続に失敗した場合、DTS はリトライ時間範囲内で直ちに接続をリトライします。有効値: 10 から 1,440。単位: 分。デフォルト値: 720。パラメーターを 30 より大きい値に設定することをお勧めします。指定されたリトライ時間範囲内に DTS がソースおよびターゲットデータベースに再接続されると、DTS はデータ移行タスクを再開します。それ以外の場合、データ移行タスクは失敗します。

      説明
      • 同じソースまたはターゲットデータベースを共有する複数のデータ移行タスクに異なるリトライ時間範囲を指定した場合、後で指定された値が優先されます。

      • DTS が接続をリトライしている間、DTS インスタンスに対して課金されます。ビジネス要件に基づいてリトライ時間範囲を指定することをお勧めします。また、ソースデータベースとターゲットインスタンスがリリースされた後、できるだけ早く DTS インスタンスをリリースすることもできます。

      移行元データベースと移行先データベースで他の問題が発生した場合の、再試行までの待機時間です。

      その他の問題のリトライ時間範囲。たとえば、データ移行タスクの開始後に DDL または DML 操作の実行に失敗した場合、DTS はリトライ時間範囲内で直ちに操作をリトライします。有効値: 1 から 1440。単位: 分。デフォルト値: 10。パラメーターを 10 より大きい値に設定することをお勧めします。指定されたリトライ時間範囲内に失敗した操作が正常に実行されると、DTS はデータ移行タスクを再開します。それ以外の場合、データ移行タスクは失敗します。

      重要

      移行元データベースと移行先データベースで他の問題が発生した場合の、再試行までの待機時間です。 パラメーターの値は、失敗した接続の再試行時間 パラメーターの値より小さくする必要があります。

      完全移行率を制限するかどうか

      完全なデータ移行のスロットリングを有効にするかどうかを指定します。完全なデータ移行中、DTS はソースデータベースとターゲットデータベースの読み取りおよび書き込みリソースを使用します。これにより、データベースサーバーの負荷が増加する可能性があります。ビジネス要件に基づいて、完全なデータ移行のスロットリングを有効にすることができます。スロットリングを構成するには、1 秒あたりのソースデータベースのクエリ率 QPS1 秒あたりの完全移行の行数 RPS、および 1 秒あたりの完全移行データ量 (MB) BPS パラメーターを構成する必要があります。これにより、ターゲットデータベースサーバーの負荷が軽減されます。

      説明

      このパラメーターは、移行タイプ パラメーターで 完全データ移行 を選択した場合にのみ構成できます。

      増分移行率を制限するかどうか

      増分データ移行のスロットリングを有効にするかどうかを指定します。スロットリングを構成するには、1 秒あたりの増分移行の行数 RPS および 1 秒あたりの増分移行データ量 (MB) BPS パラメーターを構成する必要があります。これにより、ターゲットデータベースサーバーの負荷が軽減されます。

      説明

      このパラメーターは、移行タイプ パラメーターで 増分データ移行 を選択した場合にのみ構成できます。

      順方向および逆方向タスクのハートビートテーブル SQL を削除

      DTS インスタンスの実行中に、ハートビートテーブルに対する SQL 操作をソースデータベースに書き込むかどうかを指定します。有効値:

      • [はい]: ハートビートテーブルに対する SQL 操作を書き込みません。この場合、DTS インスタンスの遅延が表示されることがあります。

      • [いいえ]: ハートビートテーブルに対する SQL 操作を書き込みます。この場合、ソースデータベースの物理バックアップやクローニングなどの機能が影響を受ける可能性があります。

      環境タグ

      必要に応じて、インスタンスを識別するための環境タグを選択できます。この例では選択は不要です。

      ETL の設定

      抽出・変換・書き出し (ETL) 機能を有効にするかどうかを指定します。詳細については、「ETL とは」をご参照ください。有効値:

      監視アラート

      データ移行タスクのアラートを構成するかどうかを指定します。タスクが失敗した場合、または移行遅延が指定されたしきい値を超えた場合、アラート連絡先は通知を受け取ります。有効値:

      • [いいえ]: アラートを構成しません。

      • [はい]: アラートを構成します。この場合、アラートのしきい値と アラート通知設定も構成する必要があります。詳細については、「モニタリングとアラートの構成」トピックの「DTS タスク作成時のモニタリングとアラートの構成」セクションをご参照ください。

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

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

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

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

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

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

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

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

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

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

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

      セクション

      パラメーター

      説明

      新しいインスタンスクラス

      [リソースグループ]

      データ移行インスタンスが属するリソースグループ。デフォルト値: [デフォルトリソースグループ]。詳細については、「Resource Management とは」をご参照ください。

      インスタンスクラス

      DTS は、移行速度が異なるインスタンスクラスを提供します。ビジネスシナリオに基づいてインスタンスクラスを選択できます。詳細については、「データ移行インスタンスのインスタンスクラス」をご参照ください。

    3. チェックボックスをオンにして、[Data Transmission Service (Pay-as-you-go) サービス規約]を読んで同意します。

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

      [データ移行] ページでタスクの進行状況を表示できます。

      説明
      • データ移行タスクが増分データの移行に使用できない場合、タスクは自動的に停止します。[ステータス] セクションに [完了] が表示されます。

      • データ移行タスクが増分データの移行に使用できる場合、タスクは自動的に停止しません。増分データ移行タスクは停止も完了もしません。[ステータス] セクションに [実行中] が表示されます。

マッピング情報

  1. 選択中のオブジェクト リストボックスで、宛先 Topic の上にマウスポインターを置きます。

  2. Topic 名の横にある 編集 をクリックします。

  3. 表示されるダイアログボックスで、マッピング情報を構成します。

    説明
    • データベースレベルとテーブルレベルの両方でマッピングを有効にした場合、テーブルレベルのマッピングが優先されます。データベースレベルのマッピングは有効になりません。

    • スキーマの編集 ダイアログボックスはデータベースレベルのマッピングに使用されます。テーブルの編集 ダイアログボックスはテーブルレベルのマッピングに使用されます。

    データベースレベル

    構成

    説明

    スキーマ名

    データが書き込まれる宛先 Topic の名前。デフォルトでは、これは ソースデータベースとターゲットデータベースの設定 ページの 移行先データベース セクションで選択した トピック です。

    重要
    • データが書き込まれる宛先 Topic の名前。デフォルトでは、これは ソースデータベースとターゲットデータベースの設定 ページの 移行先データベース セクションで選択した トピック です。

    • スキーマ名 を変更すると、データは入力した Topic に書き込まれます。

    同期する DDL および DML 操作を選択

    必要に応じて、増分移行する SQL 操作を選択します。

    テーブルレベル

    構成

    説明

    テーブル名

    データが書き込まれる宛先 Topic の名前。デフォルトでは、これは ソースデータベースとターゲットデータベースの設定 ページの 移行先データベース セクションで選択した トピック です。

    重要
    • 指定した Topic 名は、宛先の ApsaraMQ for RocketMQ インスタンスに存在する必要があります。そうでない場合、データ移行は失敗します。

    • テーブル名 を変更すると、データは入力した Topic に書き込まれます。

    フィルタリング条件

    詳細については、「フィルター条件の設定」をご参照ください。

    同期する DDL および DML 操作を選択

    必要に応じて、増分移行する SQL 操作を選択します。

    パーティションキー

    RocketMQ に配信されるメッセージ順序のルール指定した列のハッシュ値による配信 に設定されている場合、このパラメーターを構成できます。ハッシュ値を計算するために、1 つ以上の列をパーティションキーとして指定します。DTS は、計算されたハッシュ値に基づいて、宛先 Topic の異なるパーティションに行を配信します。

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