FetchSourceTableSchema 2025.5.31.15¶

捆绑包¶

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

描述¶

提取数据库中给定表的表架构（即列名、数据类型等），将数据类型转换为与 Snowflake 兼容的类型。该架构以 JSON 对象形式写入 FlowFile 内容，例如：{ "columns": [ { "name": "<columnName>", "type": "<snowflakeType>", "nullable": <true|false>, "scale": <scale>, "precision": <precision> }, ... ], "primaryKeys": ["<primaryKey1>", "<primaryKey2>", ...]}

标签¶

输入要求¶

REQUIRED

支持敏感的动态属性¶

false

属性¶

属性	描述
Column Filter Service	指定用于筛选掉不需要的列的 Column Filter Service
连接池	用于提取源表架构的连接池
架构名称	存储源表的架构的名称
表名称	源表的名称

关系¶

名称	描述
failure	如果无法获取源表的架构，则会将 FlowFiles 路由到此关系
success	成功提取源表的架构后，会将 FlowFiles 路由到此关系
table not found	当源表不存在时，会将 FlowFiles 路由到此关系

写入属性¶

名称	描述
mime.type	application/json
dbms.type	存储源表的数据库管理系统 (DBMS) 的类型。例如 `POSTGRESQL`
primary.key.count	源表中主键的数量
column.count	源表中的列数