Python: subprocess.call broken pipe

Question

Я пытаюсь вызвать скрипт оболочки в python, но он продолжает сообщать об ошибке поврежденного канала (результат в порядке, но я не хочу видеть сообщение об ошибке в STDERR). Я точно определили причину, и она может быть воспроизведена в следующем фрагменте:

subprocess.call('cat /dev/zero | head -c 10 | base64', shell=True)

AAAAAAAAAAAAAA ==

кошки: написать об ошибке: Broken трубы

/dev/zero бесконечный поток, но head -c 10 только считывает 10 байтов из него и выходит, тогда кошка получит SIGPIPE из-за того, что сверстник закрыл трубу. Когда я запускаю команду в оболочке, нет сообщения об ошибке сбойной трубы, но почему это показывает python?

Answer 1

В этом тривиальном случае, по крайней мере, вы ничего не набираете, используя команды оболочки —, и вы теряете переносимость и скорость.

Python 2 Код:

>>> import base64 
>>> base64.b64encode(open('/dev/zero', 'rb').read(10)) 
'AAAAAAAAAAAAAA==' 
>>> base64.b64encode('\0' * 10) 
'AAAAAAAAAAAAAA==' 

В Python 3 (код также будет работать в 2.6+, хотя он будет возвращать str, а не bytes экземпляров):

>>> import base64 
>>> base64.b64encode(open('/dev/zero', 'rb').read(10)) 
b'AAAAAAAAAAAAAA==' 
>>> base64.b64encode(b'\0' * 10) 
b'AAAAAAAAAAAAAA==' 

В каждом случае, первый пример сохраняет использование /dev/zero (сам по себе не переносимый, но неважно), второй производит эффект, хотя я думаю, что это не то, что вы хотите конкретно?

Answer 2

Действие по умолчанию для сигнала SIGPIPE - это прекращение программы. Интерпретатор Python меняет его на SIG_IGN, чтобы иметь возможность сообщать об ошибках разбитых труб в программу в виде исключений.

Когда вы выполняете cat ... |head ... в оболочке, cat имеет обработчик SIGPIPE по умолчанию, а ядро ​​ОС просто завершает его на SIGPIPE.

При выполнении cat с помощью subprocess это унаследованный обработчик SIGPIPE от своего родителя (питон переводчик), SIGPIPE просто игнорируются, и cat обрабатывает самое ошибку, проверяя errno переменного и печати сообщения об ошибке.

Чтобы избежать сообщений об ошибках от cat вы можете использовать preexec_fn аргумент subprocess.call:

from signal import signal, SIGPIPE, SIG_DFL 
subprocess.call(
    'cat /dev/zero | head -c 10 | base64', 
    shell = True, 
    preexec_fn = lambda: signal(SIGPIPE, SIG_DFL) 
)