SnowflakeDetectDuplicate 2025.10.2.19¶

バンドル¶

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

FlowFile のハッシュ（FlowFile 属性として提供）がすでにSnowflakeテーブルにあるかどうかを確認し、見つかった場合は「重複」、見つからなかった場合は「重複なし」、エラーの場合は「失敗」に FlowFile をルーティングします。

データベース、検出、重複、ハッシュ、Snowflake

REQUIRED

false

プロパティ	説明
コンテンツ・ハッシュ	事前に計算されたハッシュを保持する FlowFile 属性の名前。式言語をサポートしています。
ドキュメントソース識別子	ドキュメントソース識別子 (doc ID) を指定します。式言語をサポートしています。
ドキュメントソース名	ドキュメントソースシステム名を指定します。式言語をサポートしています。
Snowflake 接続サービス	Snowflakeへの接続を提供する DBCPService。
Snowflakeテーブルネーム	ファイルハッシュを格納するSnowflakeテーブル名。テーブル名は大文字と小文字を区別しません。データベースとスキーマは、事前にSnowflake Connection Serviceで構成する必要があります。

名前	説明
distinct	既存のドキュメントにマッチしない FlowFiles はここにルーティングされます (新しいハッシュが挿入されます)。
duplicate	既存のドキュメント (同じハッシュ) にマッチする FlowFiles はここにルーティングされます。
failure	処理中にエラーや例外が発生した FlowFiles は、ここにルーティングされます。

名前	説明
Snowflake.detect.duplicate	FlowFile が重複として検出されたかどうかを示す 'true' または 'false' 属性。