Как загрузить файл в куски в Google Cloud Storage с помощью Fastapi's request.stream ()? ⇐ Python

[Anonymous]

У меня есть поток данных в приложении FastAPI, где потенциально очень Http -Pul Body загружается, и мне нужно транслировать это в Google Cloud Storage. Я использую библиотеку gcloud.aio.storage для взаимодействия с Google Cloud Storage, поскольку она имеет поддержку Asyncio (она основана на AIOHTTP ). Я пытаюсь транслировать тело, так что мне не нужно было хранить все тело одновременно в памяти. /> Итак, если я позвоню ниже: < /p>

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

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
)

Это не удается с типамиррором: не поддерживается тип загрузки: "" .
Как я получу io.iobase -вызванного потока, который будет принят, без чтения всего тела запроса одновременно?>

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