ExecuteStreamCommand 2025.5.31.15

バンドル

org.apache.nifi | nifi-standard-nar

説明

ExecuteStreamCommand プロセッサーは、外部コマンドやスクリプトを NiFi データフローに統合する柔軟な方法を提供します。ExecuteStreamCommand は、パイプと同じように、入力された FlowFile の内容を実行するコマンドに渡すことができます。

タグ

コマンド、コマンド実行、実行、ストリーム

入力要件

REQUIRED

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

true

プロパティ

プロパティ

説明

引数の区切り文字

コマンド [デフォルト: ;]の引数を区切るデリミタ。1文字である必要があります。

コマンド引数

「;」文字で区切られた実行ファイルに与える引数。

コマンドパス

実行するコマンドを指定します。実行ファイル名だけをプロバイダーとして指定する場合は、ユーザーの環境 PATH でなければなりません。

無視 STDIN

trueの場合、入力されたフローファイルの内容は実行コマンドに渡されません。

属性の最大長

ストリーム・コマンドの出力を属性にルーティングする場合、属性値に格納される文字数は最大でもこの量になります。属性はメモリに保持され、大容量の属性はすぐにメモリ不足の問題を引き起こすため、これは重要です。出力がこの値より長い場合は、収まるように切り捨てられます。可能であれば、これを小さくすることも検討してください。

出力先属性

セットされた場合、ストリームコマンドの出力は、個別の FlowFile ではなく、元の FlowFile の属性に入れられます。「出力ストリーム」や「非ゼロステータス」の関係はなくなります。このプロパティの値が出力属性のキーになります。

出力 MIME タイプ

"mime.type "属性にセットする値を指定します。「出力先属性」がセットされている場合、このプロパティは無視されます。

作業ディレクトリ

コマンド実行時に現在の作業ディレクトリとして使用するディレクトリ。

argumentsStrategy

コマンドに供給される引数を構成するための戦略。

制限事項

必要な許可

説明

実行コード

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

リレーションシップ

名前

説明

非ゼロステータス

返されたステータス・コードが0以外の場合、コマンドの出力から作成されるフロー・ファイルの宛先パス。このリレーションシップにルーティングされたすべてのフローファイルにペナルティが課せられます。

original

元の FlowFile は、ルーティングされます。スクリプトの実行結果を示す新しい属性が追加されます。

出力ストリーム

返されたステータス・コードが0の場合、コマンドの出力から作成されるフロー・ファイルの宛先パス。

属性の書き込み

名前

説明

execution.command

実行されたコマンド名

execution.command.args

セミコロンで区切られた引数のリスト。センシティブなプロパティはマスキングされます。

execution.status

コマンド実行時に返される終了ステータスコード。

execution.error

コマンド実行時に返されるエラーメッセージ。

mime.type

Output MIME Type' プロパティがセットされ、 'Output Destination Attribute' がセットされていない場合、出力の MIME タイプを設定します。