IO错误：[错误32]破碎的管道：Python的

Question

我有一个非常简单的Python 3脚本：

f1 = open('a.txt', 'r') 
print(f1.readlines()) 
f2 = open('b.txt', 'r') 
print(f2.readlines()) 
f3 = open('c.txt', 'r') 
print(f3.readlines()) 
f4 = open('d.txt', 'r') 
print(f4.readlines()) 
f1.close() 
f2.close() 
f3.close() 
f4.close() 

但它总是说：

IOError: [Errno 32] Broken pipe 

我在网上看到的所有复杂的方式要解决这个问题，但我直接复制了这段代码，所以我认为代码有问题，而不是Python的SIGPIPE。

我重定向输出，因此，如果上面的脚本被命名为“open.py”，那么我的命令来运行将是：

open.py | othercommand 

Answer 1

我没有复制问题，但也许这种方法将解决这个问题：（写一行行至stdout，而不是使用print）

import sys 
with open('a.txt', 'r') as f1: 
    for line in f1: 
     sys.stdout.write(line) 

---

你可以赶上破裂的管道？这会将文件逐行写入stdout，直到管道关闭。

import sys, errno 
try: 
    with open('a.txt', 'r') as f1: 
     for line in f1: 
      sys.stdout.write(line) 
except IOError as e: 
    if e.errno == errno.EPIPE: 
     # Handle error 

你还需要确保othercommand从管道读取它变得太大之前 - https://unix.stackexchange.com/questions/11946/how-big-is-the-pipe-buffer

Answer 2

当您尝试写入已关闭的管道时，会发生“断管”的错误另一端。由于你所展示的代码并不直接涉及任何管道，我怀疑你正在做一些Python之外的事情来将Python解释器的标准输出重定向到其他地方。如果你正在运行一个脚本，这样就会出现这种情况：

python foo.py | someothercommand 

你的问题是，someothercommand是不读的标准输入提供一切退出。这会导致您的写入（通过print）在某个时候失败。

我能够重现误差与Linux系统上下面的命令：

python -c 'for i in range(1000): print i' | less 

如果我关闭less寻呼机，而不通过其所有的输入（1000线）的滚动，Python的离开与同IOError你已经报告过。

Answer 3

问题是由于SIGPIPE处理。您可以使用下面的代码解决这个问题：

from signal import signal, SIGPIPE, SIG_DFL 
signal(SIGPIPE,SIG_DFL) 

See here有关此解决方案的背景。

Answer 4

如果从脚本输出的读端过早死亡

即open.py这也可能发生| otherCommand

如果otherCommand出口和open.py尝试写入到stdout

我有没有这个可爱的给我一个坏的GAWK脚本。

Answer 5

关闭应按照打开的相反顺序完成。

Answer 6

要使用一些额外的信息带来Alex L.'s helpful answer，akhan's helpful answer和Blckknght's helpful answer在一起：

• Standard Unix signal SIGPIPE被送到写到pipe过程当没有过程从管道读取（再）。

  • 这不一定是一个错误条件;一些Unix实用程序，如head设计一旦收到足够的数据，就会停止从管道中过早读取数据。

• 默认情况下 - 即如果写作过程中没有明确陷阱SIGPIPE - 写作过程很简单终止，它的退出代码设置为141，其计算公式为（通常信号终止信号）+ 13（SIGPIPE的特定信号号码）。

• 在设计上，然而，的Python 本身陷阱SIGPIPE和将其转换为一个Python IOError实例与errno值errno.EPIPE，使Python脚本可以赶上它，如果它选择这样做 - 看Alex L.'s answer为怎么做。

• 如果一个Python脚本不不抓它，巨蟒输出错误信息IOError: [Errno 32] Broken pipe和终止，退出代码为1脚本 - 这是症状的OP锯。

• 在许多情况下这是比有用更具破坏性，所以恢复到默认的行为是可取的：

  • 使用signal模块允许了这一点，如在规定akhan's answer; signal.signal()作为第二个参数处理第一个参数和处理程序;特殊句柄值SIG_DFL表示系统的默认行为：

    from signal import signal, SIGPIPE, SIG_DFL 
    signal(SIGPIPE, SIG_DFL) 
    

Answer 7

我觉得有必要指出的是，该方法使用

signal(SIGPIPE, SIG_DFL) 

确实危险（如已David Bennet在评论中建议），而在我的情况下，梳理时会导致依赖平台的有趣业务用multiprocessing.Manager（因为标准库依赖BrokenPipeError在几个地方被引发）。为了让这个漫长而痛苦的故事变得简短，我就这样修复它：

首先，您需要赶上IOError（Python 2）或BrokenPipeError（Python 3）。根据您的程序，您可以尝试早点退出或忽略该例外：

from errno import EPIPE 

try: 
    broken_pipe_exception = BrokenPipeError 
except NameError: # Python 2 
    broken_pipe_exception = IOError 

try: 
    YOUR CODE GOES HERE 
except broken_pipe_exception as exc: 
    if broken_pipe_exception == IOError: 
     if exc.errno != EPIPE: 
      raise 

但是，这还不够。 Python 3里仍然可以打印这样的消息：

Exception ignored in: <_io.TextIOWrapper name='<stdout>' mode='w' encoding='UTF-8'> 
BrokenPipeError: [Errno 32] Broken pipe 

不幸的是摆脱该消息并不简单，但我终于找到http://bugs.python.org/issue11380其中罗伯特·柯林斯表明，这种解决办法，我变成了一个装饰你可以用你的主要功能（是的，这是一些疯狂的缩进）：

from functools import wraps 
from sys import exit, stderr, stdout 
from traceback import print_exc 


def suppress_broken_pipe_msg(f): 
    @wraps(f) 
    def wrapper(*args, **kwargs): 
     try: 
      return f(*args, **kwargs) 
     except SystemExit: 
      raise 
     except: 
      print_exc() 
      exit(1) 
     finally: 
      try: 
       stdout.flush() 
      finally: 
       try: 
        stdout.close() 
       finally: 
        try: 
         stderr.flush() 
        finally: 
         stderr.close() 
    return wrapper 


@suppress_broken_pipe_msg 
def main(): 
    YOUR CODE GOES HERE