将 ResponseStream 上传到 Blob 存储

Question

不幸的是，我几乎陷入了以下情况：

我正在使用 .NET Core 3.1 并通过 DI 使用 HttpClient（类型化客户端）从 url 获取数据。此数据是一个 csv 文件，应上传到 Azure Blob 存储。在我尝试将其上传到 Blob 存储的地方，它似乎失败了，并出现以下异常：

 System.Net.Http: The operation was canceled. System.Net.Http: Error while copying content to a stream. 
 System.Net.Sockets: Unable to read data from the transport connection: The I/O operation has been aborted because of either a thread exit or an application request.. 
 The I/O operation has been aborted because of either a thread exit or an application request.

我目前不知道为什么上传不起作用。来自其他流的其他上传似乎没有任何错误。你们有谁知道我的线索吗？

我的课

public class Web<T> where T : BlobStorageContext
{

    private HttpClient _client { get; }
    private ILogger<Web> _logger;
    private Csv<T> _csv { get; }

    public Web(HttpClient client, Csv<T> csv, ILogger<Web> logger)
    {
        _client = client;
        _logger = logger;

        _csv = csv;
    }

    public async Task AccessWebFileAndSaveToAzureAsync()
    {
        ...

        var request = new HttpRequestMessage(HttpMethod.Get,
            url);
        
        using (var response = await _client.SendAsync(request))
        {
           
            await using (var str = await response.Content.ReadAsStreamAsync())
            {
                await _csv.WriteFileToAzureAsync(str);
            }
        }
    }
}


public class Csv<T> where T : BlobStorageContext
{
    private BlobServiceClient _blobServiceClient { get; set; }
    private ILogger<Csv<T>> _logger { get; set; }

    public Csv(IOptions<BlobStorageConfiguration<T>> configuration, ILogger<Csv<T>> logger)
    {
        _blobServiceClient = new BlobServiceClient(configuration.Value.ConnectionString());
        _logger = logger;
    }

    public async Task WriteFileToAzureAsync(Stream str)
    {
      
        var container = _blobServiceClient.GetBlobContainerClient("container);
        var blob = container.GetBlobClient(blobPath);
        await blob.UploadAsync(str, true);
    }
}

Answer 1

复制连接字符串并赋值给upload_ToBlob()方法中的storageAccount_connectionString变量

storageAccount_connectionString = "your Azure storage account connection string"  

以下语句用于为存储帐户、Blob 客户端和 Blob 容器创建对象。

CloudStorageAccount mycloudStorageAccount = CloudStorageAccount.Parse(storageAccount_connectionString);  
CloudBlobClient blobClient = mycloudStorageAccount.CreateCloudBlobClient(); 
CloudBlobContainer container = blobClient.GetContainerReference(azure_ContainerName);   

此代码用于检查指定容器是否存在于存储帐户中。

如果存在，应用程序将使用现有容器。否则，它将在存储帐户内创建一个具有指定名称的容器。

if (container.CreateIfNotExists())
{      
    container.SetPermissionsAsync(new    
    BlobContainerPermissions    
   {    
       PublicAccess =BlobContainerPublicAccessType.Blob    
   });
} 

以下语句用于使用带扩展名的文件名创建块 blob 对象

CloudBlockBlob cloudBlockBlob = container.GetBlockBlobReference(filename_withExtension);  

cloudBlockBlob.UploadFromStreamAsync(file) 语句用于将文件上传到 blob 存储。