すべてのプロダクト
Search

このプロダクト

    Data Transmission Service:PolarDB for PostgreSQL (Oracle 互換) から Kafka へのデータ移行

    ドキュメントセンター

    Data Transmission Service:PolarDB for PostgreSQL (Oracle 互換) から Kafka へのデータ移行

    最終更新日:Jan 18, 2026

    このトピックでは、Data Transmission Service (DTS) を使用して、PolarDB for PostgreSQL (Oracle 互換) クラスターから Message Queue for Apache Kafka インスタンスにデータを移行する方法について説明します。

    前提条件

    • ソースの PolarDB for PostgreSQL (Oracle 互換) クラスターで、wal_level パラメーターの値が logical に設定されていること。これにより、論理デコーディングに必要な情報が先行書き込みログ (WAL) に追加されます。詳細については、「クラスターパラメーターの設定」をご参照ください。

    • 移行先の Message Queue for Apache Kafka インスタンスが作成されていること。移行先インスタンスには、ソースの PolarDB for PostgreSQL (Oracle 互換) インスタンスが使用するディスク領域よりも多くの利用可能なディスク領域が必要です。

      説明

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

    • 移行先の Message Queue for Apache Kafka インスタンスに、移行データを受信するための Topic が作成されていること。詳細については、「ステップ 1: Topic の作成」をご参照ください。

    注意事項

    タイプ

    説明

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

    • 帯域幅：ソースデータベースサーバーには十分な出力帯域幅が必要です。そうでない場合、データ移行速度に影響が出ます。

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

    • テーブルレベルでオブジェクトを移行し、列名のマッピングなどの編集が必要な場合、1 つのデータ移行タスクで移行できるテーブルは最大 1,000 個です。この制限を超えると、タスクの送信時にエラーが報告されます。この場合、テーブルをより小さなバッチに分割して複数のタスクを設定するか、データベース全体を移行するタスクを設定してください。

    • 増分移行を実行する場合、先行書き込みログ (WAL) については、以下の点にご注意ください：

      • 有効にしてください。

      • 増分移行タスクの場合、DTS はソースデータベースが WAL ログを 24 時間以上保持することを要求します。完全移行と増分移行の両方を含むタスクの場合、DTS はソースデータベースが WAL ログを少なくとも 7 日間保持することを要求します。完全移行が完了した後、ログの保持期間を 24 時間以上に変更できます。保持期間が短すぎると、DTS が必要な WAL ログを取得できず、DTS タスクが失敗する可能性があります。極端な場合、これによりデータの不整合やデータ損失が発生する可能性があります。DTS の要件より短いログ保持期間に起因する問題は、DTS のサービスレベルアグリーメント (SLA) の対象外です。

    • ソースデータベースの操作制限：

      • スキーマ移行および完全移行フェーズ中は、データベースまたはテーブルの構造を変更する DDL 操作を実行しないでください。実行した場合、データ移行タスクは失敗します。

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

      • 移行タスクが正常に実行され、プライマリ/セカンダリのスイッチオーバーによる論理サブスクリプションの中断を防ぐために、ご利用の PolarDB for PostgreSQL (Oracle 互換) インスタンスは、論理レプリケーションスロットのフェイルオーバーをサポートし、有効にしている必要があります。詳細については、「論理レプリケーションスロットのフェイルオーバーを有効にする」をご参照ください。

        説明

        ソースの PolarDB for PostgreSQL (Oracle 互換) クラスターが論理レプリケーションスロットのフェイルオーバー機能をサポートしていない場合 (たとえば、クラスターの データベースエンジン が Oracle 構文互換 2.0 の場合)、ソースデータベースが HA フェイルオーバーをトリガーすると、移行インスタンスが失敗し、回復できなくなる可能性があります。

      • ソースデータベースの論理レプリケーションの制限により、移行中に移行対象の単一の増分データが 256 MB を超えると、DTS インスタンスが失敗し、回復できなくなる可能性があります。DTS インスタンスを再設定する必要があります。

    • ソースデータベースに長時間実行トランザクションがあり、インスタンスに増分移行タスクが含まれている場合、トランザクションコミット前の先行書き込みログ (WAL) が蓄積され、クリアできなくなる可能性があります。これにより、ソースデータベースのディスク領域が不足する可能性があります。

    その他の制限

    • 1 つのデータ移行タスクで移行できるデータベースは 1 つだけです。複数のデータベースを移行するには、データベースごとにデータ移行タスクを設定してください。

    • DTS は、TimescaleDB 拡張テーブル、スキーマ間継承を持つテーブル、または式ベースの一意なインデックスを持つテーブルの移行をサポートしていません。

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

    • DTS インスタンスが増分データ移行タスクを実行する場合、データを書き込む前に、ソースデータベースの移行対象テーブルで ALTER TABLE schema.table REPLICA IDENTITY FULL; コマンドを実行する必要があります。これは、以下の 2 つのシナリオに適用され、データ整合性を確保します。このコマンドの実行中は、テーブルロック操作を行わないことを推奨します。そうしないと、テーブルがロックされる可能性があります。事前チェックで関連するチェックをスキップした場合、DTS はインスタンスの初期化中にこのコマンドを自動的に実行します。

      • インスタンスが初めて実行されるとき。

      • 移行オブジェクトの粒度がスキーマであり、移行対象のスキーマに新しいテーブルが作成されるか、RENAME コマンドを使用して移行対象のテーブルが再構築されるとき。

      説明

      • コマンドで、schema と table を移行するデータのスキーマ名とテーブル名に置き換えてください。

      • この操作はオフピーク時間に行うことを推奨します。

    • DTS は、増分データの DDL 文、増分テーブルのスキーマ、およびハートビート情報を取得するために、ソースデータベースに以下の一時テーブルを作成します。移行中にこれらの一時テーブルを削除しないでください。削除すると、DTS タスクが異常になります。一時テーブルは、DTS インスタンスがリリースされた後に自動的に削除されます。

      public.dts_pg_class、public.dts_pg_attribute、public.dts_pg_type、public.dts_pg_enum、public.dts_postgres_heartbeat、public.dts_ddl_command、public.dts_args_session、および public.aliyun_dts_instance。

    • 表示される移行遅延の精度を確保するため、DTS はソースデータベースに dts_postgres_heartbeat という名前のテーブルを追加します。

    • 増分データ移行中、DTS はデータをレプリケーションするために、ソースデータベースにプレフィックス dts_sync_ を持つレプリケーションスロットを作成します。このレプリケーションスロットを使用して、DTS はソースデータベースから過去 15 分間の増分ログを取得できます。データ移行が失敗した場合や移行インスタンスがリリースされた場合、DTS はこのレプリケーションスロットを自動的にクリアしようとします。

      説明

      • データ移行中にタスクが使用するソースデータベースアカウントのパスワードを変更したり、ソースデータベースのホワイトリストから DTS の IP アドレスを削除したりすると、レプリケーションスロットは自動的にクリアされません。この場合、レプリケーションスロットが蓄積されてディスク領域を占有し、ソースデータベースが利用できなくなるのを防ぐために、ソースデータベースで手動でレプリケーションスロットをクリアする必要があります。

      • ソースデータベースでフェイルオーバーが発生した場合、セカンダリデータベースにログインして手動でスロットをクリアする必要があります。

    • データ移行中に、移行先の Kafka インスタンスがスケールアウトまたはスケールインされた場合、移行インスタンスを再起動する必要があります。

    • データを移行する前に、ソースデータベースとターゲットデータベースのパフォーマンスを評価してください。また、オフピーク時間にデータを移行することを推奨します。そうしないと、DTS は完全データ移行中にソースデータベースとターゲットデータベースの読み取りおよび書き込みリソースを消費し、データベースの負荷が増加する可能性があります。

    • DTS は、失敗した移行タスクを 7 日以内に再開しようと試みます。ビジネスをターゲットインスタンスに切り替える前に、タスクを終了またはリリースするか、DTS がターゲットインスタンスにアクセスするために使用するアカウントの書き込み権限を取り消してください。これにより、タスクが自動的に再開された後に、ソースデータがターゲットインスタンスのデータを上書きするのを防ぎます。

    • タスクが失敗した場合、DTS の技術サポートは 8 時間以内に回復を試みます。回復プロセス中に、タスクの再起動やパラメーターの調整などの操作が実行されることがあります。

      説明

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

    • パーティションテーブルを移行する場合、子パーティションと親テーブルの両方を同期オブジェクトとして含めてください。そうしないと、パーティションテーブルでデータの不整合が発生する可能性があります。

      説明

      PolarDB for PostgreSQL (Oracle 互換) のパーティションテーブルの親テーブルは、データを直接保存しません。すべてのデータは子パーティションに保存されます。同期タスクには、親テーブルとそのすべての子パーティションの両方を含める必要があります。そうしないと、子パーティションのデータが欠落し、ソースとターゲット間でデータの不整合が発生する可能性があります。

    課金

    移行タイプ

    リンク設定料金

    データ転送料金

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

    無料です。

    パブリックネットワーク経由で Alibaba Cloud の外部にデータを移行する場合、データ転送料金が課金されます。詳細については、「課金の概要」をご参照ください。

    増分データ移行

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

    増分移行でサポートされる 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 INDEX, DROP INDEX

    重要

    • CASCADE や RESTRICT などの DDL 文内の追加情報はサポートされていません。

    • SET session_replication_role = replica コマンドが実行されるセッション内の DDL 文はサポートされていません。

    • FUNCTION やその他のメソッドを呼び出して実行される DDL 文はサポートされていません。

    • ソースデータベースから一度に送信される複数の SQL 文に DML と DDL の両方が含まれている場合、DDL 文は移行されません。

    • ソースデータベースから一度に送信される複数の SQL 文に、移行対象外のオブジェクトに対する DDL 文が含まれている場合、その DDL 文は移行されません。

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

    データベース

    必要な権限

    アカウントの作成と権限付与の方法

    PolarDB for PostgreSQL (Oracle 互換) クラスター

    特権アカウント

    データベースアカウントの作成と管理

    操作手順

    1. ターゲットリージョンの移行タスクリストページに移動します。以下のいずれかの方法を使用できます。

      DTS コンソールから

      1. Data Transmission Service (DTS) コンソールにログインします。

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

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

      DMS コンソールから

      説明

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

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

      2. 上部のナビゲーションバーで、データ + AI > Data Transmission (DTS) > データ移行 を選択します。

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

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

    3. ソースデータベースとターゲットデータベースを設定します。

      説明

      移行先の Message Queue for Apache Kafka インスタンスのパラメーターを取得する方法については、「Message Queue for Apache Kafka インスタンスのパラメーターを設定する」をご参照ください。

      カテゴリ

      構成

      説明

      N/A

      タスク名

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

      移行元データベース

      既存の接続情報の選択

      • システムに追加された (作成または保存された) データベースインスタンスを使用するには、ドロップダウンリストから目的のデータベースインスタンスを選択します。以下のデータベース情報が自動的に設定されます。

        説明

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

      • データベースインスタンスをシステムに登録していない場合、または登録済みのインスタンスを使用する必要がない場合は、以下のデータベース情報を手動で設定します。

      データベースタイプ

      PolarDB (Oracle と互換性) を選択します。

      アクセス方法

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

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

      ソースの PolarDB for PostgreSQL (Oracle 互換) クラスターが存在するリージョンを選択します。

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

      この例では、同じ Alibaba Cloud アカウント内でデータを移行します。× を選択します。

      インスタンス ID

      ソースの PolarDB for PostgreSQL (Oracle 互換) クラスターの ID を選択します。

      データベース名

      ソースの PolarDB for PostgreSQL (Oracle 互換) クラスターから移行するオブジェクトを含むデータベースの名前を入力します。

      データベースアカウント

      ソースの PolarDB for PostgreSQL (Oracle 互換) クラスターのデータベースアカウントを入力します。必要な権限については、「データベースアカウントに必要な権限」をご参照ください。

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

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

      移行先データベース

      既存の接続情報の選択

      • システムに追加された (作成または保存された) データベースインスタンスを使用するには、ドロップダウンリストから目的のデータベースインスタンスを選択します。以下のデータベース情報が自動的に設定されます。

        説明

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

      • データベースインスタンスをシステムに登録していない場合、または登録済みのインスタンスを使用する必要がない場合は、以下のデータベース情報を手動で設定します。

      データベースタイプ

      Kafka を選択します。

      アクセス方法

      Express Connect、VPN Gateway、または Smart Access Gateway を選択します。

      説明

      ここでは、Message Queue for Apache Kafka インスタンスは、移行インスタンスの自己管理 Kafka データベースとして設定されます。

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

      移行先の Message Queue for Apache Kafka インスタンスが存在するリージョンを選択します。

      接続中の VPC

      移行先の Message Queue for Apache Kafka インスタンスが属する VPC (Virtual Private Cloud) の ID を選択します。

      ドメイン名または IP アドレス

      ターゲットの ApsaraMQ for Kafka インスタンスの デフォルトエンドポイント から任意の IP アドレスを入力します。

      ポート番号

      ターゲットの ApsaraMQ for Kafka インスタンスのサービスポートを入力します。デフォルト値は 9092 です。

      データベースアカウント

      この例では、このパラメーターを入力する必要はありません。

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

      Kafka のバージョン

      Kafka インスタンスのバージョンを選択します。

      暗号化

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

      トピック

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

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

      Kafka スキーマレジストリは、Avro スキーマの保存と取得のための RESTful インターフェイスを提供するメタデータサービスレイヤーです。

      • ×：Kafka スキーマレジストリを使用しません。

      • ○：Kafka スキーマレジストリを使用します。スキーマレジストリの URL または IP アドレス テキストボックスに、Kafka スキーマレジストリに登録されている Avro スキーマの URL または IP アドレスを入力する必要があります。

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

      説明

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

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

    5. タスクオブジェクトを設定します。

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

        構成

        説明

        移行タイプ

        • 完全移行のみを実行する必要がある場合は、スキーマ移行 と 完全データ移行 の両方を選択します。

        • ゼロダウンタイム移行を実行するには、スキーマ移行、完全データ移行、および 増分データ移行 を選択します。

        説明

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

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

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

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

          説明

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

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

          警告

          エラーを無視して続行 を選択すると、データの不整合やビジネスリスクを引き起こす可能性があります。例：

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

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

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

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

        Kafka のデータ形式

        Kafka インスタンスに保存する目的のデータ形式を選択します。

        • Canal JSON を選択した場合、パラメーターの説明と例については、「Canal JSON」をご参照ください。

          説明

          現在、Canal JSON を選択できるのは、中国 (青島) および中国 (北京) リージョンのみです。

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

        • Shareplex JSON を選択した場合、パラメーターの説明と例については、「Shareplex Json」をご参照ください。

        Kafka 圧縮形式

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

        • LZ4 (デフォルト)：圧縮率は低いが、圧縮速度は速い。

        • GZIP：圧縮率は高いが、圧縮速度は遅い。

          説明

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

        • Snappy：圧縮率、圧縮速度ともに中間。

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

        目的のポリシーを選択します。

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

        目的のメッセージ確認メカニズムを選択します。

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

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

        説明

        Topic を選択しない場合、DDL 情報はデフォルトでデータを受信する Topic に保存されます。

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

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

        ソースオブジェクト

        ソースオブジェクト ボックスで、移行するオブジェクトをクリックし、向右小箭头 をクリックして 選択中のオブジェクト ボックスに移動します。

        説明

        移行するオブジェクトとしてテーブルを選択できます。

        選択中のオブジェクト

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

        説明

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

        • 増分移行の 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 を設定して、ターゲットデータベースへの圧力を軽減できます。

        説明

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

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

        環境タグ

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

        ETL 機能の設定

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

        監視アラート

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

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

        • ○：アラートを設定します。アラートのしきい値とアラート通知も設定する必要があります。移行が失敗した場合や遅延がしきい値を超えた場合に、システムはアラート通知を送信します。

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

      • API 操作を呼び出す際にこのインスタンスを設定するためのパラメーターを表示するには、次：タスク設定の保存と事前チェック ボタンにポインターを合わせ、バブル内の OpenAPI パラメーターのプレビュー をクリックします。

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

      説明

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

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

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

        • 無視できないチェック項目については、失敗した項目の横にある 詳細を表示 をクリックし、プロンプトに基づいて問題を修正してから、再度事前チェックを実行します。

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

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

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

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

        カテゴリ

        パラメーター

        説明

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

        リソースグループの設定

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

        インスタンスクラス

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

      3. 設定が完了したら、Data Transmission Service (従量課金) 利用規約 を読み、選択します。

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

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

        説明

        • 移行インスタンスに増分移行タスクが含まれていない場合、自動的に停止します。インスタンスが停止した後、その ステータス は 完了 になります。

        • 移行インスタンスに増分移行タスクが含まれている場合、自動的に停止せず、増分移行タスクは実行を続けます。増分移行タスクが正常に実行されている間、インスタンスの ステータス は 実行中 になります。

    マッピング情報

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

    2. ターゲット Topic について、編集 をクリックします。

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

      説明

      • スキーマレベルでは、ダイアログボックスは スキーマの編集 という名前で、設定可能なパラメーターが少なくなります。テーブルレベルでは、ダイアログボックスは テーブルの編集 という名前です。

      • 移行の粒度がスキーマ全体でない場合、スキーマの編集 ダイアログボックスで 対象トピックの名前 または パーティション数 を変更することはできません。

      構成

      説明

      対象トピックの名前

      ソーステーブルが移行されるターゲット Topic の名前。デフォルトでは、これは ソースデータベースとターゲットデータベースの設定 ステップの 移行先データベース セクションで選択された トピック です。

      重要

      • ターゲットデータベースが Message Queue for Apache Kafka インスタンスの場合、指定された Topic 名はターゲットの Kafka インスタンスに存在する必要があります。そうでない場合、データ移行は失敗します。ターゲットデータベースが自己管理 Kafka データベースで、移行インスタンスにスキーマ移行タスクが含まれている場合、DTS は指定した Topic をターゲットデータベースに作成しようとします。

      • 対象トピックの名前 を変更すると、データは指定した Topic に書き込まれます。

      フィルタリング条件

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

      パーティション数

      データが書き込まれるターゲット Topic のパーティション数。

      パーティションキー

      Kafka パーティションへのデータ転送ポリシー が 主キーのハッシュ値に基づいて、データを個別のパーティションに転送 に設定されている場合、このパラメーターを設定する必要があります。1 つ以上の列をパーティションキーとして指定してハッシュ値を計算します。DTS は、計算されたハッシュ値に基づいて、異なる行をターゲット Topic の各パーティションに配信します。そうでない場合、この配信ポリシーは増分書き込みフェーズで有効になりません。

      説明

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

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