使用任务库的 Amazon S3 异步上传
本文关键字:S3 异步 Amazon 任务 | 更新日期: 2023-09-27 18:31:16
我有一个将文件上传到 Amazon S3 的 Windows 表单。我尝试实现内置的异步方法,但似乎工作不正常,所以我认为最好的方法是实现System.Threading.Tasks。
我的实际代码如下所示:
public void UploadFileAsync(string bucketName, CloudDocument doc, bool publicRead)
{
config = new AmazonS3Config();
config.CommunicationProtocol = Protocol.HTTP;
client = Amazon.AWSClientFactory.CreateAmazonS3Client(accessKeyID, secretAccessKeyID, config);
// Load stream from file location
FileMode mode = FileMode.Open;
using (FileStream fs = new FileStream(doc.FullName, mode, FileAccess.Read))
{
// Create put object request
TransferUtilityUploadRequest objectRequest = new TransferUtilityUploadRequest();
objectRequest.InputStream = fs;
objectRequest.BucketName = bucketName;
if (publicRead) objectRequest.CannedACL = S3CannedACL.PublicRead;
objectRequest.Key = doc.KeyName + doc.FileName.Replace(' ', '_');
objectRequest.UploadProgressEvent += new EventHandler<UploadProgressArgs>(UploadProgressEvent);
transferUtility = new TransferUtility(client);
IAsyncResult asyncResult = transferUtility.BeginUpload(objectRequest, new AsyncCallback(UploadCallBack), results);
waitHandles.Add(asyncResult.AsyncWaitHandle);
// Wait till all the requests that were started are completed.
WaitHandle.WaitAll(waitHandles.ToArray());
}
client.Dispose();
}
}
private void UploadProgressEvent(object sender, UploadProgressArgs e)
{
if (UploadProgressChanged != null)
UploadProgressChanged(this, e);
}
private void UploadCallBack(IAsyncResult result)
{
Results results = result.AsyncState as Results;
try
{
// If there was an error during the put attributes operation it will be thrown as part of the EndPutAttributes method.
transferUtility.EndUpload(result);
results.Successes++;
}
catch (Exception e)
{
Console.WriteLine(e.Message);
results.Errors++;
}
}
有没有人尝试实施Await/异步任务以将异步上传到Amazon s3?
您可以在 MSDN 上找到有关将 APM 和 EAP 成员包装到 TAP 成员中的说明。
总之,您使用 Task.Factory.FromAsync
来包装Begin
/End
方法对,如下所示:
public static Task UploadAsync(this TransferUtility @this, TransferUtilityUploadRequest request)
{
return Task.Factory.FromAsync(@this.BeginUpload, @this.EndUpload, request, null);
}
然后你可以这样使用它:
var task = transferUtility.UploadAsync(objectRequest);
tasks.Add(task);
await Task.WhenAll(tasks);
您可能
还对适用于 .NET 的 AWS 开发工具包 2.0 的开发人员预览版感兴趣。TransferUtility 的异步扩展类的源代码可以在此处找到。如果您对预览版有任何反馈,请告诉我们!
谢谢!