如何从 subprocess.Popen() 获取输出。 proc.stdout.readline() 阻塞，没有数据打印出来

Question

我想要执行 Test_Pipe.py 的输出，我尝试在 Linux 上执行以下代码，但它不起作用。

Test_Pipe.py

import time
while True :
    print "Someting ..."
    time.sleep(.1)

Caller.py

import subprocess as subp
import time

proc = subp.Popen(["python", "Test_Pipe.py"], stdout=subp.PIPE, stdin=subp.PIPE)

while True :
    data = proc.stdout.readline() #block / wait
    print data
    time.sleep(.1)

proc.stdout.readline() 行被阻塞，因此没有数据打印出来。

Answer 1

您显然可以使用 subprocess.communicate 但我认为您正在寻找实时输入和输出。

readline 被阻止，因为该进程可能正在等待您的输入。您可以逐个字符地阅读来克服这个问题，如下所示：

import subprocess
import sys

process = subprocess.Popen(
    cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE
)

while True:
    out = process.stdout.read(1)
    if out == '' and process.poll() != None:
        break
    if out != '':
        sys.stdout.write(out)
        sys.stdout.flush()

Answer 2

Nadia 的代码片段确实有效，但强烈不建议使用 1 字节缓冲区调用 read。更好的方法是使用 fcntl 将 stdout 文件描述符设置为非阻塞

fcntl.fcntl(
    proc.stdout.fileno(),
    fcntl.F_SETFL,
    fcntl.fcntl(proc.stdout.fileno(), fcntl.F_GETFL) | os.O_NONBLOCK,
)

，然后使用 select 测试数据是否准备好。

while proc.poll() == None:
    readx = select.select([proc.stdout.fileno()], [], [])[0]
    if readx:
        chunk = proc.stdout.read()
        print chunk

她是正确的，您的问题必须与您发布的 Caller.py 和 Test_Pipe 不同。 py 按规定工作。

• https://derrickpetzold.com/p/capturing-output-from-ffmpeg-蟒蛇/

Answer 3

Test_Pipe.py 默认情况下缓冲其标准输出，因此 Caller.py 中的 proc 在子进程的缓冲区已满之前看不到任何输出（如果缓冲区大小为 8KB，则需要大约一分钟来填充 Test_Pipe.py 的 stdout 缓冲区）。

要使输出无缓冲（文本流的行缓冲），您可以传递 < code>-u flag 到子 Python 脚本。它允许“实时”逐行读取子进程的输出：

import sys
from subprocess import Popen, PIPE

proc = Popen([sys.executable, "-u", "Test_Pipe.py"], stdout=PIPE, bufsize=1)
for line in iter(proc.stdout.readline, b''):
    print line,
proc.communicate()

请参阅 Python：从 subprocess.communicate 读取流输入( ），了解如何解决非 Python 子进程的块缓冲问题。

Answer 4

为了避免缓冲任务（例如“实时获取子进程的输出到主进程”）时可能出现的许多问题，我始终建议使用 pexpect 适用于所有非 Windows 平台，wexpect，而不是 subprocess。