Wie kann ich die Ausgabe eines Unterprozesses Zeile für Zeile in Python streamen?

Streaming-Ausgabe von subprocess.communicate()

Die Funktion subprocess.communicate() von Python ist nützlich, um die Standardausgabe eines Prozesses zu erfassen. Normalerweise wird jedoch die gesamte Ausgabe auf einmal zurückgegeben. Dies kann für Prozesse, die über einen längeren Zeitraum Output erzeugen, unpraktisch sein. Um dieses Problem anzugehen, untersuchen wir eine Technik zum Drucken jeder Zeile der Standardausgabe des Prozesses im Streaming-Modus.

Lösung

Durch den Einsatz eines iterativen Mechanismus können wir Zeilen abrufen von stdout, sobald sie werden verfügbar:

from subprocess import Popen, PIPE

# Launch a process with buffering set to 1 byte
p = Popen(["cmd", "arg1"], stdout=PIPE, bufsize=1)

# Iterate over the stdout lines as they become available
with p.stdout:
    for line in iter(p.stdout.readline, b''):
        print(line, end='')

# Wait for the process to terminate
p.wait()

Erklärung

• iter(p.stdout.readline, b''): Dadurch wird ein Iterator erstellt, der kontinuierlich Zeilen von p liest .stdout auf nicht blockierende Weise.
• end='': Dadurch wird sichergestellt, dass jede Zeile ohne einen nachgestellten Zeilenumbruch gedruckt wird Zeichen.
• p.wait(): Sobald der Iterator erschöpft ist, wartet diese Funktion, bis der Prozess abgeschlossen ist, bevor sie fortfährt.

Zusätzliche Hinweise

• Für Python 2 ist iter() erforderlich, um ein Vorauslesen zu umgehen Fehler.
• Für Python 3 dekodiert die Option universal_newlines die Standardausgabe automatisch in Text.
• Alternative Methoden wie Pexpect oder ungepufferte Dienstprogramme können ebenfalls verwendet werden, um eine ungepufferte Standardausgabe zu erzwingen.

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