并行Blob上载间歇地抛出404错误请求

Question

我的服务很简单，

public class AzureService : IAzureService
{
    private readonly CloudBlobContainer _container;
    public AzureService(ISettings settings)
    {
        var storageAccount = CloudStorageAccount.Parse(settings.BlobConnectionString);            
        var blobClient = storageAccount.CreateCloudBlobClient();
        _container = blobClient.GetContainerReference(settings.BlobContainerName);
    }

    public Task UploadBlobAsync(string fileName, Stream stream)
    {
        var blob = _container.GetBlockBlobReference(fileName);
        return blob.UploadFromStreamAsync(stream);
    }

    public Task DeleteBlobAsync(string fileName)
    {
        var blob = _container.GetBlockBlobReference(fileName);
        return blob.DeleteAsync();
    }
}

此方法从调用，

    public Task SaveAllAsync(Dictionary<string, Stream> images)
    {
        var tasks = new List<Task>();
        foreach (var image in images)
        {
            var fileName = image.Key;
            var stream = image.Value;
            var task = _azureService.UploadBlobAsync(fileName, stream);
            tasks.Add(task);
        }
        return Task.WhenAll(tasks);
    }

我的流是HttpPostedFileBase.InputStream。有时它可以工作，有时我会得到远程服务器返回错误：（400）错误请求。。如果我设置一个断点，它也会起作用。

Answer 1

你所描述的行为听起来非常像线程问题(即，如果你将代码断点，它会很好地工作，因为当时它实际上是单线程的)，导致不完整或无效的数据被发送到Azure Storage API。

您的“var image”定义在多线程环境中可能会出现意外行为(如果您使用ReSharper，它会突出显示此变量并建议更改代码，因为它可能不安全)。

请阅读这篇SO帖子，了解更多信息以及如何更好地实现您的代码。

foreach标识符和闭包

Answer 2

我有同样的问题，我试图上传20张图片在一击，单线程作品，多线程使用<代码>等待任务。WhenAll失败，显示“远程服务器返回一个错误:(400)错误请求。”

>

有关更详细的信息，请参阅Microsoft.WindowsAzure.Storage.StorageException中从Upload[xxx]异步方法抛出的请求信息。

起初，请求信息说了一些关于MD5问题的事情，错误代码为“Md5Mismatch”，买我的直觉说不然，因为单线程像一个魅力，然后..我找到了。。。DefaultRequestOptions.Parallel操作在 CloudBlobClient 对象和问题上的线程计数。

BlobRequest选项成员MSDN

< br >

    private CloudBlobContainer ConnectToImageContainer()
    {
        var credentials = new StorageCredentials(AccountName, ImagesContainerKey);
        var account = new CloudStorageAccount(credentials, useHttps: true);
        var client = account.CreateCloudBlobClient();
        client.DefaultRequestOptions.ParallelOperationThreadCount = 64; // max value
        client.DefaultRequestOptions.SingleBlobUploadThresholdInBytes = 67108864; // max value
        var container = client.GetContainerReference(ImagesContainerName);
        return container;
    }