上传大文件 Azure Blob .net SDK v12 问题

Question

我正在尝试使用 .net SDK V12 将大文件存储到 Azure Blob。这个程序可以上传小文件，没有异常，但是大文件抛出异常。你有解决这个问题的办法吗？

BlobClient blobClient = containerClient.GetBlobClient(uploadFileName);

using (FileStream uploadFileStream = File.OpenRead(localFilePath))
{
    await blobClient.UploadAsync(uploadFileStream, true);
    var meta = new Dictionary<string, string>();
    meta["LastWriteTime"] = new FileInfo(localFilePath).LastWriteTime.ToString("yyyy/MM/dd HH:mm:ss");
    meta["CreationTime"] = new FileInfo(localFilePath).CreationTime.ToString("yyyy/MM/dd HH:mm:ss");
    await blobClient.SetMetadataAsync(meta);
}

我想知道的不是.NET SDK V11的解决方案，而是V12。

这个异常如下，文件大小为91.6MB

System.AggregateException: Retry failed after 6 tries. (The operation was canceled.) (The operation was canceled.) (The operation was canceled.) (The operation was canceled.) (The operation was canceled.) (The operation was canceled.)
 ---> System.Threading.Tasks.TaskCanceledException: The operation was canceled.
 ---> System.Net.Http.HttpRequestException: Error while copying content to a stream.
 ---> System.IO.IOException: Unable to read data from the transport connection: 
 ---> System.Net.Sockets.SocketException (995): 
   --- End of inner exception stack trace ---
   at System.Net.Sockets.Socket.AwaitableSocketAsyncEventArgs.ThrowException(SocketError error, CancellationToken cancellationToken)
   at System.Net.Security.SslStream.<WriteSingleChunk>g__CompleteAsync|210_1[TWriteAdapter](ValueTask writeTask, Byte[] bufferToReturn)
   at System.Net.Security.SslStream.WriteAsyncChunked[TWriteAdapter](TWriteAdapter writeAdapter, ReadOnlyMemory`1 buffer)
   at System.Net.Security.SslStream.WriteAsyncInternal[TWriteAdapter](TWriteAdapter writeAdapter, ReadOnlyMemory`1 buffer)
   at System.Net.Http.HttpConnection.WriteAsync(ReadOnlyMemory`1 source)
   at System.IO.Stream.CopyToAsyncInternal(Stream destination, Int32 bufferSize, CancellationToken cancellationToken)
   at Azure.Core.RequestContent.StreamContent.WriteToAsync(Stream stream, CancellationToken cancellation)
   at Azure.Core.Pipeline.HttpClientTransport.PipelineRequest.PipelineContentAdapter.SerializeToStreamAsync(Stream stream, TransportContext context)
   at System.Net.Http.HttpContent.CopyToAsyncCore(ValueTask copyTask)

Answer 1

我在使用StorageConnectionString 时遇到了同样的错误，如下所示：

BlobServiceClient blobServiceClient = new BlobServiceClient(StorageConnectionString);
BlobContainerClient container = blobServiceClient.GetBlobContainerClient(BlobContainerName);
BlobClient blob = container.GetBlobClient(BlobName);

// Open the file and upload its data
using (FileStream file = File.OpenRead(path))
{
    await blob.UploadAsync(file);
}

我改用StorageSharedKeyCredential，它成功了。

string accountName = "";
string accountKey = "";
Uri serviceUri = new Uri("https://xxx.blob.core.windows.net/");

// Create a SharedKeyCredential that we can use to authenticate
StorageSharedKeyCredential credential = new StorageSharedKeyCredential(accountName, accountKey);

// Create a client that can authenticate with a connection string
BlobServiceClient blobServiceClient = new BlobServiceClient(serviceUri, credential);

// BlobServiceClient blobServiceClient = new BlobServiceClient(StorageConnectionString);
BlobContainerClient container = blobServiceClient.GetBlobContainerClient(BlobContainerName);
BlobClient blob = container.GetBlobClient(BlobName);

// Open the file and upload its data
using (FileStream file = File.OpenRead(path))
{
    await blob.UploadAsync(file);
}