AttributeError: объект «zstd.ZstdDecompressionReader» не имеет атрибута «fileno». ⇐ Python

[Anonymous]

Мне нужно запустить конвейер подпроцесса, который использует файлы zstandard (слишком большие, чтобы поместиться в памяти) как на входе, так и на выходе. Рассмотрим следующий пример:

Код: Выделить всё

import subprocess
import zstandard

with zstandard.open('a.txt.zst', 'w') as f:
f.write('hello\n')

f_in = zstandard.open('a.txt.zst', 'rb')
f_out = zstandard.open('b.txt.zst', 'wb')

# in reality I'd be running multiple programs here by chaining PIPEs, but first
# reads f_in and last writes to f_out:
subprocess.call(['cat'], stdin=f_in, stdout=f_out)

Я получаю следующую ошибку:

Код: Выделить всё

Traceback (most recent call last):
File "/tmp/a.py", line 12, in 
subprocess.call(['cat'], stdin=f_in, stdout=f_out)
File "/usr/lib/python3.11/subprocess.py", line 389, in call
with Popen(*popenargs, **kwargs) as p:
^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/lib/python3.11/subprocess.py", line 892, in __init__
errread, errwrite) = self._get_handles(stdin, stdout, stderr)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/lib/python3.11/subprocess.py", line 1661, in _get_handles
p2cread = stdin.fileno()
^^^^^^^^^^^^
AttributeError: 'zstd.ZstdDecompressionReader' object has no attribute 'fileno'

Я подумываю использовать PIPE на обоих концах и снабжать их потоками, но это кажется довольно хрупким. Есть ли более идиоматическое решение этой проблемы?

Подробнее здесь: https://stackoverflow.com/questions/792 ... ute-fileno