CaptureChangePostgreSQL 2025.10.2.19¶

バンドル¶

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

説明¶

PostgreSQL データベースから CDC イベントを読み込みます。プロセッサーは、ストリームに到着したイベントを継続的に読み込み、 TableStateService によって提供されたテーブルに関連するイベントをフィルタリングし、残りを破棄します。現在のイベントのバッチ処理が完了すると、プロセッサーは複製スロットの位置を PostgreSQL に確認として返し、 WAL をトリミングできるようにします。プロセッサーは2種類の FlowFiles を出力します。DDLs にはテーブルの初期スキーマが含まれ、その後スキーマが変更されるたびに出力されます。DMLs にはテーブル内のデータの変更を表すレコードが含まれます。1つの FlowFile は常に1つのテーブルに関連するデータを表します。スキーマを含む DDL は、 FlowFile コンテンツ内に JSON オブジェクトとして書き込まれ、次のような形式になります： "<snowflakeType>", "nullable": <true|false>, "scale": <scale>, "precision": <precision> }, ... ], "primaryKeys": ["<primaryKey1>", "<primaryKey2>", ...] } DML レコードは以下のような構造ｎ造いなっています： { "primaryKeys": { "<column>": <value>, ... }, "payload": { "<column>": <value>, ... }, "metadata": { "<column>": <value>, ... }

タグ¶

cdc、イベント、jdbc、postgresql、sql

入力要件¶

FORBIDDEN

機密動的プロパティをサポート¶

false

プロパティ¶

状態管理¶

リレーションシップ¶

属性の書き込み¶