ConsumeSnowflakeStream 2025.10.2.19¶

Bundle¶

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

Beschreibung¶

Fetches data from a Snowflake stream and writes it to a FlowFile. The stream must be created in the database before using this processor. The processor will consume the stream and write the records to the FlowFile using the specified Record Writer. The processor will also add an attribute to the FlowFile with the name of the stream. The processor will not work if the stream is stale. Instead it will log an error message and stop processing. Stale stream has to be recreated in the database. After the stream is recreated in the database the processor will continue to read and process CDC records. For more information on Snowflake streams, see the <a href=“https://docs.snowflake.com/en/user-guide/streams-intro“>snowflake documentation</a>.

Tags¶

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

Eingabeanforderung¶

FORBIDDEN

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
Max Chunk Size	Anzahl der Datensätze, die in ein einzelnes FlowFile geschrieben werden sollen. Dieser Wert kann leicht überschritten werden.
Record Writer	Der Record Writer, der für die Serialisierung von CDC-Daten verwendet wird
Snowflake Connection Service	Datenbankverbindungsdienst für den Zugriff auf Snowflake
Stream-Name	Der Name des Streams in der Datenbank

Beziehungen¶

Name	Beschreibung
success	Für FlowFiles mit Stream-CDC-Datensätzen

Schreibt Attribute¶

Name	Beschreibung
snowflake.stream.name	Name des Snowflake-Streams