ConsumeSnowflakeStream 2025.5.31.15¶

捆绑包¶

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

描述¶

从 Snowflake 流中获取数据并将其写入 FlowFile。在使用此处理器之前，必须在数据库中创建流。处理器将使用该流并使用指定的记录写入器将记录写入到 FlowFile。处理器还将使用该流的名称为 FlowFile 添加一个属性。如果流过时，处理器将无法运行。相反，它将记录一条错误消息并停止处理。必须在数据库中重新创建过时的流。在数据库中重新创建数据流后，处理器将继续读取和处理 CDC 记录。有关 Snowflake 流的更多信息，请参阅 <a href="https://docs.snowflake.cn/en/user-guide/streams-intro">Snowflake 文档</a>。

标签¶

connection、database、jdbc、openflow、snowflake、stream、table、view

输入要求¶

FORBIDDEN

支持敏感的动态属性¶

false

属性¶

关系¶

写入属性¶