Simple WPF: S3实现MINIO大文件上传并显示上传进度

空生

最新内容优先发布于个人博客：小虎技术分享站，随后逐步搬运到博客园。
创作不易，如果觉得有用请在Github上为博主点亮一颗小星星吧！
目的

早两天写了一篇S3简单上传文件的小工具，知乎上看到了一个问题问如何实现显示MINIO上传进度，因此拓展一下这个小工具能够在上传大文件时显示进度。
完整代码托管于Github：mrchipset/simple-wpf

实现方式

• 先通过Xaml编写一个包含上传进度条的小界面。具体内容就不赘述了，可以参考这篇文章
  
• 为了得到上传进度就不能再简单地使用PutObjectRequest 进行上传需要使用S3中TransferUtility 提供的高等级API进行上传。
  
• 然后创建一个TransferUtilityUploadRequest 对象并绑定其UploadProgressEvent 事件以实现上传进度的监控
  

具体的实现代码如下：

1. private async Task<bool> UploadLargeFileAsync()
2. {
3.     var credentials = new BasicAWSCredentials(_accessKey, _secretKey);
5.     var clientConfig = new AmazonS3Config
6.     {
7.         ForcePathStyle = true,
8.         ServiceURL = _endpoint,
9.     };
11.     bool ret = true;
12.     using (var client = new AmazonS3Client(credentials, clientConfig))
13.     {
16.         try
17.         {
18.             var fileTransferUtility = new TransferUtility(client);
20.             var uploadRequest = new TransferUtilityUploadRequest
21.             {
22.                 BucketName = LargeBucket,
23.                 FilePath = UploadLargeFile,
24.                 Key = System.IO.Path.GetFileName(UploadLargeFile)
25.             };
27.             uploadRequest.UploadProgressEvent += UploadRequest_UploadProgressEvent;
29.             await fileTransferUtility.UploadAsync(uploadRequest);
30.         }
31.         catch (FileNotFoundException e)
32.         {
33.             ret = false;
34.             this.Dispatcher.Invoke(new Action(() => this.statusLargeTxtBlk.Text = e.Message));
35.         }
36.         catch (AmazonS3Exception e)
37.         {
38.             ret = false;
39.             if (e.ErrorCode != null &&
40.                 (e.ErrorCode.Equals("InvalidAccessKeyId") ||
41.             e.ErrorCode.Equals("InvalidSecurity")))
42.             {
43.                 this.Dispatcher.Invoke(new Action(() => this.statusLargeTxtBlk.Text = "Please check the provided AWS Credentials"));
44.             }
45.             else
46.             {
47.                 this.Dispatcher.Invoke(new Action(() => this.statusLargeTxtBlk.Text = $"An error occurred with the message '{e.Message}' when writing an object"));
48.             }
49.         }
50.         catch(Exception e)
51.         {
52.             this.Dispatcher.Invoke(new Action(() => this.statusLargeTxtBlk.Text = $"An error occurred with the message '{e.Message}' when writing an object"));
53.         }
54.     }
55.     return ret;
56. }
58. private void UploadRequest_UploadProgressEvent(object? sender, UploadProgressArgs e)
59. {
60.     this.Dispatcher.Invoke((Action)(() =>
61.     {
62.         this.uploadProgress.Value = e.TransferredBytes * 100 / e.TotalBytes ;
63.     }));
64. }

复制代码

值得一提的时，在上传进度的事件处理函数中，由于我们通过异步方法执行上传函数，因此我们需要使用Dispatcher 来更新数据到UI 上。
演示效果

参考连接

https://docs.aws.amazon.com/AmazonS3/latest/userguide/mpu-upload-object.html
https://www.xtigerkin.com/archives/96/

来源:https://www.cnblogs.com/mrchip/p/18297187
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！