前イメージタスク設定前
Kinesis や Apache Kafka のようなデータストリーミングターゲットに CDC 更新を書き込む場合、更新により変更される前のソースデータベース行の元の値を表示できます。これを実現するために、AWS DMS は、ソースデータベースエンジンから提供されたデータに基づいて更新イベントの前イメージを設定します。タスク設定ファイルを使用してタスク設定を設定する方法については、「タスク設定例」をご参照ください。
これを行うには、ソースデータベースシステムから収集された値を使用して、すべての更新オペレーションに新しい JSON 属性を追加する BeforeImageSettings パラメータを使用します。
BeforeImageSettings を全ロードと CDC タスクのみ、または CDC のみのタスクに適用することを忘れないでください。全ロードと CDC タスクにより、既存のデータが移行され、継続的変更のレプリケーションをできます。CDC のみのタスクは、データ変更のみのレプリケーションとなります。
全ロードのタスクには BeforeImageSettings を適用しないでください。
BeforeImageSettings で考えられるオプション:
-
EnableBeforeImage— に設定すると、前イメージが有効になります。trueデフォルトはfalseです。 -
FieldName— 新しい JSON 属性に名前を割り当てます。EnableBeforeImageがtrueの場合、FieldNameは必須であり、空にすることはできません。 -
ColumnFilter— 前イメージを使用して追加する列を指定します。テーブルのプライマリキーの一部である列だけを追加するには、デフォルト値pk-onlyを使用します。前イメージ値を持つ列を追加するには、allを使用します。変換前イメージは、CLOB や BLOB などのラージバイナリオブジェクト (LOB) データ型をサポートしていないことに注意します。
BeforeImageSettings の使用例:
"BeforeImageSettings": { "EnableBeforeImage": true, "FieldName": "before-image", "ColumnFilter": "pk-only" }
追加のテーブルマッピング設定など、前イメージ設定前の詳細については、「前イメージを使用した Kinesis データストリームの CDC 行の元の値のターゲットとしての表示」をご参照ください。
追加のテーブルマッピング設定を含む、Kafka の前イメージ設定の詳細については、「ターゲットとして Apache Kafka の CDC 行の元の値を表示するために前イメージを使用」をご参照ください。