1

複数のブロブを同時に更新しようとすると、Task.WaitAll を使用してパフォーマンスを改善しようとしていました

using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Blob;
using Microsoft.WindowsAzure.Storage.RetryPolicies;
using System.Threading.Tasks;

namespace ConsoleApp1
{
    class Program
    {
        static void Main(string[] args)
        {
            CloudStorageAccount storageAccount = CloudStorageAccount.Parse("UseDevelopmentStorage=true;DevelopmentStorageProxyUri=http://localhost.fiddler;");
            CloudBlobClient blobClient = storageAccount.CreateCloudBlobClient();

            CloudBlobContainer container = blobClient.GetContainerReference("mycontainer");

            // Create the container if it doesn't already exist.
            container.CreateIfNotExists();

            CloudBlockBlob blockBlob1 = container.GetBlockBlobReference("myblob1");
            CloudBlockBlob blockBlob2 = container.GetBlockBlobReference("myblob2");
            CloudBlockBlob blockBlob3 = container.GetBlockBlobReference("myblob3");
            CloudBlockBlob blockBlob4 = container.GetBlockBlobReference("myblob4");
            CloudBlockBlob blockBlob5 = container.GetBlockBlobReference("myblob5");

            blobClient.DefaultRequestOptions = new BlobRequestOptions()
            {
                RetryPolicy = new NoRetry()
            };
            var str = "To list the blobs in a container, first get a container reference. You can then use the container's ListBlobs method to retrieve the blobs and/or directories within it. To access the rich set of properties and methods for a returned IListBlobItem, you must cast it to a CloudBlockBlob, CloudPageBlob, or CloudBlobDirectory object. If the type is ";

            Task.WaitAll(UploadBlobAsync(blockBlob1, str), UploadBlobAsync(blockBlob2, str),  UploadBlobAsync(blockBlob3, str), UploadBlobAsync(blockBlob4, str), UploadBlobAsync(blockBlob5, str));            
        }


        private static async Task UploadBlobAsync(CloudBlockBlob blob, string content)
        {
            await blob.UploadTextAsync(content);
        }
    }
}

次に、シミュレーターが 500 例外をスローすることがあることがわかりました。

HTTP/1.1 500 Server encountered an internal error. Please try again after some time.
Content-Length: 253
Content-Type: application/xml
Server: Windows-Azure-Blob/1.0 Microsoft-HTTPAPI/2.0
x-ms-request-id: 53a5fe0c-496a-4925-b87d-48cb59a7df37
x-ms-version: 2016-05-31
Date: Fri, 26 May 2017 16:46:28 GMT

<?xml version="1.0" encoding="utf-8"?><Error><Code>InternalError</Code><Message>Server encountered an internal error. Please try again after some time.
RequestId:53a5fe0c-496a-4925-b87d-48cb59a7df37
Time:2017-05-26T16:46:28.9534026Z</Message></Error>

エントリ ロジックを有効にすると、成功しますが、思ったよりもはるかに時間がかかります。フィドラーを介して、ブロブ操作の 1 つが常に最初に失敗し、再試行で成功することがわかります。

毎回失敗するわけではありませんが、500 で失敗する可能性が非常に高くなります。

これは、エミュレータ 5.0 およびクライアント ライブラリ 8.1.3 でテストされています。このコードは、azure クラウド ストレージではテストしていません。

4

1 に答える 1