CaptureChangeSqlServer 2025.10.9.21¶

捆绑包¶

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

描述¶

从 SQL 服务器数据库读取 CDC 事件。处理器定期查询数据库中的变更跟踪表，但仅限于 TableStateService 提供的表。处理器维护每个表上次处理的事件的状态。处理器在每个已处理的表之后移动位置。处理器支持多线程。连接池中配置的线程数和连接上限共同定义了与源数据库保持打开连接的最大数量。处理器输出两种类型的 FlowFiles：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

属性¶

状态管理¶

关系¶