如何使用 ListBlobsSegmentedAsync 从 Azure BLOB

Question

在尝试访问 Azure blob 文件夹的所有文件时，获取示例代码container.ListBlobs();但它看起来像旧的。旧代码： container.ListBlobs();新代码尝试： container.ListBlobsSegmentedAsync(continuationToken);我正在尝试使用以下代码：container.ListBlobsSegmentedAsync(continuationToken);文件夹是这样的：Container/F1/file.jsonContainer/F1/F2/file.jsonContainer/F2/file.json寻找更新版本以从 Azure 文件夹中获取所有文件。任何示例代码都会有所帮助，谢谢！

Answer 1

这是答案的代码：

private async Task<List<IListBlobItem>> ListBlobsAsync(CloudBlobContainer container)

{

    BlobContinuationToken continuationToken = null;

    List<IListBlobItem> results = new List<IListBlobItem>();

    do

    {

       bool useFlatBlobListing = true;

       BlobListingDetails blobListingDetails = BlobListingDetails.None;

       int maxBlobsPerRequest = 500;

       var response = await container.ListBlobsSegmentedAsync(BOAppSettings.ConfigServiceEnvironment, useFlatBlobListing, blobListingDetails, maxBlobsPerRequest, continuationToken, null, null);

            continuationToken = response.ContinuationToken;

            results.AddRange(response.Results);

        }

     while (continuationToken != null);

     return results;

}

然后你可以返回如下值：

IEnumerable<IListBlobItem> listBlobs = await this.ListBlobsAsync(container);

foreach(CloudBlockBlob cloudBlockBlob in listBlobs)

  {

     BOBlobFilesViewModel boBlobFilesViewModel = new BOBlobFilesViewModel

     {

          CacheKey = cloudBlockBlob.Name,

          Name = cloudBlockBlob.Name

      };

      listBOBlobFilesViewModel.Add(boBlobFilesViewModel);

   }

//return listBOBlobFilesViewModel;

Answer 2

C#代码：

   //connection string

    string storageAccount_connectionString = "**NOTE: CONNECTION STRING**";

    // Retrieve storage account from connection string.

    CloudStorageAccount storageAccount = CloudStorageAccount.Parse(storageAccount_connectionString);

    // Create the blob client.

    CloudBlobClient blobClient = storageAccount.CreateCloudBlobClient();

    // Retrieve reference to a previously created container.

    CloudBlobContainer container = blobClient.GetContainerReference("**NOTE:NAME OF CONTAINER**");

    //The specified container does not exist

    try

    {

        //root directory

        CloudBlobDirectory dira = container.GetDirectoryReference(string.Empty);

        //true for all sub directories else false 

        var rootDirFolders = dira.ListBlobsSegmentedAsync(true, BlobListingDetails.Metadata, null, null, null, null).Result;

        foreach (var blob in rootDirFolders.Results)

        {

             Console.WriteLine("Blob", blob);

        }

    }

    catch (Exception e)

    {

        //  Block of code to handle errors

        Console.WriteLine("Error", e);

    }

Answer 3

该方法CloudBlobClient.ListBlobsSegmentedAsync用于返回包含容器中 blob 项集合的结果段。

要列出所有 blob，我们可以使用ListBlobs方法，

这是一个演示供您参考：

    public static List<V> ListAllBlobs<T, V>(Expression<Func<T, V>> expression, string containerName,string prefix)

    {

        CloudStorageAccount storageAccount = CloudStorageAccount.Parse("YourConnectionString;");

        CloudBlobClient cloudBlobClient = storageAccount.CreateCloudBlobClient();

        CloudBlobContainer container = cloudBlobClient.GetContainerReference(containerName);

        container.CreateIfNotExists();

        var list = container.ListBlobs(prefix: prefix,useFlatBlobListing: true);

        List<V> data = list.OfType<T>().Select(expression.Compile()).ToList();

        return data;

    }

用法和截图：

列出一个文件夹下的所有 blob 名称：

列出一个文件夹下所有 blob 的 URL：