如何将打印和标准输出重定向到管道并从父进程读取它？

Question

如果可能我不想使用subProcess.popen。我想捕获子进程启动的stdout的原因是因为我需要将子进程的输出保存到一个变量中以便以后再显示出来。不过，我还没有找到一种方法来做到这一点。我还需要激活多个程序，而不必关闭活动的程序。我还需要控制父流程中的子流程。

我推出一个子这样

listProgram = ["./perroquet.py"] 
listOutput = ["","",""] 
tubePerroquet = os.pipe() 
pipeMain = os.pipe() 
pipeAge = os.pipe() 
pipeSavoir = os.pipe() 
pid = os.fork() 
process = 1 
if pid == 0: 
    os.close(pipePerroquet[1]) 
    os.dup2(pipePerroquet[0],0) 
    sys.stdout = os.fdopen(tubeMain[1], 'w') 
    os.execvp("./perroquet.py", listProgram) 

现在你可以看到我启动程序与os.execvp和使用os.dup2()重定向孩子的标准输出。但是我不确定我在代码中做了什么，并且想知道将os.dup2重定向stdout然后能够在父进程中读取它的正确方法。

谢谢你的帮助。

Answer 1

我不明白为什么你不想使用优秀的子过程模块，可以为您节省大量的锅炉板代码（以及尽可能多的错误可能性......）。无论如何，我认为perroquet.py是一个python脚本，而不是一个可执行程序。 Shell知道如何为脚本找到正确的解释器，但exec系列是低级函数，它需要一个可执行程序实际。

你至少应该有这样的事情：

listProgram = [ "python", "./perroquet.py","",""] 
... 
    os.execvp("python", listProgram) 

但我宁愿使用：

prog = subprocess.Popen(("python", "./perroquet.py", "", ""), stdout = PIPE) 

，甚至因为你已经在Python进口并直接从那里调用的函数。

编辑：

看起来thart你真正想要的是：

• 用户给你的命令（几乎可以是任何东西）
• [您验证该命令是安全] - 不确定如果你打算这样做，但你应该...
• 你让shell执行命令并获得它的输出 - 你也可能想读stderr并控制退出代码

你应该尝试像

while True: 
    cmd = raw_input("commande :") # input with Python 3 
    if cmd.strip().lower() == exit: break 
    proc = subprocess.Popen(cmd, stdout=subprocess.PIPE, 
     stderr=subprocess.PIPE, shell=True) 
    out, err = proc.communicate() 
    code = proc.returncode 
    print("OUT", out, "ERR", err, "CODE", code) 

这是绝对不安全的，因为这个代码执行任何命令作为底层壳会做（包括rm -rf *，rd /s/q .，...），但它给你的输出，命令的输出和返回代码，并且可以使用它是一个循环。唯一的限制是，当你为每个命令使用一个不同的shell时，你不能使用改变shell环境的命令 - 它们将被执行但不会有效果。

Answer 2

这里有一个解决方案，如果你需要提取环境

from subprocess import Popen, PIPE 
import os  

def execute_and_get_env(cmd, initial_env=None): 
    if initial_env is None: 
     initial_env = os.environ 

    r_fd, w_fd = os.pipe() 
    write_env = "; env >&{}".format(w_fd) 

    p = Popen(cmd + write_env, shell=True, env=initial_env, pass_fds=[w_fd], stdout=PIPE, stderr=PIPE) 
    output, error = p.communicate() 

    # this will cause problems if the environment gets very large as 
    # writing to the pipe will hang because it gets full and we only 
    # read from the pipe when the process is over 
    os.close(w_fd) 
    with open(r_fd) as f: 
     env = dict(line[:-1].split("=", 1) for line in f) 

    return output, error, env 

export_cmd = "export my_var='hello world'" 
echo_cmd = "echo $my_var" 

out, err, env = execute_and_get_env(export_cmd) 
out, err, env = execute_and_get_env(echo_cmd, env) 

print(out)