ConsumeSnowflakeStream 2025.5.31.15¶

Bundle¶

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

Description¶

Récupère les données d’un flux Snowflake et les écrit dans un FlowFile. Le flux doit être créé dans la base de données avant l’utilisation de ce processeur. Le processeur consommera le flux et écrira les enregistrements dans le FlowFile à l’aide du Record Writer spécifié. Le processeur ajoutera également un attribut au FlowFile avec le nom du flux. Le processeur ne fonctionnera pas si le flux est périmé. Au lieu de cela, il consignera un message d’erreur et arrêtera le traitement. Le flux périmé devra être recréé dans la base de données. Une fois le flux recréé dans la base de données, le processeur continuera à lire et à traiter les enregistrements CDC. Pour plus d’informations sur les flux Snowflake, voir la <a href= »https://docs.snowflake.com/en/user-guide/streams-intro »>documentation snowflake</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