UpdateSnowflakeView 2025.10.2.19¶

バンドル¶

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

説明¶

受信した FlowFile で提供された列マッピングに基づいて、Snowflakeビューを作成または置換します。プロセッサーは、ビューが存在するかどうかをチェックし、定義が変更された場合にのみビューを再作成します。FlowFile コンテンツには、列のマッピング、オプションの結合構成、オプションのフラット化構成を持つ JSON が含まれている必要があります。 { "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"] } 列の構成は次をサポートします。 - source_field:単純なフィールド/列リファレンス（"data:field"のような JSON 表記または"t.column"のようなテーブルエイリアスをサポート） - expression：複雑な SQL 式（例："SUM(amount)"、"COUNT(*)"） - destination_column：ビューの出力列名（オプション - 指定しない場合は自動生成されます） - type：自動型キャスト用のSnowflakeデータ型（VARCHAR 、 NUMBER 、 BOOLEAN 、 DATE 、 TIMESTAMP など）source_field OR 式のどちらかを使用します。両方を使用することはできません。型が指定されると、自動型キャストが適用されます。型が省略された場合、式はキャストなしでそのまま使用されます。フラット化構成は次をサポートしています。 - input：フラット化するネストされたフィールド/列（必須） - alias：フラット化データのエイリアス（必須） - path：ネスト構造内のオプションのパス。"from"セクションは必須で、ソーステーブルとオプションの結合を指定します。オプションの SQL 句を含めることができます。 - where： WHERE 句の条件（たとえば、"active = true AND status ='VALID'"） - group_by：列名の配列としての GROUP BY 句（たとえば、["customer_id"、"region"]） - order_by：方向を持つ列/式の配列としての ORDER BY 句（たとえば、["order_amount DESC"、"customer_id ASC"]）

タグ¶

フラット化、ビュー

入力要件¶

REQUIRED

機密動的プロパティをサポート¶

false

プロパティ¶

リレーションシップ¶