CaptureChangeSqlServer 2025.5.31.15¶

捆绑包¶

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

描述¶

从 SQL 服务器数据库读取 CDC 事件。处理器定期查询数据库中的变更跟踪表，但仅限于 TableStateService 提供的表。处理器维护每个表上次处理的事件的状态。处理器在每个已处理的表之后移动位置。处理器支持多线程。池中配置的线程数和连接限制共同定义了与源数据库建立的开放连接的上限。处理器输出两种类型的 FlowFile：DDLs，包含表的初始架构，然后每次架构发生变化时都会输出；以及 DMLs，包含表中表明数据变化的记录。一个 FlowFile 始终表示与单个表相关的数据。包含架构的 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、event、jdbc、sql、sql server

输入要求¶

FORBIDDEN

支持敏感的动态属性¶

false

属性¶

状态管理¶

关系¶