EnrichCdcStream 2025.5.31.15¶
捆绑包¶
com.snowflake.openflow.runtime | runtime-database-cdc-processors-nar
描述¶
为来自 CaptureChangePostgreSQL 等的传入 FlowFiles 添加有关应写入哪个日志表及相关架构信息的数据。该处理器管理每个被处理表的架构版本，以确保为每个 FlowFile 使用正确的日志表。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
CDC 架构注册表 |
指定用于管理 CDC 数据架构的 CDC 架构注册表 |
记录读取器 |
指定用于读取传入数据的记录读取器 |
记录写入器 |
指定用于写入传出数据的记录写入器 |
表状态服务 |
保存复制表的状态 |
状态管理¶
范围 |
描述 |
|---|---|
CLUSTER |
跟踪每个正在处理的表所对应的当前日志表版本。 |
关系¶
名称 |
描述 |
|---|---|
failure |
如果某个 FlowFile 无法读取，则将路由到此关系。 |
schema update |
如果需要任何架构更新来处理传入的记录，FlowFile 则将路由到此关系。FlowFile 将包括架构信息，以表明需要进行哪些更改。 |
skipped ddl event |
此关系将用于处理那些不会导致目标表架构变化的 DDL / 架构更改事件的关系。 |
success |
要插入到 Snowflake 表中的行将路由到此关系。 |
table not in state |
当 FlowFile 引用的表在复制表的状态中不存在（可能是因为该表已从复制中移除）时使用。 |
写入属性¶
名称 |
描述 |
|---|---|
table.schema.generation |
用于增量处理的日志表索引。 |
table.schema.initial |
标记日志表的初始生成。 |
destination.table.schema |
目标表的更新架构。此属性仅为 DDL 事件编写。 |