CaptureChangePostgreSQL 2025.5.31.15¶

バンドル¶

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

説明¶

PostgreSQL データベースから CDC イベントを読み込みます。プロセッサーはストリームに到着するイベントを継続的に読み込み、 TableStateService が提供するテーブルに関連するものをフィルターし、残りを破棄します。現在のイベントのバッチが処理された後、プロセッサーは複製スロットの位置を PostgreSQL に確認し、 WAL をトリミングさせます。プロセッサーは2タイプのフローファイルを出力します: DDLs は最初のテーブルのスキーマを含み、 DMLs はテーブルのデータへの変更の記録を表し、スキーマが変わる度にテーブルのデータへの変更の記録を表します。1つのフローファイルは常に1つのテーブルに関連するデータを表します。スキーマを含む DDL は、下記の形式で JSON オブジェクトとして FlowFile コンテンツに書き込まれます。{ "columns": [ { "name": "<columnName>", "type": "<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

プロパティ¶

状態管理¶

リレーションシップ¶

属性の書き込み¶