CaptureChangePostgreSQL 2025.10.2.19¶

Bundle¶

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

Beschreibung¶

Liest CDC-Ereignisse aus einer PostgreSQL-Datenbank. Der Prozessor liest kontinuierlich Ereignisse, die im Stream eintreffen, und filtert nach Ereignissen, die sich auf Tabellen beziehen, die vom TableStateService bereitgestellt werden, und der Rest wird verworfen. Nachdem der aktuelle Batch von Ereignissen verarbeitet wurde, bestätigt der Prozessor die Position des Replikations-Slots zurück an PostgreSQL, sodass der WAL-Wert abgeschnitten wird. Der Prozessor gibt zwei Arten von FlowFiles aus: DDLs, die das anfängliche Schema einer Tabelle enthalten, und jedes Mal, wenn sich das Schema ändert, und DMLs mit Datensätzen, die Änderungen an Daten in der Tabelle darstellen. Ein FlowFile steht immer für Daten, die sich auf eine einzelne Tabelle beziehen. Die DDL mit dem Schema wird in den FlowFile-Inhalt als JSON-Objekt geschrieben: { „columns“: [ { „name“: „<columnName>“, „type“: „<snowflakeType>“, „nullable“: <true|false>, „scale“: <scale>, „precision“: <precision> }, … ], „primaryKeys“: [„<primaryKey1>“, „<primaryKey2>“, …] } Die DML-Datensätze sind wie folgt strukturiert: { „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¶