ConsumeSnowflakeStream 2025.10.2.19¶

Bundle¶

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

Description¶

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>.

Balises¶

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

Exigences en matière d’entrées¶

FORBIDDEN

Prend en charge les propriétés dynamiques sensibles¶

false

Propriétés¶

Propriété	Description
Max Chunk Size	Nombre d’enregistrements à écrire dans un seul FlowFile. Cette valeur peut être légèrement dépassée.
Record Writer	Le Record Writer à utiliser pour la sérialisation des enregistrements CDC
Snowflake Connection Service	Le service de connexion à la base de données pour l’accès à Snowflake
Stream Name	Le nom du flux dans la base de données

Relations¶

Nom	Description
success	Pour les FlowFiles contenant des enregistrements de flux CDC

Écrit les attributs¶

Nom	Description
snowflake.stream.name	Nom du flux Snowflake