Может ли Amazon DMS сформировать состояние записи до и после перехода на Kafka?

Question

Мы экспериментируем с Amazon DMS в качестве альтернативы Debezium для внесения изменений базы данных SQL Server в Kafka. Все идет хорошо, но есть одна особенность Debezium, которую нам будет не хватать в DMS: возможность сообщений в Kafka содержать состояние записи как до, так и после того, как было внесено изменение. Похоже, что с DMS вы получаете только последующую версию записи, а не предыдущую. Есть ли где-нибудь настройка для этого? Мне не удалось найти никакой документации, подтверждающей это, но я решил, что спрошу коллектив stackru, прежде чем сдамся.

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"
      }
    }