UpdateSnowflakeView 프로세서

UpdateSnowflakeView 프로세서

Openflow의 UpdateSnowflakeView 프로세서는 열 매핑을 기준으로 Snowflake 뷰를 생성하거나 교체하는 데 사용합니다. 이 문서에서 프로세서의 번들, 설명, 속성, 관계 등을 확인할 수 있습니다.

출처: Snowflake 문서

본문

번들 (Bundle)

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

설명 (Description)

들어오는 FlowFile에 제공된 열 매핑을 기준으로 Snowflake 뷰를 생성하거나 교체합니다. 프로세서는 뷰가 존재하는지 확인하고 정의가 변경된 경우에만 다시 생성합니다. FlowFile 내용에는 열 매핑, 선택적 join 구성, 선택적 flatten 구성을 포함한 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: 단순 필드/열 참조(JSON 표기 "data:field" 또는 테이블 별칭 "t.column" 지원) - expression: 복잡한 SQL 표현식(예: "SUM(amount)", "COUNT()") - destination_column: 뷰의 출력 열 이름(선택 사항, 제공하지 않으면 자동 생성) - type: 자동 타입 변환을 위한 Snowflake 데이터 유형(VARCHAR, NUMBER, BOOLEAN, DATE, TIMESTAMP 등) source_field 또는 expression 중 하나만 사용하며 둘 다 사용할 수 없습니다. type을 지정하면 자동 타입 변환이 적용됩니다. type을 생략하면 표현식이 변환 없이 그대로 사용됩니다. flatten 구성이 지원하는 항목: - input: 평탄화할 중첩 필드/열(필수) - alias: 평탄화된 데이터의 별칭(필수) - path: 중첩 구조 내의 선택적 경로 from 섹션은 필수이며 소스 테이블과 선택적 join을 지정합니다. 선택적 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"])

태그 (Tags)

flatten, view

입력 요구사항 (Input Requirement)

REQUIRED

민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)

false

속성 (Properties)

관계 (Relationships)

더 알아보기 (Learn more)

• UpdateSnowflakeView 프로세서 - Snowflake 문서