ConsumeSnowflakeStream 2025.10.2.19¶

번들¶

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

설명¶

Snowflake 스트림에서 데이터를 가져와서 FlowFile에 씁니다. 이 프로세서를 사용하기 전에 데이터베이스에 스트림을 생성해야 합니다. 프로세서는 스트림을 사용하고 지정된 Record Writer를 사용하여 레코드를 FlowFile에 씁니다. 프로세서는 FlowFile에 스트림 이름이 지정된 속성도 추가합니다. 스트림이 부실하면 프로세서가 작동하지 않습니다. 대신 오류 메시지를 기록하고 처리를 중지합니다. 데이터베이스에서 부실 스트림을 다시 만들어야 합니다. 데이터베이스에서 스트림이 다시 생성된 후 프로세서는 계속해서 CDC 레코드를 읽고 처리합니다. Snowflake 스트림에 대한 자세한 내용은 <a href=”https://docs.snowflake.com/en/user-guide/streams-intro”>Snowflake 설명서</a>를 참조하세요.

태그¶

connection, database, jdbc, openflow, snowflake, stream, table, view

입력 요구 사항¶

FORBIDDEN

민감한 동적 속성 지원¶

false

속성¶

관계¶

Writes 특성¶