すべてのプロダクト
Search

このプロダクト

    Data Transmission Service:RDS for MySQL から ApsaraMQ for Kafka への移行

    ドキュメントセンター

    Data Transmission Service:RDS for MySQL から ApsaraMQ for Kafka への移行

    最終更新日:Jul 18, 2026

    Data Transmission Service (DTS) を使用して、RDS for MySQL インスタンスから Message Queue for Apache Kafka インスタンスへデータを移行できます。

    前提条件

    • ソース ApsaraDB RDS for MySQL インスタンスと送信先 ApsaraMQ for Kafka インスタンスを作成しました。

      説明

    • ターゲットとなる ApsaraMQ for Kafka インスタンスのストレージ容量は、ソースとなる ApsaraDB RDS for MySQL インスタンスが使用している容量よりも大きい必要があります。

    • ターゲットとなる ApsaraMQ for Kafka インスタンスに、移行データを受信するためのトピックを作成済みである必要があります。手順については、「ステップ 1：トピックの作成」をご参照ください。

    制限事項

    説明

    DTS は外部キーを移行しません。そのため、ソースデータベースでカスケード削除などのカスケード操作を行っても、ターゲットデータベースには複製されません。

    種別

    説明

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

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

    • 移行対象の各テーブルにはプライマリキーまたは一意制約が設定されており、キー列には一意の値が含まれている必要があります。そうでない場合、ターゲットデータベースに重複レコードが発生する可能性があります。

    • 移行オブジェクトとしてテーブルを選択し、列名のマッピングなど編集を行う場合、1 つの移行タスクで最大 1,000 のテーブルをサポートします。この上限を超えると、タスクの送信時にエラーが発生し失敗します。これを回避するには、複数のタスクに分割するか、データベース全体の移行タスクを構成してください。

    • 増分移行を実施する場合は、バイナリロギングを有効にしてください。

      • binlog_format を ROW に、binlog_row_image を FULL に設定してください。設定しない場合、事前チェックに失敗し、タスクを開始できません。

        重要

        セルフマネージド MySQL ソースがデュアルマスタクラスター（各インスタンスがマスタかつスレーブの役割を果たす）の場合、log_slave_updates パラメーターを有効にしてください。これにより、DTS がすべてのバイナリログを読み取れるようになります。

      • RDS for MySQL インスタンスの場合、ローカルバイナリログを最低でも 3 日間（推奨は 7 日間）保持してください。セルフマネージド MySQL データベースの場合は、最低でも 7 日間保持してください。DTS がバイナリログにアクセスできない場合、タスクは失敗します。最悪の場合、データの不整合やデータ損失が発生する可能性があります。DTS が要求するよりも短いバイナリログ保持期間に起因する問題は、DTS の SLA の対象外です。

        説明

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

    • ソースデータベースで許可されない操作：

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

        説明

        完全移行中、DTS はソースデータベースに対してクエリを実行します。これによりメタデータロックが発生し、ソースデータベースでの DDL 操作がブロックされる可能性があります。

      • 完全移行のみを実行する場合、ソースインスタンスに新しいデータを書き込まないでください。書き込むと、ソースとターゲットのデータが不整合になります。リアルタイムでデータを整合させるには、スキーマ移行、完全移行、および増分移行をすべて選択してください。

    • DTS は、バイナリログに書き込まれない変更によって生成されたデータを移行しません。例として、物理バックアップからの復元やカスケード操作によって作成されたデータが該当します。

      説明

      このような状況が発生した場合は、業務上可能なタイミングで完全移行を再実行してください。

    • ソース MySQL データベースのバージョンが 8.0.23 以降で、非表示の隠しカラムが含まれている場合、DTS はこれらのカラムを読み取れません。これによりデータ損失が発生する可能性があります。

      説明

      ALTER TABLE <table_name> ALTER COLUMN <column_name> SET VISIBLE; を実行して、隠しカラムを表示可能にしてください。詳細については、「Invisible Columns」をご参照ください。

    • MySQL 互換性：DTS が MySQL ファミリーのソースデータベースからデータを移行する際は、標準的な MySQL プロトコルおよび Binlog 形式に依存しており、標準 MySQL と互換性のない動作はサポートされません。ソースデータベースが MySQL 互換を謳っていても、MySQL とは異なる動作をする場合（例：OceanBase を MySQL モードでソースとして接続した際に、Binlog 内の末尾 rotate イベントのタイムスタンプが 0 になるなど）、DTS 移行タスクが失敗する可能性があります。

    その他の制限

    • 移行オブジェクトとしてサポートされるのはデータテーブルのみです。

    • DTS は INDEX、PARTITION、VIEW、PROCEDURE、FUNCTION、TRIGGER、FK オブジェクトの移行をサポートしていません。

    • 移行前に、ソースおよびターゲットデータベースのパフォーマンスを評価してください。業務のピーク時間帯を避けて移行を実行してください。そうでない場合、完全移行により両方のデータベースの読み取りおよび書き込みリソースが消費され、データベース負荷が増大します。

    • 完全移行では INSERT 操作が同時に行われます。これによりターゲットテーブルがフラグメント化し、完全移行後、ターゲットテーブルのストレージ容量がソーステーブルよりも多く必要になります。

    • FLOAT または DOUBLE 列に対する DTS の移行精度が、ビジネス要件を満たしていることを確認してください。DTS はこれらの列を ROUND(COLUMN,PRECISION) を使用して読み取ります。精度が定義されていない場合、DTS は FLOAT に 38 桁、DOUBLE に 308 桁を使用します。

    • DTS は失敗したタスクを 7 日以内に回復しようと試みます。ターゲットインスタンスへのトラフィック切り替え前に、タスクを終了またはリリースするか、revoke コマンドを実行して、ターゲットインスタンスアカウントに対する DTS の書き込み権限を取り消してください。これにより、自動回復によってターゲットデータがソースデータで上書きされるのを防げます。

    • DTS を通じて以外でターゲットデータベースにデータを書き込まないでください。書き込むと、ソースおよびターゲットデータベース間でデータの不整合が発生する可能性があります。

    • 移行中にターゲット Kafka クラスターのスケールアウトまたはスケールインを実施した場合、DTS タスクを再起動してください。

    • RDS for MySQL インスタンスで Always-Encrypted が有効になっている場合、完全移行はサポートされません。

      説明

      Transparent Data Encryption (TDE) が有効になっている RDS for MySQL インスタンスは、スキーマ移行、完全移行、および増分移行をサポートしています。

    • タスクが失敗した場合、DTS サポートスタッフが 8 時間以内に復旧を試みます。復旧中、タスクを再起動したり、パラメーターを調整したりする可能性があります。

      説明

      変更されるのは DTS タスクパラメーターのみで、データベースパラメーターは変更されません。 調整対象となるパラメーターは、「インスタンスパラメーターの変更」に記載されています。

    特殊なケース

    • セルフマネージド MySQL ソースの場合：

      • ソースデータベースでマスタ–スタンバイスイッチオーバーが発生すると、移行タスクが失敗します。

      • DTS は、ターゲットデータベースに最後に移行されたレコードのタイムスタンプと現在時刻を比較して遅延を計算します。ソースで長時間 DML 操作が実行されない場合、遅延レポートが不正確になります。遅延が過大に表示される場合は、ソースで DML 操作を実行して遅延値を更新してください。

        説明

        データベース全体の移行を選択する場合は、ハートビートテーブルを作成し、毎秒更新または書き込みを行ってください。

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

      • Amazon Aurora MySQL またはその他のクラスター化された MySQL インスタンスをソースとして使用する場合、タスクに設定されたドメイン名または IP アドレスおよびその DNS 解決が常に読み取り–書き込み (RW) ノードを指すようにしてください。そうでない場合、移行タスクが失敗する可能性があります。

    • RDS for MySQL ソースの場合：

      • 増分移行を実施する必要がある場合、トランザクションログを記録しない RDS for MySQL インスタンス（例：RDS for MySQL 5.6 読み取り専用インスタンス）はソースとしてサポートされません。

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

    課金

    移行タイプ

    タスク構成料金

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

    スキーマ移行および完全データ移行

    無料です。

    ターゲットデータベースのアクセス方法が パブリック IP アドレス に設定されている場合、DTS はインターネットトラフィック料金を請求します。「課金概要」をご参照ください。

    増分データ移行

    課金対象です。「課金概要」をご参照ください。

    移行タイプ

    • スキーマ移行

      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. Data Transmission Service (DTS) コンソールにログインします。

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

      3. ページ左上隅で、移行インスタンスが配置されているリージョンを選択します。

      DMS コンソールから

      説明

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

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

      2. 上部メニューバーで、Data + AI > Data Transmission (DTS) > データ移行 を選択します。

      3. データ移行タスク の右側で、移行インスタンスが配置されているリージョンを選択します。

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

    3. ソースおよびターゲットデータベースを構成します。

      警告

      ソースおよびターゲットインスタンスを選択した後、ページ上部に表示される制限事項を慎重にご確認ください。確認しない場合、タスクが失敗したり、データの不整合が発生したりする可能性があります。

      カテゴリ

      パラメーター

      説明

      該当なし

      タスク名

      DTS は自動的にタスク名を生成します。識別しやすいように、わかりやすい名前を指定することを推奨します。名前は一意である必要はありません。

      ソースデータベース

      既存の接続情報の選択

      • システムに追加済み（作成または保存済み）のデータベースインスタンスを使用する場合、ドロップダウンリストから目的のデータベースインスタンスを選択してください。これにより、下記のデータベース情報が自動的に構成されます。

        説明

        DMS コンソールでは、このパラメーターの名称は DMS データベースインスタンスの選択 です。

      • データベースインスタンスをシステムに登録していない場合、または登録済みのインスタンスを使用しない場合は、下記でデータベース情報を手動で構成してください。

      データベースタイプ

      MySQL を選択します。

      アクセス方法

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

      インスタンスリージョン

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

      Alibaba Cloudアカウント全体でのデータの複製

      同一 Alibaba Cloud アカウント内での移行の場合、× を選択します。

      RDS インスタンス ID

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

      データベースアカウント

      ソース RDS for MySQL インスタンスのデータベースアカウントを入力します。このアカウントには、移行対象オブジェクトに対する読み取り権限が必要です。

      データベースパスワード

      データベースアカウントに対応するパスワードを入力します。

      暗号化

      必要に応じて、非暗号化 または SSL 暗号化 を選択します。SSL 暗号化 を選択する場合は、事前に RDS for MySQL インスタンスで SSL 暗号化を有効にしておく必要があります。詳細については、「クラウド証明書を使用した SSL 暗号化の迅速な有効化」をご参照ください。

      宛先データベース

      既存の接続情報の選択

      • システムに追加済み（作成または保存済み）のデータベースインスタンスを使用する場合、ドロップダウンリストから目的のデータベースインスタンスを選択してください。これにより、下記のデータベース情報が自動的に構成されます。

        説明

        DMS コンソールでは、このパラメーターの名称は DMS データベースインスタンスの選択 です。

      • データベースインスタンスをシステムに登録していない場合、または登録済みのインスタンスを使用しない場合は、下記でデータベース情報を手動で構成してください。

      データベースタイプ

      Kafka を選択します。

      アクセス方法

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

      インスタンスリージョン

      ターゲット ApsaraMQ for Kafka インスタンスのリージョンを選択します。

      Kafka インスタンス ID

      ターゲット ApsaraMQ for Kafka インスタンスの ID を選択します。

      暗号化

      ビジネスおよびセキュリティ要件に基づき、非暗号化 または SCRAM-SHA-256 を選択します。

      トピック

      データを受信するトピックを選択します。

      Kafka スキーマレジストリの使用

      Kafka Schema Registry は、Avro スキーマを格納および取得するための RESTful インターフェイスを提供します。

      • ×：Kafka Schema Registry を使用しません。

      • ○：Kafka Schema Registry を使用します。Kafka Schema Registry に登録された Avro スキーマの URL または IP アドレスを入力する必要があります。

    4. 構成が完了したら、ページ下部の 接続をテストして続行 をクリックします。

      説明

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

      • ソースまたはターゲットデータベースが自己管理データベース（アクセス方法 が Alibaba Cloud インスタンス ではない）の場合、表示される DTS サーバーの CIDR ブロック ダイアログボックス内で、接続テスト をクリックする必要があります。

    5. タスクオブジェクトを構成します。

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

        パラメーター

        説明

        移行タイプ

        • 完全移行のみ必要な場合は、スキーマ移行 および 完全データ移行 の両方を選択します。

        • ダウンタイムなしのシームレスな移行を行う場合は、スキーマ移行、完全データ移行、および 増分データ移行 を選択します。

        説明

        • ターゲット Kafka インスタンスの アクセス方法 が Alibaba Cloud インスタンス の場合、スキーマ移行 はサポートされません。

        • データ整合性を確保するため、増分データ移行 を選択しない場合、移行中はソースインスタンスに新しいデータを書き込まないでください。

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

        • エラーの事前チェックと報告：ターゲットデータベースに同名のテーブルが存在するかどうかをチェックします。同名のテーブルが存在しない場合、事前チェックは合格します。同名のテーブルが存在する場合、事前チェック中にエラーが報告され、データ移行タスクは開始されません。

          説明

          ターゲットデータベースのテーブルが同名であり、簡単に削除または名前変更できない場合は、ターゲットデータベース内のテーブル名を変更できます。詳細については、「オブジェクト名マッピング」をご参照ください。

        • エラーを無視して続行：同名のテーブルのチェックをスキップします。

          警告

          エラーを無視して続行 を選択すると、データの不整合やビジネスリスクが発生する可能性があります。例として以下のようなケースが考えられます。

          • テーブルスキーマが一致しており、ターゲットデータベースのレコードがソースデータベースのレコードと同じプライマリキー値を持つ場合：

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

            • 増分移行中、DTS はターゲットデータベースのレコードを保持しません。ソースデータベースのレコードがターゲットデータベースのレコードを上書きします。

          • テーブルスキーマが不一致の場合、一部のカラムのデータのみが移行されるか、移行が失敗する可能性があります。慎重に進めてください。

        Kafka のデータ形式

        Kafka インスタンスに移行するデータのストレージ形式を選択します。

        • DTS Avro を選択する場合、DTS Avro スキーマ定義に基づいてデータを解析する必要があります。詳細については、「DTS Avro スキーマ定義」および「DTS Avro デシリアライズの例」をご参照ください。

        • Canal JSON を選択する場合、パラメーターの詳細および例については、「Canal JSON の説明」をご参照ください。

        • Shareplex JSON を選択する場合、パラメーターの詳細および例については、「Shareplex JSON」をご参照ください。

        Kafka 圧縮形式

        要件に基づき、Kafka メッセージの圧縮形式を選択します。

        • LZ4（デフォルト）：圧縮率が低く、圧縮速度が高速です。

        • GZIP：圧縮率が高く、圧縮速度が低速です。

          説明

          CPU 使用率が高くなります。

        • Snappy：圧縮率および圧縮速度が中程度です。

        Kafka パーティションへのデータ転送ポリシー

        ビジネス要件に基づき、戦略 を選択します。

        メッセージ肯定応答メカニズム

        ビジネス要件に基づき、メッセージ確認応答メカニズム を選択します。

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

        DDL 情報を格納するトピックを選択します。

        説明

        トピックを選択しない場合、DTS はデフォルトでデータトピックに DDL 情報を格納します。

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

        ターゲットインスタンスにおける移行オブジェクト（データベース、テーブル、カラムなど）の名前の大文字小文字区別ポリシーを構成できます。デフォルトでは、DTS のデフォルトポリシー が選択されています。また、ソースまたはターゲットデータベースのデフォルトポリシーと一致させるように選択することもできます。詳細については、「ターゲットデータベースにおけるオブジェクト名の大文字小文字区別」をご参照ください。

        ソースオブジェクト

        ソースオブジェクト ボックスで、移行対象のオブジェクトをクリックし、Right arrow をクリックして 選択中のオブジェクト ボックスに移動させます。

        説明

        テーブルレベルで移行対象のオブジェクトを選択できます。

        選択中のオブジェクト

        この例では追加の構成は不要です。マッピング機能を使用して、各ソーステーブルのトピック名、パーティション数、パーティションキーを指定できます。詳細については、「マッピング情報」をご参照ください。

        説明

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

        • 増分移行の SQL 操作を選択するには、選択中のオブジェクト ボックス内の移行オブジェクトを右クリックし、表示されるダイアログボックスで目的の SQL 操作を選択します。

      2. 詳細設定へ をクリックして、詳細パラメーターを構成します。

        パラメーター

        説明

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

        デフォルトでは、DTS は共有クラスター上でタスクをスケジューリングします。選択する必要はありません。より安定したタスクを実行したい場合は、DTS 移行タスクを実行するための専用クラスターを購入できます。

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

        移行タスク開始後、ソースまたはターゲットデータベースへの接続が失敗した場合、DTS はエラーを報告し、直ちに接続の再試行を開始します。デフォルトの再試行時間は 720 分です。10 ～ 1440 分の範囲で再試行時間をカスタマイズできます。30 分以上に設定することを推奨します。指定された時間内に DTS がソースおよびターゲットデータベースに再接続できた場合、移行タスクは自動的に再開されます。そうでない場合、タスクは失敗します。

        説明

        • 同一のソースまたはターゲットを共有する複数の DTS インスタンスの場合、ネットワーク再試行時間は最後に作成されたタスクの設定によって決定されます。

        • 接続再試行期間中もタスクに対して課金されるため、ビジネス要件に基づいて再試行時間をカスタマイズするか、ソースおよびターゲットデータベースインスタンスをリリースした後はできるだけ早く DTS インスタンスをリリースすることを推奨します。

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

        移行タスク開始後、接続以外の問題（DDL または DML 実行例外など）がソースまたはターゲットデータベースで発生した場合、DTS はエラーを報告し、直ちに操作の再試行を開始します。デフォルトの再試行時間は 10 分です。1 ～ 1440 分の範囲で再試行時間をカスタマイズできます。10 分以上に設定することを推奨します。指定された再試行時間内に関連操作が成功した場合、移行タスクは自動的に再開されます。そうでない場合、タスクは失敗します。

        重要

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

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

        完全移行中、DTS はソースおよびターゲットデータベースの読み取りおよび書き込みリソースを消費するため、データベース負荷が増大する可能性があります。必要に応じて、完全移行タスクの速度制限を有効化できます。1 秒あたりのソースデータベースのクエリ率 QPS、1 秒あたりの完全移行の行数 RPS、および 1 秒あたりの完全移行データ量 (MB) BPS を設定して、ターゲットデータベースの負荷を軽減できます。

        説明

        • この設定項目は、移行タイプ で 完全データ移行 を選択した場合にのみ利用可能です。

        • 移行インスタンスの実行後も、完全移行速度を調整 できます。

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

        必要に応じて、増分移行タスクの速度制限を設定することもできます。1 秒あたりの増分移行の行数 RPS および 1 秒あたりの増分移行データ量 (MB) BPS を設定して、ターゲットデータベースの負荷を軽減できます。

        説明

        • この設定項目は、移行タイプ で 増分データ移行 を選択した場合にのみ利用可能です。

        • 移行インスタンスの実行後も、増分移行速度を調整 できます。

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

        DTS インスタンス実行時に、ハートビート SQL 情報をソースデータベースに書き込むかどうかを選択します。

        • ○：ハートビート SQL 情報はソースデータベースに書き込まれません。これにより、DTS インスタンスが遅延を報告する可能性があります。

        • ×：ハートビート SQL 情報をソースデータベースに書き込みます。これにより、ソースデータベースの物理バックアップやクローンなどの機能に干渉する可能性があります。

        環境タグ

        インスタンスを識別するために環境タグを選択します。この例では選択不要です。

        ETL 機能の設定

        ビジネス要件に基づき、データを処理するためにETL 機能を構成するかどうかを選択します。

        • ○：ETL 機能を構成します。また、テキストボックスにデータ処理文を入力する必要があります。

        • ×：ETL 機能を構成しません。

        監視アラート

        ビジネス要件に基づき、アラートを設定してアラート通知を受信するかどうかを選択します。

        • ×：アラートを設定しません。

        • ○：アラートのしきい値 および アラート通知 を設定してアラートを構成します。移行が失敗した場合や遅延がしきい値を超えた場合、システムがアラート通知を送信します。

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

      • API オペレーションを呼び出す際にこのインスタンスを構成するパラメーターを表示するには、次：タスク設定の保存と事前チェック ボタンにポインターを合わせ、表示されるバルーン内で OpenAPI パラメーターのプレビュー をクリックします。

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

      説明

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

      • 事前チェックに失敗した場合、失敗したチェック項目の横にある 詳細を表示 をクリックし、プロンプトに基づいて問題を修正した後、再度事前チェックを実行してください。

      • 事前チェック中に警告が報告された場合：

        • 無視できないチェック項目の場合、失敗した項目の横にある 詳細を表示 をクリックし、プロンプトに基づいて問題を修正した後、再度事前チェックを実行してください。

        • 無視可能なチェック項目の場合、アラートの詳細を確認、無視、OK、および 再度事前チェックを実行 をクリックして、アラート項目をスキップし、再度事前チェックを実行できます。警告を無視することを選択した場合、データの不整合などの問題が発生し、ビジネスにリスクをもたらす可能性があります。

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

      1. 成功率 が 100% になったら、次：インスタンスの購入 をクリックします。

      2. 購入 ページで、データ移行インスタンスのリンク仕様を選択します。詳細は次の表をご参照ください。

        カテゴリ

        パラメーター

        説明

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

        リソースグループの設定

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

        インスタンスクラス

        DTS は、さまざまなパフォーマンスレベルを持つ移行仕様を提供しています。リンク仕様は移行速度に影響します。ビジネスシナリオに基づいて仕様を選択できます。詳細については、「データ移行リンク仕様」をご参照ください。

      3. 構成が完了したら、Data Transmission Service (従量課金) 利用規約 を読み、同意してください。

      4. 購入して起動 をクリックします。表示される OK ダイアログボックスで、OK をクリックします。

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

        説明

        • 移行タスクに増分移行が含まれていない場合、完全移行完了後に自動的に停止します。タスクが停止すると、ステータス は 完了 に変化します。

        • 移行タスクに増分移行が含まれている場合、自動的に停止しません。増分移行タスクは継続して実行されます。増分移行タスク実行中、タスクの ステータス は 実行中 です。

    マッピング情報

    1. 選択中のオブジェクト エリアで、テーブルレベルの宛先トピック名にポインターを合わせます。

    2. 宛先トピック名の横にある 編集 をクリックします。

    3. テーブルの編集 ダイアログボックスで、マッピング情報を構成します。

      説明

      • ダイアログボックスの名称は、データベースレベルでは スキーマの編集、テーブルレベルでは テーブルの編集 です。スキーマの編集 ダイアログボックスのパラメーターは少ないです。

      • データベース全体を移行しない場合、スキーマの編集 ダイアログボックスで、対象トピックの名前 および パーティション数 パラメーターを変更できません。

      パラメーター

      説明

      対象トピックの名前

      ソーステーブルからデータを受信するトピックの名前です。これは、ソースデータベースとターゲットデータベースの設定 ステップの 移行先データベース セクションで選択した トピック がデフォルトになります。

      重要

      • ターゲットが Message Queue for Apache Kafka インスタンスの場合、指定されたトピックはすでにターゲットインスタンスに存在している必要があります。存在しない場合、データ移行タスクは失敗します。ターゲットが自己管理 Kafka データベースで、データ移行タスクにデータベースおよびテーブル構造の移行が含まれている場合、DTS はターゲットデータベースに指定されたトピックの作成を試みます。

      • 対象トピックの名前 を変更した場合、DTS は指定されたトピックにデータを書き込みます。

      フィルタリング条件

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

      パーティション数

      宛先トピックのパーティション数です。

      パーティションキー

      Kafka パーティションへのデータ転送ポリシー が 主キーのハッシュ値に基づいて、データを個別のパーティションに転送 に設定されている場合に利用可能です。1 つ以上のカラムをパーティションキーとして指定します。DTS は指定されたカラムのハッシュ値を計算し、行を宛先トピックのパーティション間で分散させます。

      説明

      パーティションキー は、テーブルの編集 ダイアログボックスでのみ選択できます。

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