python - Python、Popen、select-プロセスの終了またはタイムアウトを待機中

Question

私は以下を使用してサブプロセスを実行します：

  p = subprocess.Popen("subprocess", 
                       stdout=subprocess.PIPE, 
                       stderr=subprocess.PIPE, 
                       stdin=subprocess.PIPE)

このサブプロセスは、stderrでエラーが発生してすぐに終了するか、実行を継続する可能性があります。これらの状態のいずれかを検出したい-後者は数秒待つことによって。

私はこれを試しました：

  SECONDS_TO_WAIT = 10
  select.select([], 
                [p.stdout, p.stderr], 
                [p.stdout, p.stderr],
                SECONDS_TO_WAIT)

しかし、それはただ戻ります：

  ([],[],[])

どちらの条件でも。私に何ができる？

score 15 · Accepted Answer

Popen.Poll() メソッドを使用してみましたか。これを行うことができます：

p = subprocess.Popen("subprocess", 
                   stdout=subprocess.PIPE, 
                   stderr=subprocess.PIPE, 
                   stdin=subprocess.PIPE)

time.sleep(SECONDS_TO_WAIT)
retcode = p.poll()
if retcode is not None:
   # process has terminated

これにより、常に 10 秒間待機することになりますが、失敗のケースがまれな場合、これはすべての成功のケースで償却されます。

編集：

どうですか：

t_nought = time.time()
seconds_passed = 0

while(p.poll() is not None and seconds_passed < 10):
    seconds_passed = time.time() - t_nought

if seconds_passed >= 10:
   #TIMED OUT

これには忙しい待ち時間という醜さがありますが、あなたが望むものを達成すると思います。

さらに、select call のドキュメントをもう一度見てみると、次のように変更したいと思うかもしれません。

SECONDS_TO_WAIT = 10
  select.select([p.stderr], 
                [], 
                [p.stdout, p.stderr],
                SECONDS_TO_WAIT)

通常は stderr から読み取りたいので、いつ読み取り可能なものがあるか (つまり、失敗の場合) を知りたいと思うでしょう。

これが役立つことを願っています。

score 7 · Accepted Answer

これが私が思いついたものです。p プロセスでタイムアウトが必要な場合と不要な場合に機能しますが、セミビジーループがあります。

def runCmd(cmd, timeout=None):
    '''
    Will execute a command, read the output and return it back.

    @param cmd: command to execute
    @param timeout: process timeout in seconds
    @return: a tuple of three: first stdout, then stderr, then exit code
    @raise OSError: on missing command or if a timeout was reached
    '''

    ph_out = None # process output
    ph_err = None # stderr
    ph_ret = None # return code

    p = subprocess.Popen(cmd, shell=True,
                         stdout=subprocess.PIPE,
                         stderr=subprocess.PIPE)
    # if timeout is not set wait for process to complete
    if not timeout:
        ph_ret = p.wait()
    else:
        fin_time = time.time() + timeout
        while p.poll() == None and fin_time > time.time():
            time.sleep(1)

        # if timeout reached, raise an exception
        if fin_time < time.time():

            # starting 2.6 subprocess has a kill() method which is preferable
            # p.kill()
            os.kill(p.pid, signal.SIGKILL)
            raise OSError("Process timeout has been reached")

        ph_ret = p.returncode


    ph_out, ph_err = p.communicate()

    return (ph_out, ph_err, ph_ret)

score 3 · Accepted Answer

これが良い例です：

from threading import Timer
from subprocess import Popen, PIPE

proc = Popen("ping 127.0.0.1", shell=True)
t = Timer(60, proc.kill)
t.start()
proc.wait()

score 2 · Accepted Answer

selectと sleepを使用してもあまり意味がありません。 select (またはカーネルポーリングメカニズム) は本質的に非同期プログラミングに役立ちますが、あなたの例は同期です。したがって、通常のブロッキング方式を使用するようにコードを書き直すか、Twisted の使用を検討してください。

from twisted.internet.utils import getProcessOutputAndValue
from twisted.internet import reactor    

def stop(r):
    reactor.stop()
def eb(reason):
    reason.printTraceback()
def cb(result):
    stdout, stderr, exitcode = result
    # do something
getProcessOutputAndValue('/bin/someproc', []
    ).addCallback(cb).addErrback(eb).addBoth(stop)
reactor.run()

ちなみに、独自の ProcessProtocol を作成することにより、Twisted でこれを行うより安全な方法があります。

http://twistedmatrix.com/projects/core/documentation/howto/process.html

score 2 · Accepted Answer

パイソン3.3

import subprocess as sp

try:
    sp.check_call(["/subprocess"], timeout=10,
                  stdin=sp.DEVNULL, stdout=sp.DEVNULL, stderr=sp.DEVNULL)
except sp.TimeoutError:
    # timeout (the subprocess is killed at this point)
except sp.CalledProcessError:
    # subprocess failed before timeout
else:
    # subprocess ended successfully before timeout

TimeoutExpired のドキュメントを参照してください。

score 1 · Accepted Answer

上記のコメントで述べたように、毎回出力を微調整してコマンドを再実行するだけの場合、次のように機能しますか?

from threading import Timer
import subprocess

WAIT_TIME = 10.0

def check_cmd(cmd):
    p = subprocess.Popen(cmd,
        stdout=subprocess.PIPE, 
            stderr=subprocess.PIPE)
    def _check():
        if p.poll()!=0:
            print cmd+" did not quit within the given time period."

    # check whether the given process has exited WAIT_TIME
    # seconds from now
    Timer(WAIT_TIME, _check).start()

check_cmd('echo')
check_cmd('python')

上記のコードを実行すると、次のように出力されます。

python did not quit within the given time period.

私が考えることができる上記のコードの唯一の欠点は、check_cmd を実行し続けるとプロセスがオーバーラップする可能性があることです。

score 0 · Accepted Answer

これはエヴァンの答えの言い換えですが、次のことを考慮しています。

Timer オブジェクトを明示的にキャンセルする: Timer 間隔が長くなり、プロセスが「自分の意志」によって終了する場合、スクリプトがハングする可能性があります :(

タイマーアプローチには固有の競合があります (プロセスが終了した直後にタイマーがプロセスを強制終了しようとすると、Windows では例外が発生します)。

  DEVNULL = open(os.devnull, "wb")
  process = Popen("c:/myExe.exe", stdout=DEVNULL) # no need for stdout

  def kill_process():
  """ Kill process helper"""
  try:
     process.kill()
   except OSError:
     pass  # Swallow the error

  timer = Timer(timeout_in_sec, kill_process)
  timer.start()

  process.wait()
  timer.cancel()

python - Python、Popen、select-プロセスの終了またはタイムアウトを待機中

7 に答える 7

パイソン3.3

Related

Reference