Асинхронный генератор для BytesIO или аналогичный? ⇐ Python

[Anonymous]

У меня есть поток данных в службе FastAPI, куда загружается (потенциально очень большое) тело HTTP PUT, и мне нужно передать его в потоковом режиме в Google Cloud Storage. Я использую библиотеку gcloud.aio.storage для взаимодействия с Google Cloud Storage для поддержки asyncio (она основана на aiohttp). Я пытаюсь передать тело через потоковую передачу, так как невозможно сохранить все тело в памяти одновременно.
Проблема, с которой я столкнулся, заключается в том, что fastapi request.stream() предоставляет асинхронный генератор, в то время как клиент хранилища ожидает либо необработанные данные в виде байтов или строки, либо что-то на основе io.IOBase.
Итак, если я вызову следующее:

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

async def upload(request: fastapi.Request, storage_client: gcloud.aio.storage.Storage):
upload_stream = request.stream()
await storage_client.upload(
"my_bucket",
"my_object",
upload_stream
)

Ошибка TypeError: неподдерживаемый тип загрузки: «»
Как мне получить файл io. Объект потока, производный от IOBase, который будет принят без одновременного чтения всего тела запроса?

Подробнее здесь: https://stackoverflow.com/questions/793 ... or-similar