UpdateSnowflakeStream 2025.10.2.19¶
번들¶
com.snowflake.openflow.runtime | runtime-snowflake-processors-nar
설명¶
구성된 작업에 따라 Snowflake 스트림을 생성, 삭제 또는 교체하여 관리합니다. Snowflake의 스트림은 테이블의 데이터 변경 사항을 캡처하고 시간에 따른 DML 변경 사항을 추적하는 데 사용할 수 있습니다.
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
Connection Pool |
Snowflake에 연결하는 데 사용할 연결 풀입니다 |
오브젝트 식별자 확인 |
Snowflake에서 소스 오브젝트 식별자(스키마, 테이블, 열)를 저장하고 쿼리하는 방법을 제어합니다. 이 설정은 SQL 쿼리에서 큰따옴표를 사용해야 하는지 여부를 결정합니다. |
Schema Name |
스트림 및/또는 소스 테이블을 포함하는 스키마의 이름입니다. |
소스 테이블 이름 |
스트림에 대한 소스 테이블의 이름입니다. |
스트림 생성 매개 변수 |
CREATE STREAM 문에 포함할 추가 매개 변수입니다. 예: ‘APPEND_ONLY=TRUE SHOW_INITIAL_ROWS=TRUE’ |
스트림 이름 |
생성, 삭제 또는 대체할 스트림의 이름입니다. |
업데이트 유형 |
수행할 스트림 작업의 유형입니다. |
관계¶
이름 |
설명 |
|---|---|
실패 |
수신 FlowFile은 스트림 작업을 완료할 수 없는 경우 이 관계로 라우팅됩니다. |
오브젝트를 찾을 수 없음 |
수신 FlowFile은 지정된 스트림 또는 소스 테이블이 없는 경우 이 관계로 라우팅됩니다. |
성공 |
수신 FlowFile은 스트림 작업이 성공적으로 완료된 후 이 관계로 라우팅됩니다. |