将文件上传到谷歌云存储时出错

Answer 1

选项1

根据文档，upload_from_file() 支持 file-like 对象；因此，您可以使用UploadFile 的.file 属性（代表SpooledTemporaryFile 实例）。例如：

blob.upload_from_file(file.file)  

选项 2

您可以读取file 的内容并将它们传递给upload_from_string()，它支持bytes 或string 格式的data。例如：

blob.upload_from_string(file.file.read())

或者，由于您使用async def 定义了端点（请参阅this answer 以了解def 与async def）：

contents = await file.read()
blob.upload_from_string(contents)

选项 3

为了完整起见，upload_from_filename() 期望 filename 代表小路到file。因此，当您通过 file.filename（如您的评论中所述）时，会引发 No such file or directory 错误，因为这不是小路到文件。要使用该方法（作为最后的手段），您应该将 file 内容保存到 NamedTemporaryFile，它“在文件系统中有一个可见的名称”，“可用于打开文件”，并且一旦您完成了，删除它。例子：

from tempfile import NamedTemporaryFile
import os

contents = file.file.read()
temp = NamedTemporaryFile(delete=False)
try:
    with temp as f:
        f.write(contents);
    blob.upload_from_filename(temp.name)
except Exception:
    return {"message": "There was an error uploading the file"}
finally:
    #temp.close()  # the `with` statement above takes care of closing the file
    os.remove(temp.name)

注1：

如果您将一个相当大的文件上传到 Google Cloud Storage，可能需要一些时间才能完全上传，并且遇到了 timeout 错误，请考虑增加等待服务器响应的时间，通过更改timeout 值，如upload_from_file() 文档中所示，以及前面描述的所有其他方法，默认设置为timeout=60 秒。要更改它，请使用例如blob.upload_from_file(file.file, timeout=180)，或者您也可以设置timeout=None（这意味着它将等到连接关闭）。

笔记2：

由于google-cloud-storage 包中的所有上述方法都执行阻塞 I/O 操作——如源代码 here、here 和 here 中所见——如果您决定使用async def 而不是 def（请查看 this answer 以了解有关 def 与 async def 的更多详细信息），您应该在单独的线程中运行“上传文件”功能以确保主线程（协程运行的地方）不会被阻塞。您可以使用 Starlette 的 run_in_threadpool 来做到这一点，FastAPI 在内部也使用它（也请参阅 here）。例如：

await run_in_threadpool(blob.upload_from_file, file.file)

或者，您可以使用asyncio 的loop.run_in_executor，如this answer 中所述并在this sample snippet 中演示。

至于选项3，如果你需要打开一个NamedTemporaryFile并将内容写入其中，你可以使用aiofiles库来完成，如this answer的选项2所示，即使用：

async with aiofiles.tempfile.NamedTemporaryFile("wb", delete=False) as temp:
    contents = await file.read()
    await temp.write(contents)
    #...

再次，在外部线程池中运行“上传文件”功能：

await run_in_threadpool(blob.upload_from_filename, temp.name)