Python调用Bash命令时进度条输出错乱，如何处理？

问题根源 #

进度条类的终端输出依赖**回车符（\r）**实现行内刷新——每次更新进度时，用\r将光标移到行首，再覆盖输出新内容。但你用for line in p.stdout按行读取时，Python会把\r当作换行分隔符的一部分，导致每一次进度更新都被当作新行输出，最终出现对角线错位的情况。

解决方案 #

方案1：逐字符读取并处理控制字符 #

放弃按行读取，改为逐字符读取输出，手动处理\r控制符：

from subprocess import Popen, PIPE, CalledProcessError

command = "你的Bash命令"
with Popen(command.split(), stdout=PIPE, bufsize=0, universal_newlines=True) as p:
    buffer = []
    while True:
        char = p.stdout.read(1)
        if not char:
            break
        if char == '\r':
            # 遇到回车，将光标移到行首并清空缓冲区
            print('\r', end='')
            buffer = []
        elif char == '\n':
            # 遇到换行，输出缓冲区内容并换行
            print(''.join(buffer), end='\n')
            buffer = []
        else:
            buffer.append(char)
            # 实时输出字符，保持进度条动态效果
            print(char, end='', flush=True)

if p.returncode != 0:
    raise CalledProcessError(p.returncode, p.args)

方案2：模拟终端环境运行子进程 #

很多命令会检测输出是否为终端（TTY），仅在终端环境下输出动态进度条。可以用pty模块模拟终端，让子进程正常输出进度条：

import pty
import os
from subprocess import CalledProcessError

command = "你的Bash命令"
# 打开虚拟终端
master, slave = pty.openpty()
try:
    pid = os.fork()
    if pid == 0:
        # 子进程：将标准输出/错误重定向到虚拟终端
        os.dup2(slave, 1)
        os.dup2(slave, 2)
        os.close(master)
        os.close(slave)
        # 执行目标命令
        os.execvp(command.split()[0], command.split())
    else:
        # 父进程：读取虚拟终端输出
        os.close(slave)
        with os.fdopen(master, 'r') as f:
            for line in f:
                print(line, end='')
    # 检查命令返回码
    _, returncode = os.waitpid(pid, 0)
    if returncode != 0:
        raise CalledProcessError(returncode, command)
finally:
    # 清理资源
    try:
        os.close(master)
        os.close(slave)
    except:
        pass

方案3：直接禁用命令的进度条输出（可选） #

如果不需要看到进度条，可以给目标命令加参数关闭动态输出。比如apt命令加-qq参数，wget加--no-progress参数：

# 示例：用apt的静默模式执行移除操作
command = "apt remove language-pack-en language-pack-en-base -qq"
# 原有的Popen代码即可正常运行
with Popen(command.split(), stdout=PIPE, bufsize=1, universal_newlines=True) as p:
    for line in p.stdout:
        print(line, end='')

if p.returncode != 0:
    raise CalledProcessError(p.returncode, p.args)

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