ScriptedFilterRecord 2025.5.31.15¶
バンドル¶
org.apache.nifi | nifi-scripting-nar
説明¶
このプロセッサーは、ユーザーが用意したスクリプトを使用して、 FlowFiles から記録をフィルターする機能を提供します。すべての記録はスクリプトによって評価され、ブール値で返されなければなりません。結果が「true」の記録は、バッチで「matching」リレーションシップにルーティングされます。その他の記録はフィルターにかけられます。
入力要件¶
REQUIRED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
モジュールディレクトリ |
スクリプトが必要とするモジュールを含むファイルやディレクトリへのパスをカンマで区切ったリスト。 |
Record Reader |
入力された FlowFile を記録にパースするために使用するRecord Reader。 |
Record Writer |
変換後の記録をシリアライズするために使用するRecord Writer。 |
本文 |
実行するスクリプト本文。スクリプトファイルまたはスクリプト本文のどちらか一方のみを使用できます。 |
スクリプトエンジン |
スクリプトに使用する言語 |
スクリプトファイル |
実行するスクリプトファイルのパス。スクリプトファイルまたはスクリプト本文のどちらか一方のみを使用できます。 |
制限事項¶
必要な許可 |
説明 |
|---|---|
実行コード |
演算子に、 NiFi が持つすべてのパーミッションを想定して任意のコードを実行する能力を提供します。 |
リレーションシップ¶
名前 |
説明 |
|---|---|
failure |
受信 FlowFile の処理中に何らかの問題が発生した場合、受信 FlowFile はこのリレーションシップにルーティングされます。 |
original |
プロセシングが成功すると、 FlowFile がこのリレーションシップに転送されます。これはフィルターや残りの記録数に関係なく発生します。 |
success |
オリジナル FlowFile の一致する記録は、このリレーションシップにルーティングされます。一致する記録がない場合、 FlowFile はここにルーティングされません。 |
属性の書き込み¶
名前 |
説明 |
|---|---|
mime.type |
mime.type属性をRecord Writerで指定された MIME Typeにセットします。 |
record.count |
フローファイル内の記録数。 |
record.error.message |
この属性は、エラー時にリーダーまたはライターが遭遇したエラーメッセージを提供します。 |