すべてのプロダクト
Search

このプロダクト

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

    ドキュメントセンター

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

    最終更新日:Jun 11, 2025

    このトピックでは、Data Transmission Service (DTS) を使用して ApsaraDB RDS for MySQL インスタンスから ApsaraMQ for Kafka インスタンスにデータを移行する方法について説明します。

    前提条件

    • ソース ApsaraDB RDS for MySQL インスタンスと宛先 ApsaraMQ for Kafka インスタンスが作成されている。

      説明

    • 宛先 ApsaraMQ for Kafka インスタンスの使用可能なストレージ容量が、ソース ApsaraDB RDS for MySQL インスタンスのデータの合計サイズよりも大きい。

    • 宛先 ApsaraMQ for Kafka インスタンスで、移行されたデータを受信するためのトピックが作成されている。詳細については、「手順 3: リソースの作成」トピックの「手順 1: トピックの作成」セクションをご参照ください。

    制限事項

    説明

    DTS は、ソースデータベースの外部キーを宛先データベースに移行しません。そのため、ソースデータベースのカスケード操作と削除操作は宛先データベースに移行されません。

    カテゴリ

    説明

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

    • ソースデータベースがデプロイされているサーバーには、十分なアウトバウンド帯域幅が必要です。そうでない場合、データ移行速度が低下します。

    • 移行するテーブルには、PRIMARY KEY または UNIQUE 制約があり、すべてのフィールドが一意である必要があります。そうでない場合、宛先データベースに重複したデータレコードが含まれる可能性があります。

    • 移行対象としてテーブルを選択し、宛先データベースのテーブル（テーブル名や列名の変更など）を変更する場合、1 つのデータ移行タスクで最大 1,000 個のテーブルを移行できます。1,000 個を超えるテーブルを移行するタスクを実行すると、リクエストエラーが発生します。この場合、複数のタスクを構成してテーブルを移行するか、データベース全体を移行するタスクを構成することをお勧めします。

    • 増分データを移行する場合、バイナリログに関する次の要件を満たす必要があります。

      • バイナリロギング機能が有効になっている。 binlog_format パラメータが row に設定され、binlog_row_image パラメータが full に設定されている。そうでない場合、事前チェック中にエラーメッセージが返され、データ移行タスクが開始できません。

        重要

        ソースデータベースがデュアルプライマリクラスターにデプロイされた自己管理 MySQL データベースの場合、log_slave_updates パラメータを ON に設定する必要があります。これにより、DTS がすべてのバイナリログを取得できるようになります。

      • ApsaraDB RDS for MySQL インスタンスのバイナリログは、少なくとも 3 日間保存する必要があります。バイナリログは 7 日間保存することをお勧めします。自己管理 MySQL データベースのバイナリログは、少なくとも 7 日間保存する必要があります。そうでない場合、DTS がバイナリログを取得できず、タスクが失敗する可能性があります。例外的な状況では、データの不整合または損失が発生する可能性があります。上記の要件に基づいてバイナリログの保存期間を構成してください。そうでない場合、DTS のサービスレベル契約 (SLA) に記載されているサービスの信頼性またはパフォーマンスが保証されない場合があります。

        説明

        ApsaraDB RDS for MySQL インスタンスのバイナリログの [保存期間] を設定する方法の詳細については、「RDS インスタンスのバイナリログファイルをシステムが自動的に削除するパラメータを構成する」をご参照ください。

    • ソースデータベースで実行される操作の制限:

      • スキーマ移行と完全データ移行中は、DDL 文を実行してデータベースまたはテーブルのスキーマを変更しないでください。変更すると、データ移行タスクが失敗します。

      • 完全データ移行のみを実行する場合は、データ移行中にソースデータベースにデータを書き込まないでください。書き込むと、ソースデータベースと宛先データベースの間でデータの不整合が発生します。データの整合性を確保するために、移行タイプとしてスキーマ移行、完全データ移行、増分データ移行を選択することをお勧めします。

    • データ移行インスタンスの実行中に、バイナリログの変更操作によって生成されたデータ (物理バックアップから復元されたデータやカスケード操作からのデータなど) は記録されず、宛先データベースに移行されません。

      説明

      変更データが記録されず、宛先データベースに移行されない場合は、ビジネスに影響がないことを前提に、完全データを再度移行できます。

    • ソースデータベースが MySQL データベース 8.0.23 以後のバージョンで、移行するデータに非表示の列が含まれている場合、その列のデータを取得できず、データ損失が発生します。

      説明

      • 列を表示するには、ALTER TABLE <table_name> ALTER COLUMN <column_name> SET VISIBLE; コマンドを実行します。詳細については、「Invisible Columns」をご参照ください。

      • プライマリキーのないテーブルは、自動的に非表示のプライマリキーを生成します。非表示のプライマリキーを表示する必要があります。詳細については、「Generated Invisible Primary Keys」をご参照ください。

    その他の制限

    • データ移行タスクを構成する前に、バージョン 0.10.1.0 ～ 2.0 の Kafka クラスタを作成する必要があります。

    • 移行対象としてテーブルのみを選択できます。

    • データ移行前に、データ移行がソースデータベースと宛先データベースのパフォーマンスに与える影響を評価してください。オフピーク時にデータを移行することをお勧めします。完全データ移行中は、DTS はソースデータベースと宛先データベースの読み取りリソースと書き込みリソースを使用します。これにより、データベースサーバーの負荷が増加する可能性があります。

    • 完全データ移行中は、同時 INSERT 操作によって宛先データベースのテーブルで断片化が発生します。完全データ移行が完了すると、宛先データベースの表領域はソースデータベースの表領域よりも大きくなります。

    • FLOAT または DOUBLE データ型の列の精度設定がビジネス要件を満たしていることを確認する必要があります。DTS は、ROUND(COLUMN,PRECISION) 関数を使用して、FLOAT または DOUBLE データ型の列から値を取得します。精度を指定しない場合、DTS は FLOAT データ型の列の精度を 38 桁に設定し、DOUBLE データ型の列の精度を 308 桁に設定します。

    • DTS は、過去 7 日以内に失敗したデータ移行タスクの再開を試みます。ワークロードを宛先データベースに切り替える前に、失敗したタスクを停止または解放する必要があります。また、REVOKE 文を実行して、DTS が宛先データベースにアクセスするために使用するアカウントから書き込み権限を取り消すこともできます。そうしないと、失敗したタスクが再開された後、ソースデータベースのデータによって宛先データベースのデータが上書きされます。

    • データ同期中に他のソースからのデータが宛先データベースに書き込まれると、ソースデータベースと宛先データベースの間でデータの不整合が発生します。

    • データ移行中に宛先 Kafka クラスタがアップグレードまたはダウングレードされた場合は、データ移行タスクを再起動する必要があります。

    • ソースデータベースが EncDB 機能が有効になっている ApsaraDB RDS for MySQL インスタンスの場合、完全データ移行を実行できません。

      説明

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

    • DTS タスクの実行に失敗した場合、DTS テクニカルサポートは 8 時間以内にタスクの復元を試みます。復元中に、タスクが再起動され、タスクのパラメータが変更される場合があります。

      説明

      タスクのパラメータのみが変更される可能性があります。データベースのパラメータは変更されません。 変更される可能性のあるパラメータには、「DTS インスタンスのパラメータの変更」トピックの「インスタンスパラメータの変更」セクションのパラメータなどが含まれますが、これらに限定されません。

    特別なケース

    • ソースデータベースが自己管理 MySQL データベースの場合、次の制限事項に注意してください。

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

      • DTS は、宛先データベースの最後に移行されたデータのタイムスタンプとソースデータベースの現在のタイムスタンプに基づいて移行レイテンシを計算します。ソースデータベースで DML 操作が長時間実行されない場合、移行レイテンシが不正確になる可能性があります。データ移行タスクのレイテンシが過度に高い場合は、ソースデータベースで DML 操作を実行してレイテンシを更新できます。

        説明

        移行対象としてデータベース全体を選択した場合は、ハートビートテーブルを作成できます。ハートビートテーブルは毎秒更新またはデータを受信します。

      • DTS は、バイナリログファイルの位置を移動するために、スケジュールどおりにソースデータベースで CREATE DATABASE IF NOT EXISTS `test` 文を実行します。

    • ソースデータベースが Apsara RDS for MySQL インスタンスの場合、次の制限事項に注意してください。

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

      • DTS は、バイナリログファイルの位置を移動するために、スケジュールどおりにソースデータベースで CREATE DATABASE IF NOT EXISTS `test` 文を実行します。

    課金ルール

    移行タイプ

    タスク構成料金

    インターネットトラフィック料金

    スキーマ移行と完全データ移行

    無料。

    Alibaba Cloud からインターネット経由でデータが移行される場合にのみ課金されます。詳細については、「課金概要」をご参照ください。

    増分データ移行

    課金されます。詳細については、「課金概要」をご参照ください。

    移行タイプ

    • スキーマ移行

      DTS は、選択したオブジェクトのスキーマをソースデータベースから宛先データベースに移行します。

    • 完全データ移行

      DTS は、必要なオブジェクトの既存データをソースデータベースから宛先データベースに移行します。

    • 増分データ移行

      完全データ移行が完了すると、DTS はソースデータベースから宛先データベースに増分データを移行します。増分データ移行により、データ移行中に自己管理アプリケーションのサービスを中断することなく、データをスムーズに移行できます。

    増分移行できる 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

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

    インスタンス

    スキーマ移行

    完全データ移行

    増分データ移行

    ソース ApsaraDB RDS for MySQL インスタンス

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

    手順

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

      DTS コンソール

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

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

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

      DMS コンソール

      説明

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

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

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

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

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

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

      警告

      ソースデータベースと宛先データベースを構成した後、ページの上部に表示される [制限事項] を読むことをお勧めします。そうでない場合、タスクが失敗したり、データの不整合が発生したりする可能性があります。

      セクション

      パラメータ

      説明

      該当なし

      タスク名

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

      ソースデータベース

      [既存の接続を選択]

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

        説明

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

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

      データベースタイプ

      ソースデータベースのタイプ。[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 暗号化を有効にする」をご参照ください。

      宛先データベース

      [既存の接続を選択]

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

        説明

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

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

      データベースタイプ

      宛先データベースのタイプ。[Kafka] を選択します。

      アクセス方法

      宛先データベースのアクセス方法。Alibaba Cloud インスタンス を選択します。

      インスタンスリージョン

      宛先 ApsaraMQ for Kafka インスタンスが存在するリージョン。

      [Kafka インスタンス ID]

      宛先 ApsaraMQ for Kafka インスタンスの ID。

      暗号化

      宛先インスタンスへの接続を暗号化するかどうかを指定します。ビジネスとセキュリティの要件に基づいて、[暗号化なし] または [SCRAM-SHA-256] を選択します。

      [トピック]

      移行されたデータを受信するために使用されるトピック。ドロップダウンリストからトピックを選択します。

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

      DDL 情報を格納するために使用されるトピック。ドロップダウンリストからトピックを選択します。このパラメータを構成しない場合、DDL 情報は [トピック] パラメータで指定されたトピックに格納されます。

      [Kafka Schema Registry を使用する]

      Kafka Schema Registry を使用するかどうかを指定します。Kafka Schema Registry は、メタデータのサービス層を提供します。これは、Avro スキーマを格納および取得するための RESTful API を提供します。有効な値:

      • いいえ

      • [はい]: このパラメータで [はい] を選択した場合は、Avro スキーマの Kafka Schema Registry に登録されている URL または IP アドレスを入力する必要があります。

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

      説明

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

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

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

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

        パラメータ

        説明

        移行タイプ

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

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

        説明

        • 宛先データベースが ApsaraMQ for Kafka インスタンスの場合、[スキーマ移行] はサポートされていません。

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

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

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

          説明

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

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

          警告

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

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

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

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

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

        [Kafka のデータ形式]

        宛先 ApsaraMQ for Kafka インスタンスにデータが格納される形式。

        • [DTS Avro] を選択すると、データは DTS Avro のスキーマ定義に基づいて解析されます。詳細については、「GitHub」をご参照ください。

        • [Canal JSON] を選択すると、データは Canal JSON 形式に解析されます。データを Canal JSON 形式に解析するために使用されるパラメータとサンプルコードの詳細については、「メッセージキューのデータ形式」トピックの Canal JSON セクションをご参照ください。

        [Kafka データ圧縮形式]

        Kafka 圧縮データの圧縮形式。ビジネス要件に基づいて圧縮形式を選択します。有効な値:

        • [LZ4]: (デフォルト): 低圧縮率、高圧縮速度。

        • [GZIP]: 高圧縮率、低圧縮速度。

          説明

          GZIP 圧縮は大量の CPU リソースを消費します。

        • [Snappy]: 中程度の圧縮率、中程度の圧縮速度。

        [Kafka パーティションへのデータ送信ポリシー]

        Kafka パーティションにデータを移行するためのポリシー。ビジネス要件に基づいてポリシーを選択します。詳細については、「Kafka パーティションにデータを移行するためのポリシーを指定する」をご参照ください。

        [メッセージ確認応答メカニズム]

        DTS が Apache Kafka インスタンスにデータを移行するときのメッセージ確認応答メカニズム。詳細については、「メッセージ確認応答メカニズム」をご参照ください。

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

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

        ソースオブジェクト

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

        説明

        移行対象としてテーブルのみを選択できます。

        選択中のオブジェクト

        この例では、このパラメータを構成する必要はありません。オブジェクト名マッピング機能を使用して、宛先 ApsaraMQ for Kafka インスタンスに関する情報 (ソーステーブルのデータの移行先のトピックの名前、トピックのパーティション数、パーティションキーなど) を指定できます。詳細については、このトピックの オブジェクト名マッピング機能を使用する セクションをご参照ください。

        説明

        • オブジェクト名マッピング機能を使用してオブジェクトの名前を変更すると、そのオブジェクトに依存する他のオブジェクトが移行に失敗する可能性があります。

        • 増分移行中にオブジェクトで実行された DML または DDL 操作を移行するには、選択中のオブジェクト セクションでオブジェクトを右クリックします。表示されるダイアログボックスで、移行する DML 操作と DDL 操作を選択します。詳細については、このトピックの 増分移行できる 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 秒あたりのソースデータベースのクエリ率 QPS、1 秒あたりの完全移行の行数 RPS、1 秒あたりの完全移行データ量 (MB) BPS パラメータを構成する必要があります。これにより、宛先データベースサーバーの負荷が軽減されます。

        説明

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

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

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

        説明

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

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

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

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

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

        環境タグ

        DTS インスタンスを識別するために使用される環境タグ。ビジネス要件に基づいて環境タグを選択できます。この例では、環境タグは追加されていません。

        ETL の設定

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

        [監視とアラート]

        データ移行タスクのアラートを構成するかどうかを指定します。タスクが失敗した場合、または移行レイテンシが指定されたしきい値を超えた場合、アラート連絡先に通知が送信されます。有効な値:

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

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

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

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

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

      説明

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

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

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

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

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

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

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

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

        セクション

        パラメータ

        説明

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

        [リソースグループ]

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

        インスタンスクラス

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

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

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

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

        説明

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

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

    オブジェクト名マッピング機能を使用する

    1. 選択中のオブジェクト セクションで、トピック名にポインターを移動します。

    2. 編集 を右クリックします。

    3. 表示されるダイアログボックスで、次の表に示すパラメータを構成します。

      パラメータ

      説明

      テーブル名

      ソーステーブルのデータの移行先のトピックの名前。デフォルトでは、このパラメータは [ソースデータベースと宛先データベースの構成] 手順の [宛先データベース] セクションの トピック の値に設定されます。

      重要

      • 宛先データベースが ApsaraMQ for Kafka インスタンスの場合、トピックは宛先 ApsaraMQ for Kafka インスタンスに存在する必要があります。そうでない場合、データ移行は失敗します。自己管理 Kafka クラスタにデータを移行し、スキーマ移行タスクが移行インスタンスに含まれている場合、DTS は宛先データベースで指定したトピックの作成を試みます。

      • ソーステーブルの [テーブル名] パラメータの値を宛先データベースのトピックの名前に変更すると、テーブルのデータは指定されたトピックに書き込まれます。

      フィルタリング条件

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

      パーティション数

      データの移行先のトピックのパーティション数。

      パーティションキー

      Kafka パーティションへのデータ転送ポリシー パラメータを 主キーのハッシュ値に基づいて、データを個別のパーティションに転送 に設定した場合は、このパラメータを構成して、ハッシュ値を計算するためのパーティションキーとして 1 つ以上の列を指定します。DTS は、計算されたハッシュ値に基づいて、宛先トピックの各パーティションに異なる行を配信します。

      説明

      列の パーティションキー を選択するには、まず すべてのテーブルを同期 をオフにする必要があります。

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