一定期間subprocessの標準出力がない事を検知したい

Question

前提・実現したいこと

初歩的な質問かもしれませんが、自己解決出来なかったため質問させていただきます。

subprocessで起動したサーバーソフトの起動ログ（標準出力）のみを取得するためprco.stdoutをforループで回しています。

command = ['./program']
P_PATH = '/home/user/デスクトップ/NewFolder'

prco = subprocess.Popen(command, cwd=P_PATH, stdout = subprocess.PIPE, stderr = subprocess.STDOUT)

for line in prco.stdout:
    print(line)

print("finish")

（forを使うと内部でイテレータが動いているらしいです）subprocessで起動したサーバーソフトを終了しないと要素が無くなった判定にならないのかStopIteration例外が出ず、forループから抜け出すことができません。

起動ログを取得したあと別の処理に移りたいので、一定期間出力がなければループを抜けたいのですが検知する方法が分からず困っています。

Python、Linux系OS初心者なので細かいところまで解説していただけると幸いです。

ご回答よろしくお願いします。

環境

Python 3.6.9
Ubuntu 18.04.4 LTS

Answer 1

timeout on subprocess readline in pythonの回答が参考になります。
以下では5秒出力がなければ起動したプロセスを終了し、後の処理を行うコード例です。

import asyncio
import sys
from asyncio.subprocess import PIPE, STDOUT

# 何らかの処理。単にlineを出力
def do_something(line):
    print(line.decode().rstrip())
    return True

async def run_command(*args, timeout=None):
    # start child process
    # NOTE: universal_newlines parameter is not supported
    process = await asyncio.create_subprocess_exec(*args,
            stdout=PIPE, stderr=STDOUT)

    # read line (sequence of bytes ending with b'\n') asynchronously
    while True:
        try:
            line = await asyncio.wait_for(process.stdout.readline(), timeout)
        except asyncio.TimeoutError:
            print('timeout')
        else:
            if not line: # EOF
                break
            elif do_something(line): 
                continue # while some criterium is satisfied
        process.kill() # timeout or some criterium is not satisfied
        break
    return await process.wait() # wait for the child process to exit


if __name__ == '__main__':

    if sys.platform == "win32":
        loop = asyncio.ProactorEventLoop() # for subprocess' pipes on Windows
        asyncio.set_event_loop(loop)
    else:
        loop = asyncio.get_event_loop()

    # 5秒出力がなければ終了する
    args = ('python', 'test.py')
    returncode = loop.run_until_complete(run_command(*args, timeout=5))
    loop.close()

    # 後の処理
    # ：
    print('after proc')

test.py

import time
import sys

for i in range(10):
    sys.stdout.write('{}\n'.format(i))
    sys.stdout.flush()
    time.sleep(i+1)

実行結果

0
1
2
3
4
5
timeout
after proc

Comments

[Reem]

ご回答ありがとうございます。
asyncio.create_subprocess_execとasyncio.wait_forで実現したい機能を作ることができました！
とても勉強になりました。

Answer 2

subprocessで実行しているコマンドが終了したかどうかを検出できればいいのでは

Comments

[Reem]

ご回答ありがとうございます。
分かりづい質問をしてしまいすみません。

subprocessで実行しているのはサーバーソフトなので、コマンドが終了したのを検知する方法だとサーバーソフトが終了した時にしかログが取得出来ません。
意図した回答と少し違うので、よろしければ再度ご回答お願いします。

[y_waiwai]

表題の通りなら、標準出力がなされた時点の時刻を取得しておいて、現在時刻とある程度の時間経過があったかどうかを判定すればいいという話となります