使用Popen communicate输出乱码，求同步输出及命令间延时方案

我来帮你搞定这两个核心问题——输出乱码/无法同步显示，还有每条命令执行后等待5秒的需求。先拆解下你原代码里的问题，再给你针对性的解决方案：

原代码的问题点 #

• 你用了communicate()方法，它会一次性把所有命令传给bash进程，然后等整个bash会话结束才一次性返回所有输出，自然没法同步看到每条命令的执行结果；而且universal_newlines=True（现在Python 3.7+更推荐用text=True）已经把stdout/stderr转换成字符串了，你再调用o.decode('utf8')反而会触发错误，这也是乱码的潜在诱因。
• 一次性传入所有命令的方式，没法控制每条命令之间的5秒延迟，必须拆分命令逐个处理。

方案1：独立执行每条命令（命令间无环境依赖） #

如果你的命令之间不需要共享环境变量（比如前一条命令export的变量后一条不用），这种方式最简单可靠：

import subprocess
import time
from subprocess import Popen, PIPE

def do_shell(cmd):
    # 将多命令字符串按换行拆分，过滤空行避免无效执行
    commands = [cmd.strip() for cmd in cmd.split('\n') if cmd.strip()]
    
    for single_cmd in commands:
        # 启动子进程执行单条命令，合并stdout和stderr，实时输出
        p = Popen(
            single_cmd,
            shell=True,
            text=True,  # 等价于universal_newlines=True，自动处理编码
            stdout=subprocess.STDOUT,
            stderr=subprocess.STDOUT
        )
        # 逐行读取并打印输出，实现同步显示
        for line in p.stdout:
            print(line, end='')
        # 等待命令执行完成
        p.wait()
        # 每条命令执行后等待5秒
        time.sleep(5)

关键说明 #

• text=True确保输出直接是字符串，无需手动decode，从根源避免编码乱码问题；
• stdout=subprocess.STDOUT把标准错误合并到标准输出，不用分开处理；
• 逐行读取子进程输出并实时打印，完美解决同步显示问题；
• 每条命令独立执行，执行完成后强制等待5秒再执行下一条。

方案2：共享bash进程（命令间有环境依赖） #

如果你的命令之间需要共享环境（比如前一条命令设置的环境变量、工作目录等要被后一条使用），就需要保持同一个bash进程，逐条发送命令并控制延迟：

import subprocess
import time
from subprocess import Popen, PIPE

def do_shell(cmd):
    commands = [cmd.strip() for cmd in cmd.split('\n') if cmd.strip()]
    
    # 启动一个持久的bash进程，保持stdin/stdout打开
    bash_process = Popen(
        '/bin/bash',
        shell=False,
        text=True,
        stdin=PIPE,
        stdout=subprocess.STDOUT,
        stderr=subprocess.STDOUT
    )
    
    for single_cmd in commands:
        # 向bash发送单条命令，加换行触发执行
        bash_process.stdin.write(f"{single_cmd}\n")
        bash_process.stdin.flush()  # 确保命令被立即发送
        
        # 实时读取并打印输出，直到当前命令执行完成
        while True:
            line = bash_process.stdout.readline()
            # 当没有输出且进程未退出时继续等待，否则跳出循环
            if not line and bash_process.poll() is not None:
                break
            print(line, end='')
        
        # 命令执行完成后等待5秒
        time.sleep(5)
    
    # 关闭stdin，让bash进程退出
    bash_process.stdin.close()
    bash_process.wait()

关键说明 #

• 保持同一个bash进程，确保命令间的环境状态一致；
• 逐条发送命令并手动flush，确保bash立即执行；
• 循环读取输出直到当前命令执行完成，实现同步显示；
• 最后关闭stdin并等待bash进程退出，避免资源泄漏。

内容的提问来源于stack exchange，提问作者user6882413