CaptureChangeSqlServer 2025.5.31.15¶

バンドル¶

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

説明¶

SQL Server データベースから CDC イベントを読み込みます。プロセッサーは定期的にデータベース内のChange Trackingテーブルで、 TableStateService に発行されたテーブルに対してのみクエリを発行します。プロセッサーは、各テーブルの最後に処理されたイベントの状態を保持します。プロセッサーは、各テーブルを処理した後に位置を移動します。プロセッサーはマルチスレッドに対応しています。プールで構成されたスレッド数と接続制限は、ソースデータベースへのオープン接続の上限を定義します。プロセッサーは2種類のフロータイプを出力します。: DDLs はテーブルの最初のスキーマを含み、その後もスキーマが変わるたびに、 DMLs はテーブルで変更されたデータの記録を表示します。1つの FlowFile は常に1つのテーブルに関連するデータを表します。スキーマを含む DDL は JSON オブジェクトとして FlowFile のコンテンツに以下のように書き込まれます。:{ "columns": [ { "name": "<columnName>", "type": "<snowflakeType>", "nullable": <true|false>, "scale": <scale>, "precision": <precision> }, ... ], "primaryKeys": ["<primaryKey1>", "<primaryKey2>", ...]}The DML records are structured as:{ "primaryKeys": { "<column>": <value>, ... }, "payload": { "<column>": <value>, ... }, "metadata": { "<column>": <value>, ... }}

タグ¶

cdc, イベント, jdbc, sql, sql server

入力要件¶

FORBIDDEN

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

false

プロパティ¶

状態管理¶

リレーションシップ¶