sql-server - Amazon DMS 能否在更改 Kafka 前后生成记录状态？

Question

我们正在试验使用 Amazon DMS 作为 Debezium 的替代方案，用于对 Kafka 进行 SQL Server 数据库更改。一切进展顺利，但我们将在 DMS 中错过 Debezium 的一个特性：Kafka 中的消息能够包含更改之前和之后的记录状态。似乎使用 DMS，您只能获得记录的之后版本，而不是之前版本。在某个地方有这个设置吗？我找不到任何表明存在的文档，但我想在我放弃之前我会问 Stack Overflow 的 hivemind。

Answer 1

您可以尝试使用 beforeimage 任务设置来获取之前的图像数据记录，这将为您提供具有指定前缀和列名后缀的之前记录值。在您的任务设置中添加以下转换规则以获得所需的输出。

{
      "rule-type": "transformation",
      "rule-id": "2",
      "rule-name": "2",
      "rule-target": "column",
      "object-locator": {
        "schema-name": "%",
        "table-name": "employees"
      },
      "rule-action": "add-before-image-columns",
      "before-image-def": {
        "column-prefix": "BI_",
        "column-suffix": "",
        "column-filter": "pk-only"
      }
    }