1

我已按照以下帖子将块上传到 blob

如何跟踪异步文件上传到 Azure 存储的进度

但这在 windows 商店应用程序或 windows 8.1 应用程序中不起作用，因为 win 8.1 应用程序中不支持 MemoryStream。

无论如何，我已经修改了上面线程中的代码并提出了类似以下的内容

        CloudBlobClient myBlobClient = storageAccount.CreateCloudBlobClient();
        var filePicker = new FileOpenPicker();

        filePicker.FileTypeFilter.Add("*");
        var file = await filePicker.PickSingleFileAsync();
        string output = string.Empty;

            var fileName = file.Name;


        myBlobClient.SingleBlobUploadThresholdInBytes = 1024 * 1024;
        CloudBlobContainer container = myBlobClient.GetContainerReference("files");
        //container.CreateIfNotExists();
        CloudBlockBlob myBlob = container.GetBlockBlobReference(fileName);
        var blockSize = 256 * 1024;
        myBlob.StreamWriteSizeInBytes = blockSize;

        var fileProp = await file.GetBasicPropertiesAsync();
        var bytesToUpload = fileProp.Size;
        var fileSize = bytesToUpload;



        if (bytesToUpload < Convert.ToUInt64(blockSize))
        {
            CancellationToken ca = new CancellationToken();
            var ado = myBlob.UploadFromFileAsync(file).AsTask();
            await
                            //Console.WriteLine(ado.Status); //Does Not Help Much
                            ado.ContinueWith(t =>
                            {
                                //Console.WriteLine("Status = " + t.Status);
                                //Console.WriteLine("It is over"); //this is working OK
                            });
        }
        else
        {
            List<string> blockIds = new List<string>();
            int index = 1;
            ulong startPosition = 0;
            ulong bytesUploaded = 0;
            do
            {
                var bytesToRead = Math.Min(Convert.ToUInt64(blockSize), bytesToUpload);
                var blobContents = new byte[bytesToRead];




                using (Stream fs = await file.OpenStreamForWriteAsync())
                {
                    fs.Position = Convert.ToInt64(startPosition);
                    fs.Read(blobContents, 0, (int)bytesToRead);
                    //var iStream = fs.AsInputStream();



                    ManualResetEvent mre = new ManualResetEvent(false);
                    var blockId = Convert.ToBase64String(Encoding.UTF8.GetBytes(index.ToString("d6")));
                    //Console.WriteLine("Now uploading block # " + index.ToString("d6"));
                    blockIds.Add(blockId);
                    var ado = myBlob.PutBlockAsync(blockId, fs.AsRandomAccessStream(), null).AsTask();
                    await ado.ContinueWith(t =>
                              {
                                  bytesUploaded += bytesToRead;
                                  bytesToUpload -= bytesToRead;
                                  startPosition += bytesToRead;
                                  index++;
                                  double percentComplete = (double)bytesUploaded / (double)fileSize;
                                  output += (percentComplete * 100).ToString() + ",";
                        // AppModel.TasksFormObj.SetProgress(percentComplete * 100);
                        // Console.WriteLine("Percent complete = " + percentComplete.ToString("P"));
                        mre.Set();
                              });

                mre.WaitOne();
                }
            }
            while (bytesToUpload > 0);
            //Console.WriteLine("Now committing block list");
            var pbl = myBlob.PutBlockListAsync(blockIds).AsTask();
             pbl.ContinueWith(t =>
            {
                //Console.WriteLine("Blob uploaded completely.");
            });
        }
    }

上面的代码将文件保存在 blob 中，进度也很好，但 blob 中保存的文件始终为 0 字节。调试后发现 var ado = myBlob.PutBlockAsync(blockId, fs.AsRandomAccessStream(), null).AsTask(); 后抛出错误 最后一个 blob 传输为

<?xml version="1.0" encoding="utf-16"?>
<!--An exception has occurred. For more information please deserialize this message via RequestResult.TranslateFromExceptionMessage.-->
<RequestResult>
  <HTTPStatusCode>400</HTTPStatusCode>
  <HttpStatusMessage>The value for one of the HTTP headers is not in the correct format.</HttpStatusMessage>
  <TargetLocation>Primary</TargetLocation>
  <ServiceRequestID>13633308-0001-0031-060b-7249ea000000</ServiceRequestID>
  <ContentMd5 />
  <Etag />
  <RequestDate>Sun, 28 Feb 2016 10:31:44 GMT</RequestDate>
  <StartTime>Sun, 28 Feb 2016 09:31:43 GMT</StartTime>
  <EndTime>Sun, 28 Feb 2016 09:31:44 GMT</EndTime>
  <Error>
    <Code>InvalidHeaderValue</Code>
    <Message>The value for one of the HTTP headers is not in the correct format.
RequestId:13633308-0001-0031-060b-7249ea000000
Time:2016-02-28T09:34:18.3545085Z</Message>
    <HeaderName>Content-Length</HeaderName>
    <HeaderValue>0</HeaderValue>
  </Error>
  <ExceptionInfo>
    <Type>StorageException</Type>
    <HResult>-2147467259</HResult>
    <Message>The value for one of the HTTP headers is not in the correct format.</Message>
    <Source>Microsoft.WindowsAzure.Storage</Source>
    <StackTrace>   at Microsoft.WindowsAzure.Storage.Core.Executor.Executor.&lt;ExecuteAsyncInternal&gt;d__c`1.MoveNext()</StackTrace>
  </ExceptionInfo>
</RequestResult>

然后在最后一次提交时，在 myBlob.PutBlockListAsync(blockIds) as The specified block list is invalid之后抛出错误

因此，请有人帮助我找出我做错了什么，或者有什么可能的解决方案让它 100% 工作。

4

1 回答 1

0

像这样使用AsTask()。

 CancellationTokenSource _cts;

 _cts = new CancellationTokenSource();//<--In Constructor 

 var progress = new Progress<double>(TranscodeProgress); 
 await var ado = myBlob.UploadFromFileAsync(file).AsTask(_cts.Token, progress);
于 2016-03-01T08:03:17.937 回答