标准接口

using System;
using System.Collections.Generic;
using System.IO;
using System.Threading.Tasks;
using Amazon.Runtime;
using Amazon.S3;
using Amazon.S3.Model;

namespace DotNetSDK.ObjectOperation
{
    public class UploadPartExample
    {
        public static async Task UploadPart()
        {
            var accessKey = "YOUR_ACCESS_KEY";
            var secretKey = "YOUR_SECRET_KEY";
            var endpoint = "YOUR_ENDPOINT";
            var bucketName = "EXAMPLE_BUCKET";
            var key = "EXAMPLE_KEY";
            var filePath = "LOCAL_FILE_PATH";
            try
            {
                var credentials = new BasicAWSCredentials(accessKey, secretKey);
                var conf = new AmazonS3Config
                {
                    ServiceURL = endpoint
                };
                var s3Client = new AmazonS3Client(credentials, conf);
                //1. 发起一个分段上传操作请求，获取upload id
                var initiateMultipartUploadRequest = new InitiateMultipartUploadRequest()
                {
                    BucketName = bucketName,
                    Key = key
                };
                var initiateMultipartUploadResponse = await s3Client.InitiateMultipartUploadAsync(initiateMultipartUploadRequest);
                var uploadId = initiateMultipartUploadResponse.UploadId;
                Console.WriteLine("upload id: {0}", uploadId);
                // 2. 分割大文件然后分段上传
                var partSize = 1024 * 1024 * 16;
                var fileInfo = new FileInfo(filePath);
                var fileLen = fileInfo.Length;
                var partNumber = fileLen / partSize;
                if (fileLen % partSize != 0)
                {
                    partNumber++;
                }

                var etagList = new List<PartETag>();
                using (var fs = File.Open(filePath, FileMode.Open))
                {
                    for (var i = 0; i < partNumber; i++)
                    {
                        var seekBytes = (long) partSize * i;
                        fs.Seek(seekBytes, 0);
                        var size = (partSize < fileLen - seekBytes) ? partSize : (fileLen - seekBytes);
                        var uploadPartRequest = new UploadPartRequest()
                        {
                            BucketName = bucketName,
                            Key = key,
                            UploadId = uploadId,
                            InputStream = fs,
                            PartSize = size,
                            PartNumber = i + 1
                        };
                        // 分片上传
                        var uploadPartResponse = await s3Client.UploadPartAsync(uploadPartRequest);
                        etagList.Add(new PartETag(uploadPartResponse.PartNumber, uploadPartResponse.ETag));
                        Console.WriteLine("finish upload part {0}/{1}", etagList.Count, partNumber);
                    }
                }

                // 3. 完成分段上传
                var completeMultipartUploadRequest = new CompleteMultipartUploadRequest()
                {
                    BucketName = bucketName,
                    Key = key,
                    UploadId = uploadId
                };
                foreach (var etag in etagList)
                {
                    completeMultipartUploadRequest.PartETags.Add(etag);
                }

                var completeMultipartUploadResponse = await s3Client.CompleteMultipartUploadAsync(completeMultipartUploadRequest);
                if (completeMultipartUploadResponse.HttpStatusCode != System.Net.HttpStatusCode.OK)
                {
                    Console.WriteLine("fail to complete multipart upload, HttpStatusCode:{0}, ErrorCode:{1}.", (int) completeMultipartUploadResponse.HttpStatusCode,
                        completeMultipartUploadResponse.HttpStatusCode);
                }
                else
                {
                    Console.WriteLine("complete multipart upload.");
                }
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
            }
        }
    }
}