backtype.storm.multilang.NoOutputException：サブプロセスへのパイプが壊れているようです！出力がありません

Question

私は嵐でpythonを使うのが新しいです。ローカルモードで実行する際に問題に直面しています

ERROR backtype.storm.util - Async loop died! 
java.lang.RuntimeException: backtype.storm.multilang.NoOutputException: Pipe to subprocess seems to be broken! No output read. 
Serializer Exception: 
usage: simbolt.py [-h] --data DATAPATH --pre PRECOMPPATH --res RESULT --inp 
        ORIGFILE 
simbolt.py: error: argument --data/-d is required 

私はそれをどのように修正できますか、問題はどこにありますか？ 何かが必要な場合は、その理由を知るためにコードから共有することができます

Answer 1

まず何をしようとしていますか？サブプロセスを呼び出す場合は、入ってくるタプルで受け取ったデータを使ってボルトから外部プログラムを実行しようとしていると思いますか？もしそうなら、これを行うためのより多くのStorm（JVM）ネイティブの方法がありますが、Javaを使う必要があります。

Pythonと他の外部プログラムを使ってデータを処理し、分散して実行したい場合は、Stormが最適な方法ではないかもしれません。 Celeryのようなものを使う方が良いかもしれません。

しかし、Stormのすべての利点を望んでいて、外部サブプロセスがPythonで何をしているのかを書き換えることができれば、StreamParseは良い選択肢かもしれません。

サブプロセスとトポロジ全体で何をしようとしているのかについて詳しく知ることができれば、さらに助けてくれるかもしれません。