在 uwsgi/gunicorn 多进程环境中，如何用 Python 获取 os.popen() 和 subprocess.Popen() 的回调信息？

在uWSGI/Gunicorn多进程环境里，用os.popen()和subprocess.Popen()获取回调信息确实要注意进程隔离问题。直接在主进程里开子进程，worker重启时子进程会变孤儿进程。

简单粗暴的解法是用subprocess.Popen()配合communicate()同步获取输出：

import subprocess

def run_command(cmd):
    proc = subprocess.Popen(
        cmd,
        shell=True,
        stdout=subprocess.PIPE,
        stderr=subprocess.PIPE,
        text=True
    )
    stdout, stderr = proc.communicate()
    return {
        'returncode': proc.returncode,
        'stdout': stdout,
        'stderr': stderr
    }

但这样会阻塞worker。要实时获取输出的话，得用异步方式：

import subprocess
import select

def run_command_async(cmd):
    proc = subprocess.Popen(
        cmd,
        shell=True,
        stdout=subprocess.PIPE,
        stderr=subprocess.PIPE,
        text=True,
        bufsize=1
    )
    
    outputs = []
    while True:
        reads = [proc.stdout.fileno(), proc.stderr.fileno()]
        ret = select.select(reads, [], [])
        
        for fd in ret[0]:
            if fd == proc.stdout.fileno():
                line = proc.stdout.readline()
                if line:
                    outputs.append(('stdout', line.strip()))
            if fd == proc.stderr.fileno():
                line = proc.stderr.readline()
                if line:
                    outputs.append(('stderr', line.strip()))
        
        if proc.poll() is not None:
            break
    
    # 收尾
    for line in proc.stdout:
        outputs.append(('stdout', line.strip()))
    for line in proc.stderr:
        outputs.append(('stderr', line.strip()))
    
    return {
        'returncode': proc.returncode,
        'outputs': outputs
    }

更稳当的做法是把耗时命令扔到Celery之类的任务队列里，避免阻塞worker进程。用消息队列解耦最靠谱。