Pythonサブプロセスが完了したときにポストアクションを実行する方法

Question

インデックス作成操作を実行するサブプロセスを作成するpythonスクリプトがあります（logstashからelasticsearchへ）。

次のようにコードスニペットは、

process = subprocess.Popen([logstash, '-f', sample.conf], 
            stdout=subprocess.PIPE, stderr=subprocess.STDOUT) 

私は、スクリプトの残りの部分とは独立して実行する必要性を作成していますサブプロセスとして、）（process.waitを呼び出すことはありません。

しかし、サブプロセスが完了したらデータベースレコードを更新する必要があります。実行中の索引付け操作では、データベースを更新できるポスト・ジョブ・コールを作成できません。

どうすればこの問題をPythonのサブプロセスで処理できますか？ジョブのPIDをテキストファイルに保存しますが、次のスクリプトを実行するためにサブプロセスが完了したことを知っているトリガーが必要です。

Answer 1

スレッド内でプロセスを作成することができます。あなたが出力を得るようにするには、スレッドからwaitをすることができ、そしてそれは

import threading 
import subprocess 

def run_command(): 
    p = subprocess.Popen([logstash, '-f', sample.conf], 
           stdout=subprocess.PIPE, stderr=subprocess.STDOUT) 
    output = p.stdout.read() 
    p.wait() 
    # now your command has ended, do whatever you like 

とあなたのメインスレッドでは、非ブロッキングです：

t = threading.Thread(target=run_command) 
t.start() 
# continue with main processing 

Answer 2

あなたはどこかprocess変数を隠しておくように見えるので、後でpollメソッドを呼び出すと、そのreturncode attributeを確認できます。

処理が完了した場合、returncodeの値はNoneにならず、データベースを更新できます。