UpdateSnowflakeStream 2025.10.2.19¶

Bundle¶

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

Description¶

Gère les flux Snowflake en les créant, en les supprimant ou en les remplaçant en fonction de l’opération configurée. Les flux dans Snowflake capturent le changement de données pour les tables et peuvent être utilisés pour suivre les changements DML au fil du temps.

Balises¶

cdc, create, drop, preview, replace, snowflake, stream, table

Exigences en matière d’entrées¶

REQUIRED

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

false

Propriétés¶

Propriété	Description
Connection Pool	Le pooling de connexions à utiliser pour se connecter à Snowflake
Résolution de l’identificateur d’objet	Contrôle la manière dont les identificateurs des objets sources (schémas, tables, colonnes) sont stockés et interrogés dans Snowflake. Ce paramètre détermine si vous devrez utiliser des guillemets doubles dans vos requêtes SQL.
Nom de schéma	Le nom du schéma contenant le flux et/ou la table source
Nom de la table source.	Nom de la table source du flux
Stream Creation Parameters	Paramètres supplémentaires à inclure dans l’instruction CREATE STREAM. Par exemple : “APPEND_ONLY=TRUE SHOW_INITIAL_ROWS=TRUE”
Stream Name	Le nom du flux à créer, détruire ou remplacer
Update Type	Le type d’opération de flux à effectuer

Relations¶

Nom	Description
failure	Le FlowFile entrant est acheminé vers cette relation si l’opération de flux ne peut pas être terminée
Objet introuvable	Le FlowFile entrant est acheminé vers cette relation si le flux ou la table source spécifié n’existe pas.
success	Le FlowFile entrant est acheminé vers cette relation une fois que l’opération de flux a été effectuée