UpdateSnowflakeView 2025.10.2.19¶

Bundle¶

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

Description¶

Crée ou remplace des vues Snowflake en fonction des mappages de colonnes fournis dans le FlowFile entrant. Le processeur vérifie si la vue existe et ne la recrée que si la définition a changé. Le contenu du FlowFile doit contenir JSON avec des mappages de colonnes, une configuration de jonction facultative et une configuration d’aplatissement facultative : { « columns »: [ { « source_field »: « customer_data:id », « destination_column »: « customer_id », « type »: « VARCHAR » }, { « source_field »: « f.value:order_amount », « destination_column »: « order_amount », « type »: « NUMBER » }, { « expression »: « SUM(f.value:order_amount::NUMBER) », « destination_column »: « total_amount » }, { « expression »: « COUNT(*) », « destination_column »: « order_count » } ], « from »: { « table »: « raw_data », « alias »: « rd », « joins »: [ { « type »: « INNER », « table »: « customers », « alias »: « c », « on »: « customer_data:id::VARCHAR = c.customer_id » } ] }, « flatten »: [ { « input »: « rd.orders », « alias »: « f », « path »: null } ], « where »: « active = true AND status =”VALID” », « group_by »: [« customer_id », « region »], « order_by »: [« order_amount DESC », « customer_id ASC »] } La configuration de colonne prend en charge : - source_field: référence simple de champ/colonne (prend en charge la notation JSON comme « data:field » ou alias de table comme « t.column ») - expression : expression SQL complexe (par exemple, « SUM(montant) », « COUNT(*) »), - destination_column : Le nom de la colonne de sortie dans la vue (facultatif - généré automatiquement si non fourni), type : Type de données Snowflake pour le casting automatique des types (VARCHAR, NUMBER, BOOLEAN, DATE, TIMESTAMP, etc.) Utilisez soit source_field OR expression, et non les deux. Lorsque le type est spécifié, le casting de type automatique est appliqué. Lorsque le type est omis, l’expression est utilisée telle quelle sans casting. La configuration de l’aplatissement prend en charge : - input : Le champ/colonne imbriqué à aplatir (obligatoire) - alias : Alias pour les données aplaties (obligatoire) - path : Chemin facultatif dans la structure imbriquée La section « from » est obligatoire et spécifie la table source et les jointures facultatives. Les clauses SQL facultatives peuvent être incluses : - où : condition de la clause WHERE (par exemple, « active = true AND status =”VALID” »), group_by : clause GROUP BY sous la forme d’un tableau de noms de colonnes (par exemple, [« customer_id », « region »]), - order_by : clause ORDER BY en tant que tableau de colonnes/expressions avec une direction (par exemple, [« order_amount DESC », « customer_id ASC »])

Balises¶

flatten, view

Exigences en matière d’entrées¶

REQUIRED

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

false

Propriétés¶

Relations¶