有没有办法优化我的搜索blob程序？

问题描述：

您好

我编写此代码以根据内容搜索blob项（文本文件）。例如：如果我搜索Good，那么包含Good or good字样的文件应该出现在搜索结果中。我的代码正在运行，但我想优化它。

Hello
I write this code to search the blob items (text files) on the basis of there content. For ex : if I search for "Good", then the files that contains "Good or good" word the name of that files should appear in search result. My code is working but i want to optimize it.

class BlobSearch
    {
        public static int num = 1;
        static void Main(string[] args)
        {
            string accountName = "accountName";
            string accessKey = "accesskey";
            string azureConString = "DefaultEndpointsProtocol=https;AccountName=" + accountName + ";AccountKey=" + accessKey;
			string blob = "MyBlobContainer";
            string searchText = string.Empty;

            Console.WriteLine("Type and enter to search : ");
            searchText = Console.ReadLine();

            CloudStorageAccount account = CloudStorageAccount.Parse(azureConString);
            CloudBlobClient blobClient = account.CreateCloudBlobClient();
            CloudBlobContainer blobContainer = blobClient.GetContainerReference(blob);

            blobContainer.FetchAttributes();
            var blobItemList = blobContainer.ListBlobs();
            GetBlobList(searchText, blobContainer, blobItemList);

            Console.ReadLine();
        }

              private static async void GetBlobList(string searchText, CloudBlobContainer blobContainer, IEnumerable<IListBlobItem> blobItemList)
        {
            foreach (var item in blobItemList)
            {               
                CloudBlockBlob blockBlob = blobContainer.GetBlockBlobReference(item.Uri.ToString());
                if (blockBlob.Name.Contains(".txt"))
                {
                    await Search(searchText, blockBlob);
                }
            }
        }


        private async static Task Search(string searchText, CloudBlockBlob blockBlob)
        {
            string text = await blockBlob.DownloadTextAsync();
            if (text.ToLower().IndexOf(searchText.ToLower()) != -1)
            {
                Console.WriteLine("Result : " + num + " => " + blockBlob.Name.Substring(blockBlob.Name.LastIndexOf('/') + 1));
                num++;
            }
        }
    }

我认为

I think

blobContainer.ListBlobs();

阻止代码，因为搜索结果在加载所有blob项之前不起作用。无论如何要优化它或我的代码中的任何其他地方。

谢谢

is blocking code because search result not work until all the blob items loaded. Is there anyway to optimize it or anywhere else in my code.

Thanks

答

如果可能的话你可以继续旋转多个线程，将blob项目作为异步进程处理！

u可以使用以下代码，它肯定会提高性能：

if its possible you can go on with spinning up multiple thread , to process the blob items as async process !

u can use the following code , it will for sure improve the performance :

async public static Task ListBlobsSegmentedInFlatListing()
{
    // Retrieve storage account from connection string.
    CloudStorageAccount storageAccount = CloudStorageAccount.Parse(
        CloudConfigurationManager.GetSetting("StorageConnectionString"));

    // Create the blob client.
    CloudBlobClient blobClient = storageAccount.CreateCloudBlobClient();

    // Retrieve reference to a previously created container.
    CloudBlobContainer container = blobClient.GetContainerReference("myblobs");

    //List blobs in pages.
    Console.WriteLine("List blobs in pages:");

    //List blobs with a paging size of 10, for the purposes of the example. 
    //The first call does not include the continuation token.
    BlobResultSegment resultSegment = await container.ListBlobsSegmentedAsync(
            "", true, BlobListingDetails.All, 10, null, null, null);

    //Enumerate the result segment returned.
    int i = 0;
    if (resultSegment.Results.Count<IListBlobItem>() > 0) { Console.WriteLine("Page {0}:", ++i); }
    foreach (var blobItem in resultSegment.Results)
    {
        Console.WriteLine("\t{0}", blobItem.StorageUri.PrimaryUri);
    }
    Console.WriteLine();

    //Get the continuation token, if there are additional pages of results.
    BlobContinuationToken continuationToken = resultSegment.ContinuationToken;

    //Check whether there are more results and list them in pages of 10 while a continuation token is returned.
    while (continuationToken != null)
    {
        //This overload allows control of the page size. 
        //You can return all remaining results by passing null for the maxResults parameter, 
        //or by calling a different overload.
        resultSegment = await container.ListBlobsSegmentedAsync(
                "", true, BlobListingDetails.All, 10, continuationToken, null, null);
        if (resultSegment.Results.Count<IListBlobItem>() > 0) { Console.WriteLine("Page {0}:", ++i); }
        foreach (var blobItem in resultSegment.Results)
        {
            Console.WriteLine("\t{0}", blobItem.StorageUri.PrimaryUri);
        }
        Console.WriteLine();

        //Get the next continuation token.
        continuationToken = resultSegment.ContinuationToken;
    }
}

有没有办法优化我的搜索blob程序？

相关推荐