简介
本文介绍对象存储 COS 通过 .NET(C#) SDK 实现下载对象功能的示例代码和描述。包括高级接口、简单接口两个部分。
注意事项
相关示例
功能名称 | 描述 | 示例代码 |
高级接口 | 高级接口封装了简单下载接口,支持断点下载,下载目录,但不支持流式下载。 | |
简单接口 | GET Object 接口可以实现流式下载和下载对象到本地文件,不支持断点下载功能。 |
前期准备:初始化 COS 服务实例
public class DownloadObject { private CosXml cosXml; //将服务用户设置成数据成员 // 初始化COS服务实例 private void InitCosXml() { string region = Environment.GetEnvironmentVariable("COS_REGION"); CosXmlConfig config = new CosXmlConfig.Builder() .SetRegion(region) // 设置默认的地域, COS 地域的简称请参照 https://cloud.tencent.com/document/product/436/6224 .Build(); string secretId = Environment.GetEnvironmentVariable("SECRET_ID"); // 云 API 密钥 SecretId, 获取 API 密钥请参照 https://console.cloud.tencent.com/cam/capi string secretKey = Environment.GetEnvironmentVariable("SECRET_KEY"); // 云 API 密钥 SecretKey, 获取 API 密钥请参照 https://console.cloud.tencent.com/cam/capi long durationSecond = 600; //每次请求签名有效时长,单位为秒 QCloudCredentialProvider qCloudCredentialProvider = new DefaultQCloudCredentialProvider(secretId, secretKey, durationSecond); this.cosXml = new CosXmlServer(config, qCloudCredentialProvider); } }
高级接口(推荐)
高级接口支持暂停、恢复以及取消下载请求,同时支持断点下载功能。
说明:
.NET Framework 4.0 及以下的用户,高级接口暂不可用,详见 向下兼容指南。
高级接口下载对象
public async Task TransferDownloadObject() { // 初始化 TransferConfig TransferConfig transferConfig = new TransferConfig(); // 手动设置高级下载接口的分块阈值为 20MB(默认为20MB), 从5.4.26版本开始支持! //transferConfig.DivisionForDownload = 20 * 1024 * 1024; // 手动设置高级下载接口的分块大小为 10MB(默认为5MB),设置过小的分块值可能导致频繁重试或下载速度不合预期 //transferConfig.SliceSizeForDownload = 10 * 1024 * 1024; // 初始化 TransferManager TransferManager transferManager = new TransferManager(cosXml, transferConfig); String bucket = "examplebucket-1250000000"; //存储桶,格式:BucketName-APPID String cosPath = "exampleobject"; //对象在存储桶中的位置标识符,即称对象键 string localDir = Path.GetTempPath();//本地文件夹 string localFileName = "my-local-temp-file"; //指定本地保存的文件名 // 下载对象 COSXMLDownloadTask downloadTask = new COSXMLDownloadTask(bucket, cosPath, localDir, localFileName);//开启断点续传,当本地存在未下载完成文件时,追加下载到文件末尾 //本地文件已存在部分不符合本次下载的内容,可能导致下载失败,请删除文件重试 //downloadTask.SetResumableDownload(true); // 手动设置高级下载接口的并发数 (默认为5), 从5.4.26版本开始支持! // downloadTask.SetMaxTasks(10);//设置进度打印回调函数 downloadTask.progressCallback = delegate (long completed, long total) { Console.WriteLine(String.Format("progress = {0:##.##}%", completed * 100.0 / total)); } try { COSXMLDownloadTask.DownloadTaskResult result = await transferManager.DownloadAsync(downloadTask); Console.WriteLine(result.GetResultInfo()); } catch (COSXML.CosException.CosClientException clientEx) { Console.WriteLine("CosClientException: " + clientEx); } catch (COSXML.CosException.CosServerException serverEx) { Console.WriteLine("CosServerException: " + serverEx.GetInfo()); } }public static void Main() { DownloadObject demo = new DownloadObject(); //初始化COS服务 demo.InitCosXml(); demo.TransferDownloadObject().Wait(); }
对于下载任务,可以通过以下方式暂停:
downloadTask.Pause();
暂停之后,可以通过以下方式续传:
downloadTask.Resume();
也通过以下方式取消上传:
downloadTask.Cancel();
批量下载
public void BatchDownload() { TransferConfig transferConfig = new TransferConfig(); // 初始化 TransferManager TransferManager transferManager = new TransferManager(cosXml, transferConfig); // 存储桶名称,此处填入格式必须为 bucketname-APPID, 其中 APPID 获取参考 https://console.cloud.tencent.com/developer string bucket = "examplebucket-1250000000"; string localDir = System.IO.Path.GetTempPath();//本地文件夹 for (int i = 0; i < 5; i++) { // 下载对象 string cosPath = "exampleobject" + i; //对象在存储桶中的位置标识符,即称对象键 string localFileName = "my-local-temp-file"; //指定本地保存的文件名 COSXMLDownloadTask downloadTask = new COSXMLDownloadTask(bucket, cosPath, localDir, localFileName); transferManager.DownloadAsync(downloadTask).Wait(); } }
文件夹下载
COS 中实际不存在文件夹下载的接口,此处通过“查询对象列表”和“批量下载” 两种操作,实现类似文件夹下载的操作。
public void GetObjectsFromFolder() {//需要通过组合 “指定前缀列出” 和 “遍历列出的对象key做下载” 两种操作,实现类似文件夹下载的操作 //下面的操作,把对象列出到列表里,然后异步下载列表中的对象 String nextMarker = null; List<string> downloadList = new List<string>(); string bucket = "examplebucket-1250000000"; string prefix = "folder1/"; //指定前缀 // 循环请求直到没有下一页数据 do { // 存储桶名称,此处填入格式必须为 bucketname-APPID, 其中 APPID 获取参考 https://console.cloud.tencent.com/developer GetBucketRequest listRequest = new GetBucketRequest(bucket); //获取 folder1/ 下的所有对象以及子目录 listRequest.SetPrefix(prefix); listRequest.SetMarker(nextMarker);//执行列出对象请求 GetBucketResult listResult = cosXml.GetBucket(listRequest); ListBucket info = listResult.listBucket; // 对象列表 List<ListBucket.Contents> objects = info.contentsList; // 下一页的下标 nextMarker = info.nextMarker; //对象列表 foreach (var content in objects) { downloadList.Add(content.key); Console.WriteLine("adding key:" + content.key); } } while (nextMarker != null); Console.WriteLine("download list construct done, " + downloadList.Count + " objects added");TransferConfig transferConfig = new TransferConfig(); TransferManager transferManager = new TransferManager(cosXml, transferConfig); string localDir = System.IO.Path.GetTempPath(); //本地文件夹 List<Task> taskList = new List<Task>(); for (int i = 0; i < downloadList.Count; i++) { // 遍历待下载列表,下载内容写到 filename_i 文件中 COSXMLDownloadTask downloadTask = new COSXMLDownloadTask(bucket, downloadList[i], localDir, "filename_" + i.ToString()); // 异步下载, 加入task队列 Task task = transferManager.DownloadAsync(downloadTask); taskList.Add(task); } Console.WriteLine("download tasks submitted, total " + taskList.Count + " tasks added"); //等待TaskList中所有Task结束 foreach (Task task in taskList) { task.Wait(); Console.WriteLine("download completed"); } }
单链接限速下载
public async void LimitSpeedDownload() { TransferConfig transferConfig = new TransferConfig(); // 初始化 TransferManager TransferManager transferManager = new TransferManager(cosXml, transferConfig); String bucket = "examplebucket-1250000000"; //存储桶,格式:BucketName-APPID String cosPath = "exampleobject"; //对象在存储桶中的位置标识符,即称对象键 string localDir = System.IO.Path.GetTempPath();//本地文件夹 string localFileName = "my-local-temp-file"; //指定本地保存的文件名 GetObjectRequest request = new GetObjectRequest(bucket, cosPath, localDir, localFileName); request.LimitTraffic(8 * 1000 * 1024); // 限制为1MB/s COSXMLDownloadTask downloadTask = new COSXMLDownloadTask(request); await transferManager.DownloadAsync(downloadTask); }
简单接口
下载一个 Object(文件/对象)至本地(GET Object)。
单对象简单下载
public void GetObject() { try { // 存储桶名称,此处填入格式必须为 bucketname-APPID, 其中 APPID 获取参考 https://console.cloud.tencent.com/developer string bucket = "examplebucket-1250000000"; string key = "exampleobject"; //对象键 string localDir = Path.GetTempPath();//本地文件夹 string localFileName = "my-local-temp-file"; //指定本地保存的文件名 GetObjectRequest request = new GetObjectRequest(bucket, key, localDir, localFileName); request.SetCosProgressCallback(delegate (long completed, long total) { Console.WriteLine(String.Format("progress = {0:##.##}%", completed * 100.0 / total)); }); //执行请求 GetObjectResult result = cosXml.GetObject(request); Console.WriteLine(result.GetResultInfo()); } catch (COSXML.CosException.CosClientException clientEx) { Console.WriteLine("CosClientException: " + clientEx); } catch (COSXML.CosException.CosServerException serverEx) { Console.WriteLine("CosServerException: " + serverEx.GetInfo()); } }
下载对象到内存中
public void DownloadToMemory() { try { // 存储桶名称,此处填入格式必须为 bucketname-APPID, 其中 APPID 获取参考 https://console.cloud.tencent.com/developer string bucket = "examplebucket-1250000000"; string key = "exampleobject"; //对象键 GetObjectBytesRequest request = new GetObjectBytesRequest(bucket, key); //设置进度回调 request.SetCosProgressCallback(delegate (long completed, long total) { Console.WriteLine(String.Format("progress = {0:##.##}%", completed * 100.0 / total)); }); //执行请求 GetObjectBytesResult result = cosXml.GetObject(request); //获取内容到 byte 数组中 byte[] content = result.content; //请求成功 Console.WriteLine(result.GetResultInfo()); } catch (COSXML.CosException.CosClientException clientEx) { Console.WriteLine("CosClientException: " + clientEx); } catch (COSXML.CosException.CosServerException serverEx) { Console.WriteLine("CosServerException: " + serverEx.GetInfo()); } }