如何使用 gcloud-aio-storage 上传和获取自定义元数据？

Question

我正在使用 gcloud-aio-storage 来缓存文件。有一个选项可以在上传功能中添加元数据字典

async def upload(self, bucket: str, object_name: str, file_data: Any,
                 *, content_type: Optional[str] = None,
                 parameters: Optional[Dict[str, str]] = None,
                 headers: Optional[Dict[str, str]] = None,
                 metadata: Optional[Dict[str, Any]])

还有下载元数据的功能 async def download_metadata(self, bucket: str, object_name: str,

应该能够添加元数据并在以后使用上述功能检索它。我做错了什么？

Answer 1

据我了解，您想上传一个带有自定义元数据的对象，然后在需要时检索它。

如果您像这样将键值对传递给 upload()，则不会添加自定义元数据：

metadata_dict = {
  "foo" : "bar",
  "color": "green"
}

原因是库正在查找字典中的 metadata 键。请参阅代码片段 here. I reviewed the library and in this case, the request body 变为：

{"foo": "bar", "color": "green", "name": "filename.txt"}

正确的必须是：

{"metadata": {"foo": "bar", "color": "green"}, "name": "filename.txt"}

解决方案是像这样配置字典：

meta_dict = {
    "metadata":{
      "foo" : "bar",
      "color": "green"
    }
}

完整代码示例（感谢）：

import asyncio
import aiohttp
# pip install aiofile
from aiofile import AIOFile
# pip install gcloud-aio-storage
from gcloud.aio.storage import Storage 
import logging
import sys

BUCKET_NAME = 'BUCKET_NAME'
FILE_NAME  = 'FILE_NAME.txt'
meta_dict = {
    "metadata":{
      "foo" : "bar",
      "color": "green"
    }
}
async def async_upload_to_bucket(blob_name, file_obj, meta_dict):
    async with aiohttp.ClientSession() as session:
        storage = Storage(session=session) 
        status = await storage.upload(BUCKET_NAME, blob_name, file_obj, metadata=meta_dict)
        print(status['metadata'])
        return status['selfLink']

async def main():
    async with AIOFile(FILE_NAME, mode='r') as afp:
        f = await afp.read()
        url = await async_upload_to_bucket(FILE_NAME, f, meta_dict)
        print(url)


# Python 3.7+
asyncio.run(main()) 
print("success")

如何使用 gcloud-aio-storage 上传和获取自定义元数据？

How to upload & get custom metadata with gcloud-aio-storage?

python

google-cloud-storage

google-cloud-platform