全部文档
当前文档
最近更新时间：2025-06-11 14:15:56
以下代码用于异步上传文件：
from ks3.connection import Connection
# 金山云主账号AccessKey拥有所有API的访问权限，风险很高。
# 强烈建议您创建并使用子账号账号进行API访问或日常运维，请登录https://uc.console.ksyun.com/pro/iam/#/user/list创建子账号。
# 通过指定host(Endpoint)，您可以在指定的地域创建新的存储空间。
c = Connection('<YOUR_ACCESS_KEY>', '<YOUR_SECRET_KEY>', host='<YOUR_REGION_ENDPOINT>')
# 获取存储空间实例
b = c.get_bucket('<YOUR_BUCKET_NAME>')
# 异步上传文件，以asyncio为例
import asyncio
async def upload_async(filenames, headers=None):
tasks = []
for index, filename in enumerate(filenames):
k = b.new_key(filename)
task = k.upload_file_async('<yourSourceFilePath>')
tasks.append(task)
results = await asyncio.gather(*tasks, return_exceptions=True)
# 打印某一个任务的requestid
print('results[0] requestid:', results[0].response_metadata.request_id)
return results
asyncio.run(upload_async(['<yourFileName1>', '<yourFileName2>']))纯净模式