CaptureChangePostgreSQL 2025.5.31.15¶

Bundle¶

com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar

Beschreibung¶

Liest CDC-Ereignisse aus einer PostgreSQL-Datenbank. Der Prozessor liest fortlaufend die Ereignisse, die im Stream ankommen, filtert diejenigen heraus, die mit den von TableStateService bereitgestellten Tabellen in Verbindung stehen, und verwirft den Rest. Nachdem der aktuelle Batch von Ereignissen verarbeitet wurde, bestätigt der Prozessor die Position des Replikationsslots zurück an PostgreSQL und lässt ihn die WAL bearbeiten. Der Prozessor gibt zwei Arten von FlowFiles aus: DDLs, die das ursprüngliche Schema und ein neues Schema bei jeder Schemaänderung enthält, und DMLs mit Datensätzen, die Änderungen an den Daten in der Tabelle darstellen. Ein FlowFile repräsentiert immer Daten, die sich auf eine einzige Tabelle beziehen. Die DDL mit dem Schema wird als JSON-Objekt in den FlowFile-Inhalt geschrieben, in einer Form wie:{ „columns“: [ { „name“: „<columnName>“, „type“: „<snowflakeType>“, „nullable“: <true|false>, „scale“: <scale>, „precision“: <precision> }, … ], „primaryKeys“: [„<primaryKey1>“, „<primaryKey2>“, …]}. Die DML-Datensätze sind wie folgt aufgebaut:{ „primaryKeys“: { „<column>“: <value>, … }, „payload“: { „<column>“: <value>, … }, „metadata“: { „<column>“: <value>, … }}

Tags¶

cdc, event, jdbc, postgresql, sql

Eingabeanforderung¶

FORBIDDEN

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Statusmanagement¶

Beziehungen¶

Schreibt Attribute¶