Comment puis-je diffuser la sortie du sous-processus en temps réel en Python ?

Diffusion en continu de la sortie du sous-processus pendant l'exécution du processus

En Python, la méthode execute() est couramment utilisée pour exécuter des commandes externes. Cependant, par défaut, il attend la fin du processus avant de renvoyer la sortie stdout et stderr combinées. Cela peut être indésirable pour les processus de longue durée.

Pour permettre l'impression en temps réel des résultats du processus, vous pouvez exploiter la puissance des itérateurs et de l'option universal_newlines de Python. Prenons cet exemple :

<code class="python">from __future__ import print_function # Only Python 2.x
import subprocess

def execute(cmd):
    popen = subprocess.Popen(cmd, stdout=subprocess.PIPE, universal_newlines=True)
    for stdout_line in iter(popen.stdout.readline, ''):
        yield stdout_line
    popen.stdout.close()
    return_code = popen.wait()
    if return_code:
        raise subprocess.CalledProcessError(return_code, cmd)</code>

Cette fonction exécutée() améliorée lance le processus à l'aide de Popen, garantissant que la sortie standard est redirigée et que les nouvelles lignes sont gérées automatiquement (universal_newlines=True). Il utilise ensuite un itérateur (iter(popen.stdout.readline, '')) pour parcourir la sortie standard ligne par ligne.

Cette approche vous permet de diffuser la sortie du processus dès qu'elle devient disponible dans une boucle, permettant vous d'afficher les progrès en temps réel ou de répondre aux résultats intermédiaires en conséquence.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!