[Azure 存储服务].NET7.0 示例代码之上传大文件到Azure Storage Blob

科技资讯 投稿 8100 0 评论

[Azure 存储服务].NET7.0 示例代码之上传大文件到Azure Storage Blob

问题描述

 

问题解答

如果使用SDK,通过自定义代码上传的时,需要主要大文件上传时候需要考虑的问题。 Azure Blob支持两种上传方式:整体上传和分块上传

    整块上传:当上传到块 Blob 的文件小于等于 SingleBlobUploadThresholdInBytes 属性(客户端可以通过设置该属性设置单个 Blob 上传的最大值,范围介于 1MB 和 256MB 之间)的值时,则可以采用整体上传的方式。

  • 分块上传:当上传的块 Blob 的文件大于 SingleBlobUploadThresholdInBytes 属性的值时,存储客户端会根据 StreamWriteSizeInBytes (客户端可以通过设置该属性设置单个分块 Blob 的大小,范围介于 16KB 和 100MB 之间 的值将文件分解成块, 采用分块上传的方式上传文件。

如下示例,就是使用.NET7.0创建的示例代码:

dotnet new console --framework net7.0

2)添加 Microsoft.WindowsAzure.Storage 引用

dotnet add package WindowsAzure.Storage --version 9.3.3

4)修改 Program.cs 代码

// See https://aka.ms/new-console-template for more information using Microsoft.Azure; using Microsoft.WindowsAzure.Storage; using Microsoft.WindowsAzure.Storage.Blob; using Microsoft.WindowsAzure.Storage.RetryPolicies; Console.WriteLine("Hello, World!"; TimeSpan backOffPeriod = TimeSpan.FromSeconds(2; int retryCount = 1; //设置请求选项 BlobRequestOptions requestoptions = new BlobRequestOptions( { SingleBlobUploadThresholdInBytes = 1024 * 1024 * 10, //10MB ParallelOperationThreadCount = 12, RetryPolicy = new ExponentialRetry(backOffPeriod, retryCount, }; //String storageConnectionString = System.Environment.GetEnvironmentVariable("StorageConnectionString", EnvironmentVariableTarget.User; //Console.WriteLine("String account string : "+storageConnectionString; String storageConnectionString ="xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"; CloudStorageAccount account = CloudStorageAccount.Parse(storageConnectionString; CloudBlobClient blobclient = account.CreateCloudBlobClient(; //设置客户端默认请求选项 blobclient.DefaultRequestOptions = requestoptions; CloudBlobContainer blobcontainer = blobclient.GetContainerReference("uploadfiles-123"; await blobcontainer.CreateIfNotExistsAsync(; //文件路径,文件大小 117MB string sourcePath = @"C:\WorkSpace\ETW\1.20211017.060119_000001.etl"; CloudBlockBlob blockblob = blobcontainer.GetBlockBlobReference("bigfiles"; //设置单个块 Blob 的大小(分块方式) blockblob.StreamWriteSizeInBytes = 1024 * 1024 * 5; try { Console.WriteLine("uploading"; //使用 Stopwatch 查看上传时间 var timer = System.Diagnostics.Stopwatch.StartNew(; using (var filestream = System.IO.File.OpenRead(sourcePath { await blockblob.UploadFromStreamAsync(filestream; } timer.Stop(; Console.WriteLine(timer.ElapsedMilliseconds; Console.WriteLine("Upload Successful, Time:" + timer.ElapsedMilliseconds; } catch (Exception e { Console.WriteLine(e.Message; }

5 代码完成。如果在Azure存储账号中开启了诊断日志,当上传大文件后,就可以通过日志分析出,以上代码执行了多次Upload操作以完成大文件的上传!

 

参考资料

上传大文件到 Azure 存储块 Blob:https://docs.azure.cn/zh-cn/articles/azure-operations-guide/storage/aog-storage-blob-howto-upload-big-file-to-storage

Tutorial: Create a .NET console application using Visual Studio Code : https://learn.microsoft.com/en-us/dotnet/core/tutorials/with-visual-studio-code?pivots=dotnet-7-0

编程笔记 » [Azure 存储服务].NET7.0 示例代码之上传大文件到Azure Storage Blob

赞同 (38) or 分享 (0)
游客 发表我的评论   换个身份
取消评论

表情
(0)个小伙伴在吐槽