UpdateSnowflakeStream 프로세서
UpdateSnowflakeStream 프로세서
Openflow의 UpdateSnowflakeStream 프로세서는 Snowflake 스트림을 생성, 삭제, 교체하여 관리하는 데 사용합니다. 이 문서에서 프로세서의 번들, 설명, 속성, 관계 등을 확인할 수 있습니다.
출처: Snowflake 문서
본문
번들 (Bundle)
com.snowflake.openflow.runtime | runtime-snowflake-processors-nar
설명 (Description)
구성된 작업에 따라 Snowflake 스트림을 생성, 삭제 또는 교체하여 관리합니다. Snowflake의 스트림은 테이블의 데이터 변경을 캡처하며 시간에 따른 DML 변경을 추적하는 데 사용할 수 있습니다.
태그 (Tags)
cdc, create, drop, preview, replace, snowflake, stream, table
입력 요구사항 (Input Requirement)
REQUIRED
민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)
false
속성 (Properties)
| 속성 (Property) | 설명 (Description) |
|---|---|
| Connection Pool | Snowflake에 연결하는 데 사용할 연결 풀입니다. |
| Object Identifier Resolution | 소스 객체 식별자(스키마, 테이블, 열)가 Snowflake에 저장되고 조회되는 방식을 제어합니다. 이 설정은 SQL 쿼리에서 큰따옴표를 사용해야 하는지 여부를 결정합니다. |
| Schema Name | 스트림 및/또는 원본 테이블이 들어 있는 스키마의 이름입니다. |
| Source Table Name | 스트림의 원본 테이블 이름입니다. |
| Stream Creation Parameters | CREATE STREAM 문에 포함할 추가 매개변수입니다. 예: APPEND_ONLY=TRUE SHOW_INITIAL_ROWS=TRUE |
| Stream Name | 생성, 삭제 또는 교체할 스트림의 이름입니다. |
| Update Type | 수행할 스트림 작업 유형입니다. |
관계 (Relationships)
| 이름 (Name) | 설명 (Description) |
|---|---|
| failure | 스트림 작업을 완료할 수 없으면 들어오는 FlowFile이 이 관계로 라우팅됩니다. |
| object not found | 지정된 스트림이나 원본 테이블이 존재하지 않으면 들어오는 FlowFile이 이 관계로 라우팅됩니다. |
| success | 스트림 작업이 성공적으로 완료된 후 들어오는 FlowFile이 이 관계로 라우팅됩니다. |