Module debezium

Macros

• jsonb_access_field 🔒

Structs

• DebeziumChangeEvent
• MongoJsonAccess

Constants

• AFTER 🔒
• BEFORE 🔒
• DEBEZIUM_CREATE_OP
• DEBEZIUM_DELETE_OP
• DEBEZIUM_READ_OP
• DEBEZIUM_TRANSACTION_STATUS_BEGIN
• DEBEZIUM_TRANSACTION_STATUS_COMMIT
• DEBEZIUM_UPDATE_OP
• OP 🔒
• SOURCE 🔒
• SOURCE_COLLECTION 🔒
• SOURCE_DB 🔒
• SOURCE_SCHEMA 🔒
• SOURCE_TABLE 🔒
• SOURCE_TS_MS 🔒
• TABLE_CHANGES
• TRANSACTION_ID
• TRANSACTION_STATUS
• UPSTREAM_DDL 🔒

Functions

• extract_bson_id
• parse_schema_change
  Parse the schema change message from Debezium. The layout of MySQL schema change message can refer to https://debezium.io/documentation/reference/2.6/connectors/mysql.html#mysql-schema-change-topic
• parse_transaction_meta