私はexecuteprocessプロセッサを使ってシェルスクリプトを実行しています。しかし、私は、スクリプトが正常に実行された場合、フローだけが次のプロセッサに送られるようにしたい。これをチェックする方法はありますか?Nifi executeprocess processor
3
A
答えて
4
代わりに、JDP10101の回答に加えて、ExecuteStreamCommand(その前にGenerateFlowFileを付けて実行をトリガー)を使用することもできます。 ExecuteStreamCommandは、プロセスの終了コードを示す属性 "execution.status"を書き込みます。成功を処理するためにRouteOnAttributeでこれを使用できます(おそらくexecution.status == 0)。失敗(execution.status!= 0)
2
ExecuteProcessはNiFiの外でコマンドを実行しているため、 "成功"/"失敗"とは何かを判断するのは難しい場合があります。 「失敗」の場合のコマンドの出力に応じて、フローロジックが変更されます。
まず、エラーストリームをFlowFileのコンテンツに含めるには、「リダイレクトエラーストリーム」をtrueに設定することをお勧めします。次に、一連の文字が「失敗」を示すかどうかを判断する必要があります。これは、プロセスによっては「ERROR」またはそれ以上の複雑なものになる可能性があります。 「失敗」の意味を判断したら、RouteTextを使用して、内容に文字が含まれるFlowFilesをルーティングします。
関連する問題
- 1. NIFI PutS3Object ProcessorのFlowFileコンテンツへのアクセス
- 2. NiFi Build Errors
- 3. Django Context Processor Trouble
- 4. sql xml order processor
- 5. uipv6 on arm processor family
- 6. turbo error: "co processor card not responding"
- 7. Nifiロードバランサ
- 8. Nifiクエリテーブルエラー
- 9. ListenHttp Apache NIfiジェネリックベースパス
- 10. NiFi-1.0.0 - ExecuteSQL CrateIO
- 11. Nifi-1.0.0とCrate.IO
- 12. Nifiクラスタ構成
- 13. Nifi ExecuteScriptのインポートモジュール
- 14. データプロバンス無効NIFI
- 15. NiFiコーディネータ - ハンドルデータ
- 16. NiFi-1.0 - content_repo&flowfile_repo
- 17. Migrate Dataflow NIFI
- 18. NiFi-1.0.0 - load luaスクリプト
- 19. apache nifi、hdfs parquet format
- 20. Apache NiFi - データWebサービス
- 21. Airbnb AirflowとApache Nifi
- 22. NifiエラーWwth putsolrcontentstreamプロセッサ
- 23. fetchelasticsearchプロセッサのNifiエラー
- 24. ウィンドウ上のNifiコマンド
- 25. Apache NiFi:ホットフォルダのメカニズム
- 26. Apache NifiでExecuteSQLプロセッサー
- 27. NiFi:フローファイルを表示
- 28. NiFi-1.0.0 GetFile関連
- 29. Nifi-1.0.0 - 同期メカニズム
- 30. NiFi 1.0.0 - キューのカスタムプライオリティ