UpdateSnowflakeSchema 프로세서
UpdateSnowflakeSchema 프로세서
Openflow의 UpdateSnowflakeSchema 프로세서는 Snowflake 데이터베이스 스키마가 없으면 생성하는 데 사용합니다. 이 문서에서 프로세서의 번들, 설명, 속성, 관계 등을 확인할 수 있습니다.
출처: Snowflake 문서
본문
번들 (Bundle)
com.snowflake.openflow.runtime | runtime-snowflake-processors-nar
설명 (Description)
Snowflake 데이터베이스 스키마가 존재하지 않으면 생성합니다.
태그 (Tags)
create, ddl, preview, schema, snowflake
입력 요구사항 (Input Requirement)
REQUIRED
민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)
false
속성 (Properties)
| 속성 (Property) | 설명 (Description) |
|---|---|
| Connection Pool | Snowflake에 연결하는 데 사용할 연결 풀입니다. |
| Object Identifier Resolution | 소스 객체 식별자(스키마, 테이블, 열)가 Snowflake에 저장되고 조회되는 방식을 제어합니다. 이 설정은 SQL 쿼리에서 큰따옴표를 사용해야 하는지 여부를 결정합니다. |
| Schema Creation Cache Expiration Time | 캐시 항목이 제거된 후의 시간입니다. |
| Schema Name | 생성할 스키마의 이름입니다. |
| Use Schema Creation Cache | FlowFile마다 CREATE SCHEMA IF NOT EXISTS 문을 실행하는 대신 스키마 생성을 캐시할지 여부입니다. |
관계 (Relationships)
| 이름 (Name) | 설명 (Description) |
|---|---|
| failure | 스키마를 생성할 수 없으면 들어오는 FlowFile이 이 관계로 라우팅됩니다. |
| success | 스키마가 성공적으로 생성된 후 들어오는 FlowFile이 이 관계로 라우팅됩니다. |