6

我想使用以下方法将 AWS S3 异步方法转换为任务：

using (var client = AWSClientFactory.CreateAmazonS3Client(accessKey, secretKey))
{
    var request = new PutObjectRequest();
    // ... set request properties ...

    await Task.Factory.FromAsync<PutObjectRequest, PutObjectResponse>(
        client.BeginPutObject,
        client.EndPutObject,
        request,
        null
    );
}

但是，我得到以下异常：

System.ArgumentException: The IAsyncResult object was not returned from the corresponding asynchronous method on this class.
Parameter name: asyncResult
   at System.Net.HttpWebRequest.EndGetResponse(IAsyncResult asyncResult)
   at Amazon.S3.AmazonS3Client.getResponseCallback[T](IAsyncResult result)
   at Amazon.S3.AmazonS3Client.endOperation[T](IAsyncResult result)
   at Amazon.S3.AmazonS3Client.EndPutObject(IAsyncResult asyncResult)
   at System.Threading.Tasks.TaskFactory`1.FromAsyncCoreLogic(IAsyncResult iar, Func`2 endFunction, Action`1 endAction, Task`1 promise, Boolean requiresSynchronization)

我的电话是FromAsync不正确的还是这里出了什么问题？

附言

  • .NET 框架 4.5
  • AWSSDK 版本 1.5.17.0
4

1 回答 1

4

我遇到了同样的问题。您的 FromAsync 调用是正确的。在没有 FromAsync 包装器的情况下直接调用 BeginPutObject/EndPutObject 时存在同样的问题。

同步方法 AmazonS3Client.PutObject() 具有以下主体：

IAsyncResult asyncResult;
asyncResult = invokePutObject(request, null, null, true);
return EndPutObject(asyncResult);

而 AmazonS3Client.BeginPutObject 说：

return invokePutObject(request, callback, state, false);

注意invokePutObject 的最后一个布尔参数。此参数称为“同步”。如果您使用 synchronized=true 调用它，它会起作用（通过同步执行操作）。如果您使用 synchronized=false 调用它，在并发负载下，您会收到您发布的异常。

这显然是 AWS 开发工具包中的一个错误，需要进一步调查。AWS 论坛上的这篇文章看起来很相似，但可能不是同一个问题；我对那里的上游回复不满意，因为并发同步上传确实有效。

ETA：需要 .Net 4.5 的新 AWS SDK 版本 2.0（在撰写本文时为测试版）具有本机 FooAsync 方法（插入 Begin/EndFoo）。它基于新的 System.Net.HttpClient 库而不是旧的 HttpWebRequest。它几乎可以肯定没有这个错误，但我自己还没有测试过。

于 2013-05-08T09:58:06.240 回答