代码之家 › 专栏 › 技术社区 › Yanayaya

如何使用ID参数作为容器将多个文件上载到Azure Blob存储区?

azure-storage-blobs kendo-ui model-view-controller azure

Yanayaya · 技术社区 · 6 年前

我在Azure上创建了一个存储帐户,用于将文件上载到。我正在使用kenoui异步上传小部件,它允许多个文件上传。我想做的是让系统基于传入创建一个容器 Id 参数,如果它不存在。

但是,我正在努力处理实际的上传部分,我不知道如何将可枚举文件传递到存储帐户。这是迄今为止我的代码:

public ActionResult Async_Save(IEnumerable<HttpPostedFileBase> files, string id)
    {
        //Connect to Azure
        CloudStorageAccount storageAccount = CloudStorageAccount.Parse(CloudConfigurationManager.GetSetting("my_AzureStorageConnectionString"));

        //Create Blob Client
        CloudBlobClient blobClient = storageAccount.CreateCloudBlobClient();

        //Retrieve a reference to a container
        CloudBlobContainer blobContainer = blobClient.GetContainerReference("vehicle_" + id);

        try
        {
            // Create the container if it doesn't already exist
            blobContainer.CreateIfNotExists();
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.Message);
            Console.WriteLine(ex.InnerException);

        }
        foreach (var file in files)
        {
            //This doesn't seem right to me and it's where I'm struggling
            var fileName = Path.GetFileName(file.FileName);
            var physicalPath = Path.Combine(blobContainer, fileName);
            file.SaveAs(physicalPath);
        }

        // Return an empty string to signify success
        return Content("");
    }

我尝试做的是创建一个连接到我的Azure存储帐户的方法,并且:

检查是否存在与传入的参数,如果不存在,则创建它。
将文件上载到现有或新创建的目录,并为其提供ID前缀,即“_uu”。

2 回复 | 直到 6 年前

Lee Liu 6 年前

正如GauravMantri上面所说,我们需要使用AzureStorageSDK。

为了获得更好的性能,我们可以执行以下操作:

Parallel.ForEach(files, file =>

{

    CloudBlockBlob blob = blobContainer.GetBlockBlobReference(file.FileName); 

    blob.UploadFromStream(file.InputStream);

    file.InputStream.Close();


});

您的代码将更好,如下所示:

public ActionResult Async_Save(List<HttpPostedFileBase> files, string id)

{

// Connect to Azure

CloudStorageAccount storageAccount = CloudStorageAccount.Parse(CloudConfigurationManager.GetSetting("my_AzureStorageConnectionString"));

try

{

   //Create Blob Client

   CloudBlobClient blobClient = storageAccount.CreateCloudBlobClient();

   //Retrieve a reference to a container

   CloudBlobContainer blobContainer = blobClient.GetContainerReference("vehicle_" + id);

   // Create the container if it doesn't already exist

   blobContainer.CreateIfNotExists();

   Parallel.ForEach(files, file =>

   {

       CloudBlockBlob blob = blobContainer.GetBlockBlobReference(file.FileName);

       blob.UploadFromStream(file.InputStream);

       file.InputStream.Close();

   });

}

catch (Exception ex)

{

    Console.WriteLine(ex.Message);

    Console.WriteLine(ex.InnerException);

} 

// Return an empty string to signify success

    return new ContentResult();

}

有关如何使用Azure存储SDK的详细信息,我们可以参考:

Get Quick Start with Storage SDK

Gaurav Mantri 6 年前

要在Azure存储中上载Blob,您需要使用Azure存储SDK。

请替换以下代码:

    foreach (var file in files)
    {
        //This doesn't seem right to me and it's where I'm struggling
        var fileName = Path.GetFileName(file.FileName);
        var physicalPath = Path.Combine(blobContainer, fileName);
        file.SaveAs(physicalPath);
    }

比如:

  foreach (var file in files)
  {
      var blob = blobContainer.GetBlockBlobReference(file.FileName);
      using (var s = file.InputStream)
      {
          blob.UploadFromStream(s);
      }
  }