ScriptedValidateRecord 2025.5.31.15¶

バンドル¶

org.apache.nifi | nifi-scripting-nar

説明¶

このプロセッサーは、ユーザー提供のスクリプトを使用して FlowFiles の記録を検証する機能を提供します。スクリプトは、引数として記録を受け取り、ブール値で返すことが期待されます。この結果に基づいて、プロセッサーは記録を「有効」または「無効」に分類し、バッチでそれぞれのリレーションシップにルーティングします。さらに、元の FlowFile は「元の」リレーションシップにルーティングされ、処理が失敗した場合は「失敗した」リレーションシップにルーティングされます。

タグ¶

groovy、記録、スクリプト、検証

入力要件¶

REQUIRED

機密動的プロパティをサポート¶

false

プロパティ¶

プロパティ	説明
モジュールディレクトリ	スクリプトが必要とするモジュールを含むファイルやディレクトリへのパスをカンマで区切ったリスト。
Record Reader	入力された FlowFile を記録にパースするために使用するRecord Reader。
Record Writer	変換後の記録をシリアライズするために使用するRecord Writer。
本文	実行するスクリプト本文。スクリプトファイルまたはスクリプト本文のどちらか一方のみを使用できます。
スクリプトエンジン	スクリプトに使用する言語
スクリプトファイル	実行するスクリプトファイルのパス。スクリプトファイルまたはスクリプト本文のどちらか一方のみを使用できます。

制限事項¶

必要な許可	説明
実行コード	演算子に、 NiFi が持つすべてのパーミッションを想定して任意のコードを実行する能力を提供します。

リレーションシップ¶

名前	説明
failure	受信フローファイルの処理中に何らかの問題が発生した場合、受信 FlowFile はこのリレーションシップにルーティングされます。
invalid	受信 FlowFile の無効な記録を含む FlowFile は、このリレーションシップにルーティングされます。無効な記録がない場合、 FlowFile はこのリレーションシップにルーティングされません。
original	プロセシングが成功すると、 FlowFile がこのリレーションシップに転送されます。これは、 FlowFiles が「有効」と「無効」のリレーションシップにルーティングされる可能性に関係なく起こります。
valid	受信 FlowFile からの有効な記録を含む FlowFile は、このリレーションシップにルーティングされます。有効な記録がない場合、 FlowFile はこのリレーションシップにルーティングされません。

属性の書き込み¶

名前	説明
mime.type	mime.type属性をRecord Writerで指定された MIME Typeにセットします。
record.count	フローファイル内の記録数。
record.error.message	この属性は、エラー時にリーダーまたはライターが遭遇したエラーメッセージを提供します。