UpdateSnowflakeDatabase 2025.5.31.15¶

Bundle¶

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

Description¶

Met à jour la définition d’une table Snowflake sur la base du schéma fourni dans le FlowFile entrant. Le schéma doit être en JSON avec le format suivant, que ce soit fourni via le contenu FlowFile ou spécifié comme propriété : { « columns »: [ { « name »: « <column name> », « type »: « <column type> », « nullable »: <true/false>, « precision »: <precision, only for numeric type>, « scale »: <scale, only for numeric type> }, … ], « primaryKeys » : [« <nom de la première clé primaire> », « <nom de la deuxième clé primaire> », …]}

Balises¶

Exigences en matière d’entrées¶

REQUIRED

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

false

Propriétés¶

Propriété	Description
Add Column Strategy	La stratégie à utiliser lorsque le schéma entrant possède une colonne qui n’est pas présente dans la table existante
Add Not Null Strategy	La stratégie à utiliser lorsque le schéma entrant a une contrainte not-null qui n’est pas présente dans la table existante
Column Name Transformation	Une transformation facultative qui peut être appliquée aux noms des colonnes définies dans le schéma. Cette transformation est appliquée aux noms des colonnes avant qu’ils ne soient comparés aux colonnes existantes dans la table. Cette propriété peut faire référence aux variables suivantes via l’Expression Language, en plus des attributs : `column.name`, `column.type`, `column.nullable`, `column.precision`, `column.scale`, `column.primaryKey`.
Column Removal Strategy	La stratégie à utiliser lorsque la table existante possède une colonne qui n’est pas présente dans le schéma entrant
Connection Pool	Le pooling de connexions à utiliser pour se connecter à Snowflake
Create Stream	Création ou non d’un flux Snowflake pour la table
Creation Parameters	Paramètres supplémentaires à inclure dans l’instruction CREATE TABLE. Par exemple, “CLUSTER BY (column_name)”
Schéma souhaité	La définition du schéma/de la table souhaitée
Drop Column Strategy	La stratégie à utiliser lorsque la table existante possède une colonne qui n’est pas présente dans le schéma entrant
Drop Not Null Strategy	Stratégie à utiliser lorsque la table existante comporte une contrainte non nulle qui n’est pas présente dans le schéma entrant.
Include Not Null Constraints	Indique s’il faut inclure les contraintes NOT NULL dans les instructions CREATE TABLE ou ALTER TABLE ADD COLUMN statements
Include Primary Key Constraints	Inclusion ou non des contraintes de clé primaire dans l’instruction de création
Max Batch Size	Le nombre maximum de FlowFiles qui peuvent être traités en une seule exécution pour une table donnée.
Modify Primary Key Strategy	La stratégie à utiliser lorsque le schéma entrant possède une clé primaire différente de la clé primaire existante. Pour modifier la clé primaire, il faut supprimer la clé existante, le cas échéant, et en ajouter une nouvelle.
Record Reader	Record Reader à utiliser pour obtenir le schéma souhaité
Removed Column Name Suffix	Le suffixe à ajouter à une colonne supprimée. Par exemple, pour renommer la colonne “foo” en “foo__deleted”, la propriété peut être définie sur `__deleted`
Nom de schéma	Le nom du schéma à mettre à jour
Stream Creation Parameters	Paramètres supplémentaires à inclure dans l’instruction CREATE STREAM. Par exemple, “APPEND_ONLY=TRUE”
Stream Name	The name of the stream
Temps d’expiration de la mémoire cache des métadonnées de la table	Délai en secondes après lequel l’entrée de cache sera supprimée
Nom de la table	Le nom de la table sur laquelle le flux doit être mis à jour ou créé
Table Schema Strategy	Spécifie comment obtenir la définition du schéma/de la table souhaité(e)
Table Stream Creation Parameters	Paramètres à inclure dans l’instruction CREATE STREAM. Par exemple, “APPEND_ONLY=TRUE”. Le flux sera créé avec la table comme source.
Table Stream Name	Le nom du flux créé avec la table. La source du flux sera la table créée.
Update Type	Le type de mise à jour à effectuer
Utiliser la cache des métadonnées de table	Indique s’il faut mettre en cache les métadonnées de la table au lieu de les lire directement depuis Snowflake. S’applique à [Create Table If Not Exists, Alter Table]

Relations¶

Nom	Description
failure	Le FlowFile est routé vers cette relation si la table ne peut pas être mise à jour
success	Le FlowFile est routé vers cette relation une fois que la table a été mise à jour avec succès