‘是’报告子进程通信错误（）

问题描述：

我正在使用以下函数在 Python 中运行命令：

def run_proc(cmd):
    child = subprocess.Popen(cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
    stdout, stderr = child.communicate()
    returncode = child.returncode
    return stdout, stderr, returncode

它一直运行良好，但现在我尝试使用该yes程序将输出传送到 stdin。我尝试运行的命令如下：

yes '' | apt-get -y -o Dpkg::Options::="--force-confdef" -o Dpkg::Options::="--force-confold" dist-upgrade

但我相信它可以用一个一般的例子来代替，例如：

yes | head -3 | cat

我的问题是，如果我尝试运行其中的任何命令yes |，上述 subprocess.Popen 将包含错误消息：

yes: standard output: Broken pipe
yes: write error

对我来说，管道似乎仍然有效，从yes | head -3 | cat的回答可以看出：y y y。

我有以下问题：

1. 即使 yes 报告错误，yes 管道是否仍然可以发挥作用？

2. 我该如何修复它？

解决方案 1：

问题是 Python 3.2+ 之前的subprocess模块不会将SIGPIPE信号处理程序恢复为默认操作。这就是为什么你会得到EPIPE写入错误。

在 Python 3.2+ 中

>>> from subprocess import check_output
>>> check_output("yes | head -3", shell=True)
b'y
y
y
'

yes`SIGPIPE在退出时被杀死head`。

在 Python 2 中：

>>> from subprocess import check_output
>>> check_output("yes | head -3", shell=True)
yes: standard output: Broken pipe
yes: write error
'y
y
y
'

yes出现EPIPE写入错误。忽略该错误是安全的。它传达的信息与 相同SIGPIPE。

为了解决该问题，你可以restore_signals在 Python 2 中使用preexec_fn参数进行模拟：

>>> from subprocess import check_output
>>> import signal
>>> def restore_signals(): # from http://hg.python.org/cpython/rev/768722b2ae0a/
...     signals = ('SIGPIPE', 'SIGXFZ', 'SIGXFSZ')
...     for sig in signals:
...         if hasattr(signal, sig):
...            signal.signal(getattr(signal, sig), signal.SIG_DFL)
... 
>>> check_output("yes | head -3", shell=True, preexec_fn=restore_signals)
'y
y
y
'

解决方案 2：

另一个问题回答了为什么……我会尝试给你一个解决方法

你不能做点什么吗

proc = subprocess.Popen(cmd, shell=True, 
                             stdout=subprocess.PIPE, 
                             stderr=subprocess.PIPE,
                             stdin = subprocess.PIPE)

for i in range(10):  #send 10 y's
    time.sleep(1) # 1 second apart
    proc.stdin.write("y") #you may also need to send a newline ...

print proc.communicate()

见下文（我没有考虑延迟，因为头部并没有做太多事情）

>>> import subprocess
>>> proc = subprocess.Popen("head -3",
...                          shell = True,
...                          stdout = subprocess.PIPE,
...                          stderr=subprocess.PIPE,
...                          stdin=subprocess.PIPE)
>>> for i in range(10):
...    proc.stdin.write("y
")
...
>>> proc.communicate()
('y
y
y
', '')

解决方案 3：

谚语：

yes | head -3

一旦读取完 3 行输入，就会head发送一个SIGPIPE到，即它会发送一个信号来终止。yes`yes`

$ yes | head -3
y
y
y
$ echo "${PIPESTATUS[@]}"
141 0

解决办法是避免SIGPIPE！