このトピックでは、data Transmission Service (DTS) を使用して、PolarDB for PostgreSQLクラスターからのデータ変更を追跡する変更追跡タスクを作成する方法について説明します。
前提条件
ソースPolarDB for PostgreSQLクラスターが作成されました。 詳細については、「クラスターの作成」をご参照ください。
ApsaraDB RDS for MySQLインスタンスがクラシックネットワークタイプの場合、ApsaraDB RDS for MySQLインスタンスに内部エンドポイントが設定されます。
使用上の注意
カテゴリ | 説明 |
ソースデータベースの制限 |
|
その他の制限 |
|
手順
[追跡タスクの変更] ページに移動します。
データ管理 (DMS) コンソール にログインします。
上部のナビゲーションバーで、[DTS] をクリックします。
左側のナビゲーションウィンドウで、 を選択します。
説明DMSコンソールにログインし、右上隅の [Enter Simple Mode] アイコンをクリックすると、左上隅の [
] アイコンの上にポインターを移動し、 を選択できます。 詳細については、「DMSコンソールのレイアウトとスタイルのカスタマイズ」をご参照ください。 新しいDTSコンソールを使用して設定を構成することもできます。
[変更追跡タスク] の右側で、変更追跡タスクを作成するリージョンを選択します。
説明新しいDTSコンソールを使用する場合は、DTSコンソールの [追跡タスクの変更] ページの [ワークベンチ] の右側にあるドロップダウンリストからリージョンを選択する必要があります。
[タスクの作成] をクリックします。 表示されるページで、ソースデータベースインスタンスとコンシューマネットワークタイプを指定します。
警告ソースデータベースインスタンスを指定した後、ページの上部に表示される制限を読むことを推奨します。 そうしないと、タスクが失敗するか、追跡されたデータを消費できません。
セクション
パラメーター
説明
なし
タスク名
変更追跡タスクの名前。 DTSはタスクに名前を自動的に割り当てます。 タスクを簡単に識別できるように、わかりやすい名前を指定することをお勧めします。 一意のタスク名を使用する必要はありません。
ソースデータベース
既存のデータベース接続の選択
ソースデータベースが属するインスタンス。 ビジネス要件に基づいて、既存のインスタンスを使用するかどうかを選択できます。
既存のインスタンスを使用する場合、DTSはソースデータベースのパラメーター設定を自動的に適用します。
既存のインスタンスを使用しない場合は、ソースデータベースのパラメーターを設定する必要があります。
データベースタイプ
移行元ディスクのタイプを設定します。 [PolarDB for PostgreSQL] を選択します。
アクセス方法
ソースデータベースへのアクセスに使用されるサービス。 [Alibaba Cloudインスタンス] を選択します。
インスタンスリージョン
ソースPolarDB for PostgreSQLクラスターが存在するリージョン。
Alibaba Cloudアカウント全体でのデータの複製
複数のAlibaba Cloudアカウント間でデータをレプリケートするかどうかを指定します。 [いいえ] のみ選択できます。
インスタンスID
PolarDB for PostgreSQLインスタンスのID。
データベース名
ソースデータベースの名前。
データベースアカウント
ソースデータベースのアカウント。 PolarDB for PostgreSQLデータベースの特権アカウントを入力します。
データベースパスワード
データベースインスタンスへのアクセスに使用されるパスワード。
消費者ネットワークタイプ
ネットワークタイプ
[ネットワークタイプ] パラメーターの値は [VPC] に固定されています。 VPCとvSwitchを選択する必要があります。 詳細は、「VPC」をご参照ください。
説明変更追跡タスクを設定した後、[コンシューマーネットワークの種類] セクションの設定を変更することはできません。
変更追跡クライアントがVPCにデプロイされている場合、クライアントに接続されている同じVPCとvSwitchを選択することを推奨します。
内部ネットワーク上のデータ変更を追跡する場合、ネットワーク遅延は最小限に抑えられます。
ページの下部で、接続性をテストして続行をクリックします。
、ソースデータベースインスタンスが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。
変更追跡タスクのオブジェクトを選択し、詳細設定を構成します。
パラメーター
説明
データ変更の種類
追跡するデータ変更の種類。 [データ更新] のみ選択できます。 DTSは、選択したオブジェクトのデータ更新を追跡します。 データ更新には、INSERT、DELETE、およびUPDATE操作が含まれます。
ソースオブジェクト
[ソースオブジェクト] セクションから1つ以上のオブジェクトを選択し、
アイコンをクリックして [選択済みオブジェクト] セクションにオブジェクトを追加します。 説明変更追跡のオブジェクトとしてテーブルまたはデータベースを選択できます。
オブジェクトとしてデータベースを選択した場合、DTSはデータベース内の新しいオブジェクトを含むすべてのオブジェクトの増分データを追跡します。
オブジェクトとしてテーブルを選択した場合、DTSはこのテーブルの増分データのみを追跡します。 この場合、別のテーブルのデータ変更を追跡する場合は、テーブルをオブジェクトリストに追加する必要があります。 詳細については、「変更追跡用オブジェクトの変更」をご参照ください。
[次へ: 詳細設定] をクリックし、詳細設定を行います。
パラメーター
説明
Set Alerts
変更追跡タスクのアラートを設定するかどうかを指定します。 タスクが失敗するか、レイテンシが指定されたしきい値を超えると、指定されたアラート連絡先が通知を受信できます。 有効な値：
No: アラートを設定しません。
Yes: アラートを設定します。 この場合、アラートしきい値とアラート連絡先も指定する必要があります。
失敗した接続のリトライ時間範囲の指定
失敗した接続のリトライ時間範囲。 変更追跡タスクが失敗した場合、DTSはその時間範囲内ですぐに接続を再試行します。 有効な値: 10 ~ 1440 単位は分です。 デフォルト値: 120 時間範囲を30分以上に設定することを推奨します。 DTSが指定された時間範囲内にソースインスタンスに再接続すると、DTSは変更追跡タスクを再開します。 それ以外の場合、変更追跡タスクは失敗します。
説明インスタンスが複数の変更追跡タスクのソースまたはターゲットデータベースとして機能する場合、インスタンスに設定されている最短の再試行時間範囲が優先されます。
DTSが接続を再試行すると、DTSインスタンスに対して課金されます。 業務要件に基づいて再試行時間範囲を指定することを推奨します。 ソースインスタンスとターゲットインスタンスがリリースされた後、できるだけ早くDTSインスタンスをリリースすることもできます。
ETLの設定
抽出、変換、および読み込み (ETL) 機能を設定するかどうかを指定します。 ETLの詳細については、「ETLとは何ですか?」をご参照ください。有効な値：
Yes: ETL機能を設定します。 コードエディターでデータ処理ステートメントを入力できます。 詳細については、「データ移行または同期タスクでのETLの設定」をご参照ください。
No: ETL機能を設定しません。
ページの下部にある [次へ: タスク設定と事前チェック] をクリックします。
ポインタを 次：タスク設定の保存と事前チェック に移動し、[OpenAPIパラメーターのプレビュー] をクリックして、インスタンスを設定するために呼び出されるAPI操作のパラメーター設定を表示します。
説明変更追跡タスクを開始する前に、DTSは事前チェックを実行します。 タスクが事前チェックに合格した後にのみ、変更追跡タスクを開始できます。
タスクが事前チェックに合格しなかった場合は、失敗した各項目の横にある [詳細の表示] をクリックします。 エラーメッセージに基づいて問題をトラブルシューティングした後、事前チェックを再度実行できます。
事前チェック中にアイテムに対してアラートが生成された場合は、シナリオに基づいて次の操作を実行します。
アラートアイテムを無視できない場合は、失敗したアイテムの横にある [詳細の表示] をクリックして問題のトラブルシューティングを行います。 次に、もう一度プレチェックを実行します。
アラート項目を無視できる場合は、[アラート詳細の確認] をクリックします。 [詳細の表示] ダイアログボックスで、[無視] をクリックします。 表示されたメッセージボックスで、[OK] をクリックします。 次に、[再度事前チェック] をクリックして、事前チェックを再度実行します。 アラート項目を無視すると、データの不整合が発生し、ビジネスが潜在的なリスクにさらされる可能性があります。
成功率が100% になるまで待ちます。 次に、[次へ: インスタンスの購入] をクリックします。
[インスタンスの購入] ページで、変更追跡インスタンスの課金方法を指定します。 次の表にパラメーターを示します。
パラメーター
説明
課金方法
サブスクリプション: インスタンスの作成時にインスタンスの料金を支払います。 サブスクリプションの課金方法は、長期使用の場合、従量課金の課金方法よりも費用対効果が高くなります。
従量課金: 従量課金インスタンスは1時間ごとに課金されます。 従量課金方法は、短期使用に適しています。 従量課金インスタンスが不要になった場合は、従量課金インスタンスをリリースしてコストを削減できます。
サブスクリプションの長さ
サブスクリプションの課金方法を選択した場合は、サブスクリプション期間と作成するインスタンスの数を設定します。 サブスクリプション期間は、1~9 か月または 1~3 年です。
説明このパラメーターは、サブスクリプションの課金方法を選択した場合にのみ使用できます。 ビジネス要件に基づいて自動更新を有効にできます。
読み取りと選択データ伝送サービス (従量課金) サービス規約.
[購入と開始] をクリックして、変更追跡タスクを開始します。 タスクリストでタスクの進行状況を確認できます。
次のステップ
変更追跡タスクが実行されているときに、ダウンストリームクライアントに基づいてコンシューマグループを作成し、追跡されたデータを消費できます。
コンシューマーグループの作成および管理方法の詳細については、「コンシューマーグループの作成」をご参照ください。
次のいずれかの方法を使用して、追跡データを消費します。