CaptureChangeSqlServer 2025.10.2.19¶

バンドル¶

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

説明¶

SQL サーバーデータベースから CDC イベントを読み取ります。プロセッサーはデータベース内の変更追​​跡テーブルを定期的にクエリしますが、対象は TableStateService によって提供されるテーブルのみです。プロセッサーは、各テーブルで最後に処理されたイベントの状態を維持します。プロセッサーは、処理された各テーブルの後の位置を移動します。プロセッサーはマルチスレッドをサポートしています。プールに設定されたスレッド数と接続制限によって、ソースデータベースへのオープン接続の上限が総合的に定義されます。プロセッサーは2種類の FlowFiles を出力します。DDLs にはテーブルの初期スキーマが含まれ、その後スキーマが変更されるたびに出力されます。DMLs にはテーブル内のデータの変更を表すレコードが含まれます。1つの FlowFile は常に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, sql, sql server

入力要件¶

FORBIDDEN

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

false

プロパティ¶

状態管理¶

リレーションシップ¶