SnowflakeDetectDuplicate 2025.5.31.15

번들

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

설명

FlowFile 의 해시(FlowFile특성으로 제공됨)가 이미 Snowflake 테이블에 있는지 확인하고, 발견되면 FlowFile 을 ‘중복’, 발견되지 않으면 ‘고유’, 오류 시 ‘실패’로 라우팅합니다.

태그

database, detect, duplicates, hash, snowflake

입력 요구 사항

REQUIRED

민감한 동적 속성 지원

false

속성

속성

설명

내용 해시

미리 계산된 해시를 저장하는 FlowFile 특성의 이름입니다. 식 언어를 지원합니다.

문서 소스 식별자

문서 소스 식별자(문서 ID)를 지정합니다. 식 언어를 지원합니다.

문서 소스 이름

문서 소스 시스템 이름을 지정합니다. 식 언어를 지원합니다.

Snowflake 연결 서비스

Snowflake에 대한 연결을 제공하는 DBCPService 입니다.

Snowflake 테이블 이름

파일 해시를 저장하는 Snowflake 테이블 이름입니다. 데이터베이스와 스키마는 Snowflake 연결 서비스에서 미리 구성해야 합니다.

관계

이름

설명

distinct

기존 문서와 일치하지 않는 FlowFiles 은 여기로 라우팅(새 해시 삽입)됩니다.

중복

기존 문서(동일한 해시)와 일치하는 FlowFiles 은 여기로 라우팅됩니다.

실패

처리 중 오류나 예외가 발생하는 FlowFiles 은 여기로 라우팅됩니다.

Writes 특성

이름

설명

Snowflake.detect.duplicate

FlowFile 이 중복으로 감지되었는지를 나타내는 ‘true’ 또는 ‘false’ 특성입니다.