翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

AWS DMS を使用した継続的なレプリケーションのタスクの作成

ソースデータストアから継続的な変更をキャプチャする AWS DMS タスクを作成できます。このキャプチャはデータの移行中に実行できます。サポートされているターゲットデータストアへの初めての (フルロード) 移行が完了した後に、継続的な変更をキャプチャするタスクを作成することもできます。このプロセスは継続的なレプリケーションまたは変更データキャプチャ (CDC) と呼ばれます。AWS DMS では、このプロセスを使用してソースデータストアの継続的な変更をレプリケートします。データベースエンジンのネイティブ API を使用してデータベースログへの変更を収集することが、このプロセスの仕組みです。

各ソースエンジンには、この変更ストリームを特定のユーザーアカウントにパブリッシュするための固有の設定要件があります。ほとんどのエンジンでは、キャプチャプロセスがデータを損失することなく意味のある方法で変更データを使用できるようにするために、追加の設定が必要になります。例えば、Oracle ではサプリメンタルロギングの追加が必要であり、MySQL では行レベルのバイナリログ (bin ログ) が必要です。

ソースデータベースから継続的な変更を読み取るために、AWS DMS はエンジン固有の API アクションを使用してソースエンジンのトランザクションログから変更を読み取ります。AWS DMS での実際の例は次のとおりです。

継続的なレプリケーションタスクには 2 つのタイプがあります。

CDC 開始点を起点とするレプリケーションの実行

AWS DMS の継続的なレプリケーションタスク (変更データキャプチャのみ) は、複数の開始点から開始できます。これには次が含まれます。

タスクが作成されると、AWS DMS は CDC の開始点にマークが付けられます。これを変更することはできません。別のCDC開始点を使用するには、新しいタスクを作成します。

CDC ネイティブ開始点の決定

CDC ネイティブ開始点は、CDC を開始できる時間を定義するデータベースエンジンのログ内の開始点です。一括データダンプが既にターゲットに適用されている場合を例にとって説明します。この場合、継続的なレプリケーションのみのタスクのネイティブ開始点を検索できます。データの不整合を回避するには、レプリケーションのみのタスクの開始点は慎重に選択します。DMS は、選択された CDC 開始点の後に開始されたトランザクションをキャプチャします。

サポートされているソースエンジンから CDC ネイティブ開始点を検索する方法の例は次のとおりです。

CDC 開始点としてのチェックポイントの使用

継続的なレプリケーションタスクが変更を移行し、AWS DMS では AWS DMS 固有のチェックポイント情報を随時キャッシュします。AWS DMS が作成するチェックポイントには、レプリケーションエンジンが変更ストリームの復旧点を認識できる情報が含まれています。チェックポイントを使用すると、変更のタイムラインに戻り、失敗した移行タスクを回復できます。また、チェックポイントを使用して、任意の時点で別のターゲットに対して別の継続的なレプリケーションタスクを開始することもできます。

チェックポイント情報の取得には、次の 3 つのいずれかの方法を使用します。

コミット時点またはサーバー時間のポイントでのタスクの停止

CDC ネイティブ開始点の導入により、AWS DMS は次の時点でタスクを停止することもできます。

必要に応じてタスクを変更して、停止する時刻を UTC で設定できます。タスクは、設定したコミット時間またはサーバー時間に基づいて自動的に停止します。または、タスクの作成時に移行タスクを停止する時間が明らかである場合は、タスクの作成時に停止時刻を設定できます。

双方向レプリケーションの実行

AWS DMS タスクを使用して、2 つのシステム間で双方向レプリケーションを実行できます。双方向レプリケーションの場合、2 つのシステム間で同じテーブル (またはテーブルセット) のデータを両方向にレプリケートできます。

例えば、EMPLOYEE テーブルをデータベース A からデータベース B にコピーして、このテーブルに対する変更をデータベース A からデータベース B にレプリケートできます。また、EMPLOYEE テーブルに対する変更をデータベース B から A にレプリケートすることもできます。つまり、双方向にレプリケートすることになります。

双方向レプリケーションは、異なるノード上のデータが運用上分離されている状況で使用します。つまり、ノード A で動作しているアプリケーションが変更したデータ要素があり、そのノード A がノード B との双方向レプリケーションを実行するとします。ノード A のそのデータ要素は、ノード B で動作するアプリケーションによって変更されることはありません。

AWS DMS は、次のデータベースエンジンで双方向レプリケーションをサポートしています。

双方向レプリケーションタスクの作成

AWS DMS 双方向レプリケーションを有効にするには、両方のデータベース(A と B) のソースエンドポイントとターゲットエンドポイントを設定します。例えば、データベース A のソースエンドポイント、データベース B のソースエンドポイント、データベース A のターゲットエンドポイント、データベース B のターゲットエンドポイントを設定します。

次に、ソース A がデータをターゲット B に移動するタスクと、ソース B がデータをターゲット A に移動するタスクの 2 つのタスクを作成します。さらに、各タスクでループバック防止機能が設定されていることを確認します。これにより、両方のタスクのターゲットに同一の変更が適用されることが避けられ、少なくとも一方のタスクのデータが破損するのを防ぐことができます。詳細については、「ループバックの防止」を参照してください。

最も簡単な方法としては、まずデータベース A とデータベース B の両方に同一のデータセットを作成します。次に CDC のみのタスクを 2 つ作成します。1 つは A から B にデータをレプリケートするタスクで、もう 1 つは B から A にデータをレプリケートするタスクです。

AWS DMS を使用してノード A からノード B の新しいデータセット (データベース) をインスタンス化するには、次を実行します。

ループバックの防止

タスク T1 で AWS DMS がソースデータベース A から変更ログを読み取り、ターゲットデータベース B に変更内容を適用するケースを例に、ループバックの防止について説明します。

次に、2 番目のタスクである T2 がソースデータベース B から変更ログを読み取り、ターゲットデータベース A に適用します。T2 がこれを行う前に、DMS では、ソースデータベース A からターゲットデータベース B に対して行われたのと同じ変更がソースデータベース B に対して行われていないことを確認する必要があります。つまり、DMS は、このような変更がターゲットデータベース A にエコー (ループ) されないことを確認する必要があります。これを行わないと、データベース A のデータが破損する可能性があります。

変更のループバックを回避するには、各双方向レプリケーションタスクに次のタスク設定を追加します。これにより、どちらの方向でもループバックデータの破損が発生しないようにします。

{
. . .

  "LoopbackPreventionSettings": {
    "EnableLoopbackPrevention": Boolean,
    "SourceSchema": String,
    "TargetSchema": String
  },

. . .
}

LoopbackPreventionSettings タスク設定により、トランザクションが新規であるか、反対方向のレプリケーションタスクからのエコーであるかが定まります。AWS DMS がトランザクションをターゲットデータベースに適用すると、変更を示す DMS テーブル (awsdms_loopback_prevention) が更新されます。各トランザクションをターゲットに適用する前に、DMS はこの awsdms_loopback_prevention テーブルへの参照を含むトランザクションをすべて無視します。したがって、変更は適用されません。

双方向ペアの各レプリケーションタスクにこのようなタスク設定を含めます。このような設定により、ループバック防止機能が有効になります。さらに、この設定は、各エンドポイントの awsdms_loopback_prevention テーブルを含むタスク内の各ソースデータベースとターゲットデータベースのスキーマも指定します。

各タスクがこのようなエコーを識別して破棄できるようにするには、EnableLoopbackPrevention を true に設定します。awsdms_loopback_prevention を含むソースでスキーマを指定するには、SourceSchema をソースデータベース内の該当するスキーマ名に設定します。同じテーブルを含むターゲットでスキーマを指定するには、TargetSchema をターゲットデータベース内の該当するスキーマ名に設定します。

次の例では、レプリケーションタスク T1 とその反対方向のレプリケーションタスク T2 の SourceSchema 設定と TargetSchema 設定が、反対方向の設定で指定されています。

タスク T1 の設定は、次のとおりです。

{
. . .

  "LoopbackPreventionSettings": {
    "EnableLoopbackPrevention": true,
    "SourceSchema": "LOOP-DATA",
    "TargetSchema": "loop-data"
  },

. . .
}

反対方向のタスク T2 の設定は、次のとおりです。

{
. . .

  "LoopbackPreventionSettings": {
    "EnableLoopbackPrevention": true,
    "SourceSchema": "loop-data",
    "TargetSchema": "LOOP-DATA"
  },

. . .
}

双方向レプリケーションの制限

AWS DMS の双方向レプリケーションには、次の制限があります。