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”])

태그¶

flatten, view

입력 요구 사항¶

REQUIRED

민감한 동적 속성 지원¶

false

속성¶

관계¶