SnowflakeDetectDuplicate 2025.10.2.19¶
번들¶
com.snowflake.openflow.runtime | runtime-snowflake-processors-nar
설명¶
Checks if a FlowFile ‘s hash (provided as a FlowFile attribute) is already in a Snowflake table, and routes the FlowFile to’ duplicate ‘if found,’distinct ‘if not found, or’ failure’ on errors.
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
내용 해시 |
미리 계산된 해시를 저장하는 FlowFile 특성의 이름입니다. 식 언어를 지원합니다. |
문서 소스 식별자 |
문서 소스 식별자(문서 ID)를 지정합니다. 식 언어를 지원합니다. |
문서 소스 이름 |
문서 소스 시스템 이름을 지정합니다. 식 언어를 지원합니다. |
Snowflake 연결 서비스 |
Snowflake에 대한 연결을 제공하는 DBCPService 입니다. |
Snowflake 테이블 이름 |
The Snowflake table name that stores the file hashes. The table name is case-insensitive. Database and schema must be configured prior in the Snowflake Connection Service. |
관계¶
이름 |
설명 |
|---|---|
distinct |
기존 문서와 일치하지 않는 FlowFiles 은 여기로 라우팅(새 해시 삽입)됩니다. |
중복 |
기존 문서(동일한 해시)와 일치하는 FlowFiles 은 여기로 라우팅됩니다. |
실패 |
처리 중 오류나 예외가 발생하는 FlowFiles 은 여기로 라우팅됩니다. |
Writes 특성¶
이름 |
설명 |
|---|---|
Snowflake.detect.duplicate |
FlowFile 이 중복으로 감지되었는지를 나타내는 ‘true’ 또는 ‘false’ 특성입니다. |