Wie kann ich die Ausgabe von Unterprozessen mit Python in Echtzeit streamen?

Streaming-Ausgabe von Subprocess.communicate()

Bei Verwendung von subprocess.communicate() zum Abrufen der Ausgabe eines Prozesses wird die Gesamtheit der Die Standardausgabe (stdout) kann sofort zurückgegeben werden, wodurch eine Echtzeitüberwachung der Ausgabe verhindert wird. Dieses Problem entsteht aufgrund der blockierenden Natur der Funktion „communic()“.

Um dieses Problem zu beheben, kann man einen Streaming-Ansatz anwenden, um jede Zeile von stdout zu drucken, sobald sie verfügbar ist. Dies kann durch den Einsatz von Iteratoren und die Manipulation des bufsize-Parameters von Popen() erreicht werden.

In Python 2:

from subprocess import Popen, PIPE

p = Popen(["cmd", "arg1"], stdout=PIPE, bufsize=1)
with p.stdout:
    for line in iter(p.stdout.readline, b''):
        print(line)
p.wait()

In Python 3 lautet der Code:

from subprocess import Popen, PIPE

with Popen(["cmd", "arg1"], stdout=PIPE, bufsize=1, universal_newlines=True) as p:
    for line in p.stdout:
        print(line, end='')

Der Parameter bufsize=1 zwingt den Prozess, seinen Ausgabepuffer nach jeder Zeile zu leeren, um sicherzustellen, dass jede Zeile sofort gedruckt wird. iter() ermöglicht das asynchrone Lesen von Zeilen und ermöglicht so das Streamen der Ausgabe. Die Prozessbeendigung wird mit der Methode wait() abgewickelt.

Durch die Verwendung dieses Streaming-Ansatzes können Sie die Ausgabe eines Prozesses mit langer Laufzeit in Echtzeit überwachen, ohne die Synchronität der Funktion communications() zu beeinträchtigen.

Das obige ist der detaillierte Inhalt vonWie kann ich die Ausgabe von Unterprozessen mit Python in Echtzeit streamen?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!