UpdateSnowflakeTable 2025.10.2.19¶

Bundle¶

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

Description¶

Met à jour la définition d’une table Snowflake en fonction du schéma fourni dans le FlowFile entrant. Le schéma est censé se trouver dans JSON avec le format suivant, qu’il soit fourni via le contenu du FlowFile ou spécifié comme propriété : { « columns »: [ { « name »: « <column name> », « type »: « <column type> », « nullable »: <true/false>, « precision »: <only for numeric type>, « scale »: <only for numeric type> }, … ], « primaryKeys »: [« <name of first primary key column> », « <name of second primary key column> », …] } Ce processeur prend en charge les opérations sur les tables uniquement : création, modification et suppression de tables.

Balises¶

alter, columns, create, ddl, drop, preview, snowflake, table, update

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
Alter Column Type Strategy	La stratégie à utiliser lorsque la table existante possède une colonne dont le type est différent de celui du schéma entrant.
Column Name Transformation	Transformation facultative qui peut être appliquée aux noms des colonnes définies dans le schéma. Cette transformation est appliquée aux noms de 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 le langage d’expression, en plus des attributs : `column.name`, `column.type`, `column.nullable`, `column.precision`, `column.scale`, `column.primaryKey`.Le résultat de l’application de transformations basées sur cette propriété sera traité en fonction du paramètre de la propriété `Traitement du nom d'objet`.
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
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.
Inclure les valeurs par défaut	Inclure ou non les valeurs DEFAULT dans les instructions CREATE TABLE ou ALTER TABLE ADD COLUMN
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.
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.
Record Reader	Record Reader à utiliser pour obtenir le schéma souhaité
Removed Column Name Suffix	Le suffixe à ajouter à une colonne qui a été supprimée. Par exemple, pour renommer la colonne “fuo” en “fuo__deleted”, la propriété peut être définie sur `__deleted` (supprimé). La valeur de cette propriété se comportera différemment en fonction de la valeur de la propriété `Traitement du nom d’objet`, c’est-à-dire si `Traitement du nom d’objet` est défini sur `Nom sensible à la casse`, le suffixe sera ajouté tel quel. Si `Traitement du nom d'objet` est défini sur `Identificateur SQL`, alors le suffixe doit comprendre uniquement des lettres, des nombres, le signe dollar ($) et le caractère de soulignement (_). De plus, il sera ajouté comme insensible à la casse ou sensible à la casse selon si le nom de la colonne auquel il est ajouté est insensible à la casse (pas entre guillemets doubles) ou sensible à la casse (entre guillemets doubles).
Nom de schéma	Nom du schéma contenant la table.
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 à mettre à jour
Table Schema Strategy	Spécifie comment obtenir la définition du schéma/de la table souhaité(e)
Update Type	Le type de mise à jour de table à 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

Écrit les attributs¶

Nom	Description
schema.hash	Un hachage SHA-256 du schéma final de la table une fois toutes les mises à jour effectuées. Peut être utilisé à des fins de détection des modifications et de mise en cache.