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

Data Transmission Service:ApsaraDB RDS for PostgreSQLインスタンスからのデータ変更の追跡

最終更新日:Nov 04, 2024

Data Transmission Service (DTS) を使用して、自己管理型PostgreSQLデータベースおよびApsaraDB RDS for PostgreSQLインスタンスからのデータ変更を追跡できます。 このトピックでは、ApsaraDB RDS for PostgreSQLインスタンスからのデータ変更を追跡する変更追跡タスクを作成する方法について説明します。

前提条件

  • ソースApsaraDB RDS for PostgreSQLインスタンスが作成されました。 詳細については、「ApsaraDB RDS For PostgreSQLインスタンスの作成」をご参照ください。

  • wal_levelパラメーターは、ソースApsaraDB RDS for PostgreSQLインスタンスのlogicalに設定されています。 詳細については、「ApsaraDB RDS For PostgreSQLインスタンスのパラメーターの変更」をご参照ください。

  • ソースApsaraDB RDS for PostgreSQLインスタンスは、PostgreSQL 9.4、10、11、12、13、14、または15を実行します。

  • ApsaraDB RDS for MySQLインスタンスがクラシックネットワークタイプの場合、ApsaraDB RDS for MySQLインスタンスに内部エンドポイントが設定されます。

使用上の注意

カテゴリ

説明

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

  • ソーステーブルにはPRIMARY KEYまたはUNIQUE制約が必要であり、すべてのフィールドが一意である必要があります。 そうでなければ、追跡されたデータ変更の一部が重複し得る。

  • 追跡するオブジェクトとしてテーブルを選択した場合、1回の変更追跡タスクで最大500のテーブルを追跡できます。 変更追跡タスクを実行して500を超えるテーブルを追跡すると、リクエストエラーが発生します。 この場合、複数のタスクを構成してテーブルをバッチで追跡するか、データベース全体の変更追跡タスクを構成することをお勧めします。

  • 先行書き込みログ (WAL) ログの次の要件を満たす必要があります。

    • wal_levelパラメーターの値は、logicalに設定する必要があります。

    • ソースデータベースのWALログは、24時間以上保存する必要があります。 そうしないと、DTSはWALログの取得に失敗し、変更追跡タスクが失敗する可能性があります。 例外的な状況では、データの不整合または損失が発生します。 上記の要件に基づいて、WALログの保持期間を設定してください。 そうしないと、DTSのサービスレベル契約 (SLA) に記載されているサービスの信頼性とパフォーマンスが保証されない場合があります。

  • ソースインスタンスが読み取り専用インスタンスまたは一時インスタンスの場合、インスタンスにトランザクションログが記録されていることを確認します。

  • ソースApsaraDB RDS for PostgreSQLインスタンスでプライマリ /セカンダリの切り替えを実行する必要がある場合は、Logical Replication Slotフェールオーバー機能を有効にする必要があります。 これにより、論理サブスクリプションが中断されるのを防ぎ、変更追跡タスクを期待どおりに実行できるようにします。 詳細については、「Logical Replication Slot Failover」をご参照ください。

その他の制限

  • 追跡する必要があれば スキーマの更新 ソースApsaraDB RDS for PostgreSQLインスタンスのDDL情報を取得するには、ソースデータベースにトリガーと関数を作成します。 詳細については、「トリガーと関数を使用してPostgreSQLデータベースの増分DDL移行を実装する」をご参照ください。

  • 変更追跡の待ち時間を正確にするために、DTSはソースデータベースにハートビートテーブルを追加します。 ハートビートテーブルの名前はdts_postgres_heartbeatです。

  • DTSが変更追跡タスクを実行すると、DTSはソースデータベースのレプリケーションスロットを作成します。 レプリケーションスロットの先頭にdts_sync_ があります。 DTSは、ストレージ使用量を減らすために、90分ごとに履歴レプリケーションスロットを自動的にクリアします。

    説明

    変更追跡タスクがリリースされるか失敗すると、DTSは自動的にレプリケーションスロットをクリアします。 ソースApsaraDB RDS for PostgreSQLインスタンスでプライマリ /セカンダリの切り替えが実行された場合、セカンダリデータベースにログインしてレプリケーションスロットをクリアする必要があります。

    Replication slot information

  • 1つの変更追跡タスクで、1つのデータベースからのデータ変更を追跡できます。 複数のデータベースからのデータ変更を追跡するには、各データベースの変更追跡タスクを作成する必要があります。

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

特別なケース

ソースApsaraDB RDS for PostgreSQLインスタンスからのデータ変更を追跡する場合、ApsaraDB RDS for PostgreSQLインスタンスのエンドポイントまたはゾーンを変更しないでください。 それ以外の場合、変更追跡タスクは失敗します。

手順

  1. [追跡タスクの変更] ページに移動します。

    1. データ管理 (DMS) コンソール にログインします。

    2. 上部のナビゲーションバーで、[DTS] をクリックします。

    3. 左側のナビゲーションウィンドウで、[DTS (DTS)] > [追跡の変更] を選択します。

    説明
  2. [変更追跡タスク] の右側で、変更追跡タスクを作成するリージョンを選択します。

    説明

    新しいDTSコンソールを使用する場合は、DTSコンソールの [追跡タスクの変更] ページの [ワークベンチ] の右側にあるドロップダウンリストからリージョンを選択する必要があります。

  3. [タスクの作成] をクリックします。 表示されるページで、ソースデータベースインスタンスとコンシューマネットワークタイプを指定します。

    警告

    ソースデータベースインスタンスを指定した後、ページの上部に表示される制限を読むことを推奨します。 そうしないと、タスクが失敗するか、追跡されたデータを消費できません。

    セクション

    パラメーター

    説明

    なし

    タスク名

    変更追跡タスクの名前。 DTSはタスクに名前を自動的に割り当てます。 タスクを簡単に識別できるように、わかりやすい名前を指定することをお勧めします。 一意のタスク名を使用する必要はありません。

    ソースデータベース

    既存のデータベース接続の選択

    ソースデータベースが属するインスタンス。 ビジネス要件に基づいて、既存のインスタンスを使用するかどうかを選択できます。

    • 既存のインスタンスを使用する場合、DTSはソースデータベースのパラメーター設定を自動的に適用します。

    • 既存のインスタンスを使用しない場合は、ソースデータベースのパラメーターを設定する必要があります。

    データベースタイプ

    移行元ディスクのタイプを設定します。 [PostgreSQL] を選択します。

    アクセス方法

    ソースデータベースへのアクセスに使用されるサービス。 [Alibaba Cloudインスタンス] を選択します。

    インスタンスリージョン

    ソースApsaraDB RDS for PostgreSQLインスタンスが存在するリージョン。

    インスタンスID

    ソースApsaraDB RDS for PostgreSQLインスタンスのID。

    データベース名

    ソースデータベースの名前。

    データベースアカウント

    ソースデータベースのアカウント。 ApsaraDB RDS for PostgreSQLインスタンスの特権アカウントを入力します。 アカウントはデータベースの所有者である必要があります。 ApsaraDB RDS For PostgreSQLインスタンスにアカウントを作成し、このアカウントに権限を付与する方法の詳細については、「アカウントの作成」および「データベースの作成」をご参照ください。

    データベースパスワード

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

    消費者ネットワークタイプ

    ネットワークタイプ

    [ネットワークタイプ] パラメーターの値は [VPC] に固定されています。 VPCvSwitchを選択する必要があります。 詳細は、「VPC」をご参照ください。

    説明
    • 変更追跡タスクを設定した後、[コンシューマーネットワークの種類] セクションの設定を変更することはできません。

    • 変更追跡クライアントがVPCにデプロイされている場合、クライアントに接続されている同じVPCvSwitchを選択することを推奨します。

    • 内部ネットワーク上のデータ変更を追跡する場合、ネットワーク遅延は最小限に抑えられます。

  4. ページの下部で、接続性をテストして続行をクリックします。

    、ソースデータベースインスタンスがApsaraDB RDS for MySQLまたはApsaraDB for MongoDBインスタンスなどのAlibaba Cloudデータベースインスタンスの場合、DTSは自動的に対応するリージョンのDTSサーバーのCIDRブロックをインスタンスのホワイトリストに追加します。 ソースデータベースインスタンスがECSインスタンス上でホストされている自己管理データベースである場合、DTSは、対応するリージョンのDTSサーバーのCIDRブロックをECSインスタンスのセキュリティグループルールに自動的に追加します。 DTSがデータベースにアクセスできるようにするには、対応するリージョンのDTSサーバーのCIDRブロックをデータベースのセキュリティ設定に手動で追加する必要もあります。 ソースデータベースインスタンスがデータセンターにデプロイされているか、サードパーティのクラウドサービスプロバイダーによって提供されている自己管理データベースの場合、対応するリージョンのDTSサーバーのCIDRブロックをデータベースのセキュリティ設定に手動で追加して、DTSがデータベースにアクセスできるようにする必要があります。 詳細については、「DTSサーバーのCIDRブロックの追加」の「DTSサーバーのCIDRブロック」セクションをご参照ください。

    警告

    DTSサーバーのパブリックCIDRブロックがデータベースインスタンスのホワイトリストまたはECSインスタンスのセキュリティグループルールに自動的または手動で追加されると、セキュリティリスクが発生する可能性があります。 したがって、DTSを使用してデータ変更を追跡する前に、潜在的なリスクを理解して認識し、次の対策を含む予防策を講じる必要があります。VPNゲートウェイ、またはSmart Access Gateway。

  5. 変更追跡と詳細設定のオブジェクトを設定します。

    • 基本設定

      パラメーター

      説明

      データ変更の種類

      • データ更新

        DTSは、INSERT、DELETE、およびUPDATE操作を含む、選択したオブジェクトのデータ更新を追跡します。

      • スキーマ更新

        DTSは、ソースインスタンスのすべてのオブジェクトスキーマで実行される作成、削除、および変更操作を追跡します。 変更追跡クライアントを使用して、追跡するデータをフィルタリングする必要があります。

      説明

      [スキーマ更新] を選択した場合、ソースデータベースのDDL情報を取得するために、ソースデータベースにトリガーと関数を作成する必要があります。 詳細については、「トリガーと関数を使用してPostgreSQLデータベースの増分DDL移行を実装する」をご参照ください。

      ソースオブジェクト

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

      説明

      変更追跡のオブジェクトとしてテーブルまたはデータベースを選択できます。

      • オブジェクトとしてデータベースを選択した場合、DTSはデータベース内の新しいオブジェクトを含むすべてのオブジェクトの増分データを追跡します。

      • オブジェクトとしてテーブルを選択した場合、DTSはこのテーブルの増分データのみを追跡します。 この場合、別のテーブルのデータ変更を追跡する場合は、テーブルをオブジェクトリストに追加する必要があります。 詳細については、「変更追跡用オブジェクトの変更」をご参照ください。

    • 詳細設定

      パラメーター

      説明

      Set Alerts

      変更追跡タスクのアラートを設定するかどうかを指定します。 タスクが失敗するか、レイテンシが指定されたしきい値を超えると、指定されたアラート連絡先が通知を受信できます。 有効な値:

      • No: アラートを設定しません。

      • Yes: アラートを設定します。 この場合、アラートしきい値とアラート連絡先も指定する必要があります。

      失敗した接続のリトライ時間範囲の指定

      失敗した接続のリトライ時間範囲。 変更追跡タスクが失敗した場合、DTSはその時間範囲内ですぐに接続を再試行します。 有効な値: 10 ~ 1440 単位は分です。 デフォルト値: 120 時間範囲を30分以上に設定することを推奨します。 DTSが指定された時間範囲内にソースインスタンスに再接続すると、DTSは変更追跡タスクを再開します。 それ以外の場合、変更追跡タスクは失敗します。

      説明
      • インスタンスが複数の変更追跡タスクのソースまたはターゲットデータベースとして機能する場合、インスタンスに設定されている最短の再試行時間範囲が優先されます。

      • DTSが接続を再試行すると、DTSインスタンスに対して課金されます。 業務要件に基づいて再試行時間範囲を指定することを推奨します。 ソースインスタンスとターゲットインスタンスがリリースされた後、できるだけ早くDTSインスタンスをリリースすることもできます。

      ETLの設定

      抽出、変換、および読み込み (ETL) 機能を設定するかどうかを指定します。 詳細については、「」をご参照ください。ETLとは何ですか?. 有効な値:

      • Yes: ETL機能を設定します。 コードエディターでポリシーを入力できます。

      • No: ETL機能を設定しません。

  6. ページの下部にある [次へ: タスク設定と事前チェック] をクリックします。

    ポインタを 次:タスク設定の保存と事前チェック に移動し、[OpenAPIパラメーターのプレビュー] をクリックして、インスタンスを設定するために呼び出されるAPI操作のパラメーター設定を表示します。

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

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

    • 事前チェック中にアイテムに対してアラートが生成された場合は、シナリオに基づいて次の操作を実行します。

      • アラートアイテムを無視できない場合は、失敗したアイテムの横にある [詳細の表示] をクリックして問題のトラブルシューティングを行います。 次に、もう一度プレチェックを実行します。

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

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

  8. [購入] ページで、変更追跡インスタンスの課金方法を指定します。 次の表にパラメーターを示します。

    パラメーター

    説明

    課金方法

    • サブスクリプション: インスタンスの作成時にサブスクリプションの料金を支払います。 サブスクリプションの課金方法は、長期使用の場合、従量課金の課金方法よりも費用対効果が高くなります。 サブスクリプション期間が長くなると、低価格が提供されます。

    • 従量課金: 従量課金インスタンスは1時間ごとに課金されます。 短期使用の場合は、従量課金の課金方法を選択することを推奨します。 従量課金インスタンスが不要になった場合は、インスタンスをリリースしてコストを削減できます。

    リソースグループ設定

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

    サブスクリプション期間

    サブスクリプションの課金方法を選択した場合は、サブスクリプション期間と作成するインスタンスの数を設定します。 サブスクリプション期間は、1〜9か月、1年、2年、3年、または5年とすることができる。

    説明

    このパラメーターは、[サブスクリプション] の課金方法を選択した場合にのみ使用できます。

  9. 読み取りと選択データ伝送サービス (従量課金) サービス規約.

  10. [購入と開始] をクリックして、変更追跡タスクを開始します。 タスクリストでタスクの進行状況を確認できます。

次のステップ

変更追跡タスクが実行されているときに、ダウンストリームクライアントに基づいてコンシューマグループを作成し、追跡されたデータを消費できます。

  1. コンシューマーグループの作成および管理方法の詳細については、「コンシューマーグループの作成」をご参照ください。

  2. 次のいずれかの方法を使用して、追跡データを消費します。