我正在研究 POC,以从 Debezium 迁移到 AWS DMS for PostgreSQL。 PostgreSQL 作为源,Kafka 作为目标 (AWS MSK)。在 Debezium 中,我曾经看到更新之前和之后的图像,但在更新的 DMS 中,我只能看到同一个表的数据部分中的值之后。
我找不到任何有关如何获取之前图像的文档。这是预期的行为还是我需要更新任何设置才能获得之前的图像。
我正在使用 PostgresSQL 14.4 版本、DMS 复制实例引擎版本 3.5.1 和 AWS MSK 2.3.1
任何信息将不胜感激
我浏览了 Postgres 的 DMS 文档作为源,并通过互联网搜索以查看是否可以找到任何解决方案。但还没有找到太多有用的信息。
在 DMS 中,有一个称为“Beforeimage”的概念,这仅适用于 kafka 或 kinesis 等目标端点。
使用转换规则 - “add-before-image-columns”
示例:
"rules": [
{
"rule-type": "transformation",
"rule-id": "03282024",
"rule-name": "03282024",
"rule-target": "column",
"object-locator": {
"schema-name": "%",
"table-name": "%"
},
"rule-action": "add-before-image-columns",
"before-image-def": {
"column-prefix": "BI_",
"column-suffix": "",
"column-filter": "pk-only"
}
}