ConsumeSnowflakeStream 2025.5.31.15¶

번들¶

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 특성¶