Azure Search 索引内容管理

Azure Search Service REST

  在使用AzureSearch服务中portal无法对某indexer中的某个document的内容进行CRUD。感觉非常不方便，portal只提供到indexer级别的CRUD。
  在实际的项目开发过程中需要对indexer中的document内容即时CRUD。 在MSDN中翻了很久，其实AzureSearch已经提供了REST API和封装好的Net SDK供开发者使用。 在Visio studio中通过NuGet获取MicrosoftAzureSearch动态库来获取支持。
  重写了一部分内容使用起来更轻松。

public class PortalKBSearch    
{    
        /// <summary>  
        ///     The action link index client  
        /// </summary>  
        private readonly ISearchIndexClient actionLinkIndexClient;    

        /// <summary>  
        /// The allkb index client  
        /// </summary>  
        private readonly ISearchIndexClient allkbIndexClient;    

        /// <summary>  
        ///     The bot telemetry  
        /// </summary>  
        private readonly IBotTelemetry botTelemetry;    

        /// <summary>  
        ///     The _search client  
        /// </summary>  
        private readonly ISearchServiceClient searchClient;    

        /// <summary>  
        /// Initializes a new instance of the <see cref=”PortalKBSearch”/> class   
        /// Initializes a new instance of the <see cref=”PortalKBSearch”/>  
        ///     class  
        /// </summary>  
        /// <param name=”searchServiceName”>  
        /// The search Service Name  
        /// </param>  
        /// <param name=”apiKey”>  
        /// The api Key  
        /// </param>  
        /// <param name=”allKnowledgeBaseIndexName”>  
        /// The all Knowledge Base Index Name  
        /// </param>  
        /// <param name=”actionLinkIndexName”>  
        /// The action Link Index Name  
        /// </param>  
        /// <exception cref=”SystemException”>  
        /// <see langword=”throw”/> exception  
        /// </exception>  
        public PortalKBSearch(    
            string searchServiceName,    
            string apiKey,    
            string allKnowledgeBaseIndexName,    
            string actionLinkIndexName)    
        {    
            try
            {    
                botTelemetry = KnowledgeBotTelemetryCreateDefault();    

                // Create an HTTP reference to the catalog index  
                searchClient = new SearchServiceClient(searchServiceName, new SearchCredentials(apiKey));    

                allkbIndexClient = searchClientIndexesGetClient(allKnowledgeBaseIndexName);    

                actionLinkIndexClient = searchClientIndexesGetClient(actionLinkIndexName);    
            }    
            catch (Exception e)    
            {    
                throw new Exception(“Could not create PortalSearch client”, e);    
            }    
        }    

        /// <summary>  
        ///     The run indexer  
        /// </summary>  
        /// <returns>  
        ///     The <see cref=”SystemThreadingTasksTask” />   
        /// </returns>  
        public async Task RunIndexer()    
        {    
            var kbIndexers = (await searchClientIndexersListAsync())IndexersWhere(x => xNameStartsWith(“kb”))    
                ToArray();    

            for (var i = 0; i < kbIndexersLength; i++)    
            {    
                await searchClientIndexersRunAsync(kbIndexers\[i\]Name);    
            }    
        }    

        /// <summary>  
        /// 创建修改索引  
        /// </summary>  
        /// <param name=”index”></param>  
        /// <returns></returns>  
        public async Task<Indexer> CreateOrUpdateIndexer(Indexer index)    
        {    
            try
            {    
                return await searchClientIndexersCreateOrUpdateAsync(index);    
            }    
            catch (Exception ex)    
            {    
                throw new Exception(“Create indexer failed”, ex);    
            }    
        }    

        /// <summary>  
        /// 检查索引是否存在  
        /// </summary>  
        /// <param name=”indexName”></param>  
        /// <returns></returns>  
        public async Task<bool> IsExistIndexer(string indexName)    
        {    
            try
            {    
                return await searchClientIndexersExistsAsync(indexName);    
            }    
            catch (Exception ex)    
            {    
                throw new Exception(“IsExist call failed”, ex);    
            }    
        }    

        /// <summary>  
        /// 删除索引  
        /// </summary>  
        /// <param name=”indexName”></param>  
        /// <returns></returns>  
        public async Task DeleteIndexer(string indexName)    
        {    
            try
            {    
                await searchClientIndexersDeleteAsync(indexName);    
            }    
            catch (Exception ex)    
            {    
                throw new Exception(“DeleteIndexer call failed”, ex);    
            }    
        }    

        /// <summary>  
        /// 创建或修改索引文档  
        /// </summary>  
        /// <param name=”model”></param>  
        public void CreateOrUpdateDocuments(List<PortalKBSearchResult> model)    
        {    
            var batch = IndexBatchMergeOrUpload(model);    
            try
            {    
                allkbIndexClientDocumentsIndex(batch);    
            }    
            catch (IndexBatchException e)    
            {    
                // Sometimes when your Search service is under load, indexing will fail for some of the documents in  
                // the batch Depending on your application, you can take compensating actions like delaying and  
                // retrying For this simple demo, we just log the failed document keys and continue  
                botTelemetryTrackException(    
                   new BotException { Message = $“Failed to index some of the documents:{StringJoin(“, “, eIndexingResultsWhere(r => !rSucceeded)Select(r => rKey))}”, Error = e });    
            }    
        }    

        /// <summary>  
        /// 创建或修改索引文档  
        /// </summary>  
        /// <param name=”model”></param>  
        public void CreateOrUpdateDocumentsDynamic(List<Document> model)    
        {    
            var batch = IndexBatchMergeOrUpload(model);    
            try
            {    
                allkbIndexClientDocumentsIndex(batch);    
            }    
            catch (IndexBatchException e)    
            {    
                // Sometimes when your Search service is under load, indexing will fail for some of the documents in  
                // the batch Depending on your application, you can take compensating actions like delaying and  
                // retrying For this simple demo, we just log the failed document keys and continue  
                botTelemetryTrackException(    
                   new BotException { Message = $“Failed to index some of the documents:{StringJoin(“, “, eIndexingResultsWhere(r => !rSucceeded)Select(r => rKey))}”, Error = e });    
            }    
        }    

        /// <summary>  
        /// 删除索引文档  
        /// </summary>  
        /// <param name=”model”></param>  
        public void DeleteDocuments(List<PortalKBSearchResult> model)    
        {    
            var batch = IndexBatchDelete(model);    
            try
            {    
                allkbIndexClientDocumentsIndex(batch);    
            }    
            catch (IndexBatchException e)    
            {    
                // Sometimes when your Search service is under load, indexing will fail for some of the documents in  
                // the batch Depending on your application, you can take compensating actions like delaying and  
                // retrying For this simple demo, we just log the failed document keys and continue  
                botTelemetryTrackException(    
                   new BotException { Message = $“Failed to delete index some of the documents:{StringJoin(“, “, eIndexingResultsWhere(r => !rSucceeded)Select(r => rKey))}”, Error = e });    
            }    
        }    

        /// <summary>  
        /// 删除索引文档  
        /// </summary>  
        /// <param name=”key”></param>  
        /// <param name=”keyValues”></param>  
        public void DeleteDocuments(string key, IEnumerable<string> keyValues)    
        {    
            var batch = IndexBatchDelete(key,keyValues);    
            try
            {    
                allkbIndexClientDocumentsIndex(batch);    
            }    
            catch (IndexBatchException e)    
            {    
                // Sometimes when your Search service is under load, indexing will fail for some of the documents in  
                // the batch Depending on your application, you can take compensating actions like delaying and  
                // retrying For this simple demo, we just log the failed document keys and continue  
                botTelemetryTrackException(    
                   new BotException { Message = $“Failed to delete index some of the documents:{StringJoin(“, “, eIndexingResultsWhere(r => !rSucceeded)Select(r => rKey))}”, Error = e });    
            }    
        }    
}

Unit Tester:

public class PortalKBSearchTests    
{    
        [TestMethod()]    
        public void DeleteDocumentsTest()    
        {    
            var searchServiceName = “{AzureSearchName}”;    
            var apiKey = “{AzureSearchApiKey}”;    
            var IndexName = “{AzureSearchIndexName}”;    
            var actionLinkIndexName = “{AzureSearchActionLinkInxerName}”;    
            var search = new PortalKBSearch(searchServiceName, apiKey, IndexName, actionLinkIndexName);    
            string\[\] array = ArrayConvertAll(EnumerableRange(1, 1000)ToArray(), delegate (int s) { return ConvertToString(s); });//每次只能批量删除1000条  
            searchDeleteDocuments(“QuestionId”, array);//第一个参数为筛选匹配字段  
        }    

        [TestMethod()]    
        public void CreateOrUpdateDocuments()    
        {    
           var searchServiceName = “{AzureSearchName}”;    
            var apiKey = “{AzureSearchApiKey}”;    
            var IndexName = “{AzureSearchIndexName}”;    
            var actionLinkIndexName = “{AzureSearchActionLinkInxerName}”;    
            var search = new PortalKBSearch(searchServiceName, apiKey, allknowledgeBaseIndexName, actionLinkIndexName);    
            var item = new Document(); //使用Document继承Dictionary  
            itemAdd(“{Key}”, “{object value}”);    
            searchCreateOrUpdateDocuments(new List<Document>()Add(item)); //SDK中同时提供List<T>入参          
        }    
}