CodeSample小助手 2019-12-30
断点续传下载的流程如下:
您可以通过oss2.resumable_download方法断点续传下载,该方法中包含以下参数:
参数 | 描述 | 是否必需 | 默认值 |
---|---|---|---|
bucket | 存储空间名称。 | 是 | 无 |
key | OSS文件名称。 | 是 | 无 |
filename | 本地文件。OSS文件将下载到该文件中。 | 是 | 无 |
store | 记录本地分片下载结果的文件。下载过程中,断点信息会保存在此文件中,如果下载中断了,再次下载时会根据文件中记录的点继续下载。 | 否 | HOME目录下建立的.py-oss-download目录。 |
multipart_threshold | 文件长度大于该值时,则使用断点续传下载。 | 否 | 10MB |
part_size | 分片大小。 | 否 | 自动计算 |
progress_callback | 下载进度回调函数。 | 否 | 无 |
num_threads | 并发下载的线程数。 | 否 | 1 |
以下代码用于断点续传下载:
# -*- coding: utf-8 -*-
import oss2
# 阿里云主账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维,请登录 https://ram.console.aliyun.com 创建RAM账号。
auth = oss2.Auth('<yourAccessKeyId>', '<yourAccessKeySecret>')
# Endpoint以杭州为例,其它Region请按实际情况填写。
bucket = oss2.Bucket(auth, 'http://oss-cn-hangzhou.aliyuncs.com', '<yourBucketName>')
oss2.resumable_download(bucket, '<yourObjectName>', '<yourLocalFile>')
Python SDK 2.1.0以上版本支持设置可选参数进行断点续传下载,代码如下:
# -*- coding: utf-8 -*-
import oss2
# 阿里云主账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维,请登录 https://ram.console.aliyun.com 创建RAM账号。
auth = oss2.Auth('<yourAccessKeyId>', '<yourAccessKeySecret>')
# Endpoint以杭州为例,其它Region请按实际情况填写。
bucket = oss2.Bucket(auth, 'http://oss-cn-hangzhou.aliyuncs.com', '<yourBucketName>')
# 请将oss2.defaults.connection_pool_size设成大于或等于线程数,并将part_size参数设成大于或等于oss2.defaults.multiget_part_size。
oss2.resumable_download(bucket, '<yourObjectName>', '<yourLocalFile>',
store=oss2.ResumableDownloadStore(root='/tmp'),
multiget_threshold=20*1024*1024,
part_size=10*1024*1024,
num_threads=3)