UpdateSnowflakeView 2025.10.2.19¶

Bundle¶

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

Beschreibung¶

Erstellt oder ersetzt Snowflake-Ansichten auf der Grundlage von Spaltenzuordnungen, die im eingehenden FlowFile bereitgestellt werden. Der Prozessor prüft, ob die Ansicht existiert und erstellt sie nur neu, wenn sich die Definition geändert hat. Der FlowFile-Inhalt sollte JSON mit Spaltenzuordnungen, optionaler Join-Konfiguration und optionaler vereinfachter Konfiguration enthalten: { „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“] } Die Spaltenkonfiguration unterstützt: - source_field: Einfache Feld-/Spaltenreferenz (unterstützt JSON-Notation wie „data:field“ oder Tabellenaliasse wie „t.column“) - expression: Komplexer SQL-Ausdruck (z. B. „SUM(amount)“, „COUNT(*)“) - destination_column: Der Name der Ausgabespalte in der Ansicht (optional – wird automatisch generiert, wenn nicht angegeben) - type: Snowflake-Datentyp für automatische Typumwandlung (VARCHAR, NUMBER, BOOLEAN, DATE, TIMESTAMP usw.) Verwenden Sie entweder „source_field“ OR „expression“, nicht beides. Wenn der Typ angegeben ist, wird eine automatische Typumwandlung angewendet. Wenn der Typ weggelassen wird, wird der Ausdruck unverändert ohne Umwandlung verwendet. Die vereinfachte Konfiguration unterstützt: - input: Das verschachtelte Feld bzw. die zu vereinfachende Spalte (erforderlich) - alias: Alias für die vereinfachten Daten (erforderlich) - path: Optionaler Pfad innerhalb der verschachtelten Struktur. Der Abschnitt „from“ ist erforderlich und gibt die Quelltabelle und optionale Verknüpfungen an. Optionale SQL-Klauseln können eingefügt werden: - where: WHERE-Klausel-Bedingung (z. B. „active = true AND status =‘VALID‘“) - group_by: GROUP BY-Klausel als Array von Spaltennamen (z. B. [„customer_id“, „region“]) - order_by: ORDER BY-Klausel als Array von Spalte/Ausdruck mit Richtung (z. B. [„order_amount DESC“, „customer_id ASC“])

Tags¶

vereinfachen, ansicht

Eingabeanforderung¶

REQUIRED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Beziehungen¶