Elasticsearch 系列（七）- 在ASP.NET Core中使用高级客户端NEST来操作Elas

欧米尼亚

本章将和大家分享在ASP.NET Core中如何使用高级客户端NEST来操作我们的Elasticsearch。
NEST是一个高级别的Elasticsearch .NET客户端，它仍然非常接近原始Elasticsearch API的映射。所有的请求和响应都是通过类型来暴露的，这使得它非常适合快速上手和运行。
在底层，NEST使用Elasticsearch.Net低级客户端来发送请求和接收响应，使用并扩展了Elasticsearch.Net中的许多类型。这个低级客户端本身仍然可以通过高级客户端的 .LowLevel 属性来暴露。
高级客户端NEST官方文档地址：https://www.elastic.co/guide/en/elasticsearch/client/net-api/7.17/nest-getting-started.html
废话不多说，首选我们来看一下Demo的目录结构，如下所示：

本Demo的Web项目为ASP.NET Core Web 应用程序（目标框架为.NET 8.0） MVC项目。
ORM框架用的是SqlSugarScope，实体映射用的是AutoMapper，DI框架用的是Autofac。
高级客户端NEST版本用的 7.12.1 ，和Elasticsearch的版本保持一致。
一、连接Elasticsearch

1、单节点连接

1. var settings = new ConnectionSettings(new Uri("http://example.com:9200"))
2.     .DefaultIndex("people");
4. var client = new ElasticClient(settings);

复制代码

2、多节点连接

1. var uris = new[]
2. {
3.     new Uri("http://localhost:9200"),
4.     new Uri("http://localhost:9201"),
5.     new Uri("http://localhost:9202"),
6. };
8. var connectionPool = new SniffingConnectionPool(uris);
9. var settings = new ConnectionSettings(connectionPool)
10.     .DefaultIndex("people");
12. var client = new ElasticClient(settings);

复制代码

二、调试（Debugging）

官方文档：
https://www.elastic.co/guide/en/elasticsearch/client/net-api/7.17/debug-information.html
https://www.elastic.co/guide/en/elasticsearch/client/net-api/7.17/debug-mode.html
https://www.elastic.co/guide/en/elasticsearch/client/net-api/7.17/logging-with-on-request-completed.html
在使用NEST开发Elasticsearch应用程序时，查看NEST生成并发送给Elasticsearch的请求以及Elasticsearch返回的响应信息是非常有价值的。
我们直接来看一个示例，核心代码如下：

1. using System.Text;
2. using Microsoft.Extensions.Configuration;
3. using Nest;
4. using Elasticsearch.Net;
6. namespace TianYaSharpCore.Elasticsearch
7. {
8.     /// <summary>
9.     /// ElasticClient提供者
10.     /// NEST官方文档：https://www.elastic.co/guide/en/elasticsearch/client/net-api/7.17/nest-getting-started.html#nest-getting-started
11.     /// </summary>
12.     public class ElasticClientProvider : IElasticClientProvider
13.     {
14.         /// <summary>
15.         /// Linq查询的官方Client（高级客户端）
16.         /// </summary>
17.         public IElasticClient ElasticLinqClient { get; set; }
19.         /// <summary>
20.         /// Json查询的官方Client（低级客户端）
21.         /// </summary>
22.         public IElasticLowLevelClient ElasticJsonClient { get; set; }
24.         /// <summary>
25.         /// 构造函数
26.         /// </summary>
27.         public ElasticClientProvider(IConfiguration configuration)
28.         {
29.             /*
30.                 var uris = new[]
31.                 {
32.                     new Uri("http://localhost:9200"),
33.                     new Uri("http://localhost:9201"),
34.                     new Uri("http://localhost:9202"),
35.                 };
36.             */
37.             var uris = configuration["ElasticsearchConfig:Uris"];
38.             var defaultIndex = configuration["ElasticsearchConfig:DefaultIndex"]; //默认索引库名称
39.             var uriList = uris?.Split(new char[] { ';', ',' }, StringSplitOptions.RemoveEmptyEntries)
40.                 .ToList().ConvertAll(u => new Uri(u)) ?? new List<Uri>();
41.             if (uriList.Count <= 0)
42.             {
43.                 uriList.Add(new Uri("http://localhost:9200"));
44.             }
46.             if (string.IsNullOrEmpty(defaultIndex))
47.             {
48.                 defaultIndex = "defaultIndex";
49.             }
51.             var list = new List<string>();
52.             var connectionPool = new SniffingConnectionPool(uriList); //连接池
53.             var settings = new ConnectionSettings(connectionPool)
54.                 //.BasicAuthentication("root", "123456")     //验证账号密码登录
55.                 .RequestTimeout(TimeSpan.FromSeconds(30))  //请求超时 30s
56.                 .DefaultFieldNameInferrer(fieldName => fieldName) //移除NEST将类型属性名称序列化为驼峰式命名的默认行为
58.                 /* Debug调试开始 */
59.                 // 请注意，启用详细的调试信息可能会对性能产生影响，并且可能会占用更多的内存来存储额外的信息。
60.                 // 因此，在生产环境中应该禁用它，只在开发或故障排除时启用。
61.                 // 在生产环境中排查问题时建议使用 RequestConfiguration() 以针对某个请求单独禁用直接流处理以捕获请求和响应的字节。
62.                 // 官方文档：
63.                 // https://www.elastic.co/guide/en/elasticsearch/client/net-api/7.17/debug-mode.html
64.                 // https://www.elastic.co/guide/en/elasticsearch/client/net-api/7.17/debug-information.html
65.                 // https://www.elastic.co/guide/en/elasticsearch/client/net-api/7.17/logging-with-on-request-completed.html
66.                 .EnableDebugMode() // 启用详细的调试信息（在生产环境中应该禁用它，只在开发或故障排除时启用）
68.                 //.DisableDirectStreaming() // 禁用直接流处理以捕获请求和响应的字节
69.                 //.PrettyJson() // 返回格式化的JSON响应
71.                 // 这个回调会在每次请求完成（无论成功还是失败）时被调用
72.                 .OnRequestCompleted(apiCallDetails =>
73.                 {
74.                     // 如果您有复杂的日志记录需求，这是一个很好的地方来实现它们，因为您可以访问到请求和响应的详细信息。
75.                     // 根据您的具体需求，您可能需要在回调中执行更复杂的逻辑，比如记录详细的日志、发送警报或执行其他业务逻辑。
77.                     // log out the request and the request body, if one exists for the type of request
78.                     if (apiCallDetails.RequestBodyInBytes != null)
79.                     {
80.                         list.Add(
81.                             $"{apiCallDetails.HttpMethod} {apiCallDetails.Uri} " +
82.                             $"{Encoding.UTF8.GetString(apiCallDetails.RequestBodyInBytes)}"); //请求体
83.                     }
84.                     else
85.                     {
86.                         list.Add($"{apiCallDetails.HttpMethod} {apiCallDetails.Uri}");
87.                     }
89.                     // log out the response and the response body, if one exists for the type of response
90.                     if (apiCallDetails.ResponseBodyInBytes != null)
91.                     {
92.                         list.Add($"Status: {apiCallDetails.HttpStatusCode}" +
93.                                  $"{Encoding.UTF8.GetString(apiCallDetails.ResponseBodyInBytes)}"); //响应体
94.                     }
95.                     else
96.                     {
97.                         list.Add($"Status: {apiCallDetails.HttpStatusCode}");
98.                     }
99.                 })
100.                 /* Debug调试结束 */
102.                 .DefaultIndex(defaultIndex);
104.             ElasticLinqClient = new ElasticClient(settings);
105.             ElasticJsonClient = ElasticLinqClient.LowLevel; //高级客户端 NEST 可以通过访问客户端上的 .LowLevel 属性来获取 Elasticsearch.Net 低级客户端
106.         }
107.     }
108. }

复制代码

其中 .EnableDebugMode() 表示启用详细的调试信息。请注意，启用详细的调试信息可能会对性能产生影响，并且可能会占用更多的内存来存储额外的信息。因此，在生产环境中应该禁用它，只在开发或故障排除时启用。在生产环境中排查问题时建议使用 RequestConfiguration() 以针对某个请求单独禁用直接流处理以捕获请求和响应的字节。
其中 .OnRequestCompleted() 这个回调会在每次请求完成（无论成功还是失败）时被调用。如果您有复杂的日志记录需求，这是一个很好的地方来实现它们，因为您可以访问到请求和响应的详细信息。根据您的具体需求，您可能需要在回调中执行更复杂的逻辑，比如记录详细的日志、发送警报或执行其他业务逻辑。
需要注意的是，此处的 .EnableDebugMode() 配置是针对所有的请求都生效的。在生产环境中，您可能不希望为所有请求都禁用直接流传输，因为这样做会由于在内存中缓存请求和响应字节而产生性能开销。
为此，可以针对每个请求单独启用 DisableDirectStreaming 功能，如下所示：

1. /// <summary>
2. /// 调试
3. /// </summary>
4. public async Task DebugInformationAsync()
5. {
6.     // 其中HotelDoc类为自定义酒店数据对应的ES文档
7.     var searchResponse = await _elasticClientProvider.ElasticLinqClient.SearchAsync<HotelDoc>(s => s
8.         .RequestConfiguration(r => r
9.             // 官方文档：https://www.elastic.co/guide/en/elasticsearch/client/net-api/7.17/logging-with-on-request-completed.html
10.             // 在生产环境中运行应用程序时，您可能不希望为所有请求都禁用直接流传输，因为这样做会由于在内存中缓存请求和响应字节而产生性能开销。
11.             // 然而，在临时需要时捕获请求和响应可能是有用的，比如为了排查生产环境中的问题。
12.             // 为此，可以针对每个请求单独启用 DisableDirectStreaming 功能。
13.             // 利用此功能，可以在 OnRequestCompleted 中配置一个通用的日志记录机制，并仅在必要时记录请求和响应信息。
14.             .DisableDirectStreaming() // 仅针对此请求禁用直接流
15.         )
16.         .From(0)
17.         .Size(2)
18.         .Query(q => q
19.                 .Match(m => m
20.                 .Field(f => f.city)
21.                 .Query("上海")
22.                 )
23.         )
24.     );
26.     // 每个响应都包含一个DebugInformation属性
27.     // 访问DebugInformation属性来获取调试信息
28.     string debugInfo = searchResponse.DebugInformation;
29. }

复制代码

当你使用 Elasticsearch.Net 和 NEST 客户端库与 Elasticsearch 服务器进行交互时，每个响应对象都包含一个 DebugInformation 属性，该属性提供了有关请求和响应的详细信息，以帮助你进行调试和故障排除。通过配置 ConnectionSettings 和 RequestConfiguration 上的属性，你可以控制哪些额外的信息被包含在调试信息中。这些控制可以针对所有请求统一设置，或者针对每个请求单独设置。
具体来说：

• ConnectionSettings：允许你在客户端初始化时全局设置调试信息的详细程度。例如，你可以决定是否包含请求正文、响应正文或是时间戳等信息。
  
• RequestConfiguration：提供了更细粒度的控制，使得你能够为特定的请求覆盖全局设置，添加或移除某些调试信息项目。这意味着对于某个特别关注的请求，你可以增加更多的调试细节，而不影响其他请求的输出。
  

最后我们来看一下 searchResponse.DebugInformation 输出的具体内容，如下所示：

1. Valid NEST response built from a successful (200) low level call on POST: /hotel/_search?pretty=true&error_trace=true&typed_keys=true
2. # Audit trail of this API call:
3. - [1] SniffOnStartup: Took: 00:00:00.2151884
4. - [2] SniffSuccess: Node: http://localhost:9200/ Took: 00:00:00.2027398
5. - [3] PingSuccess: Node: http://127.0.0.1:9200/ Took: 00:00:00.0043129
6. - [4] HealthyResponse: Node: http://127.0.0.1:9200/ Took: 00:00:00.0943867
7. # Request:
8. {"from":0,"query":{"match":{"city":{"query":"上海"}}},"size":2}
9. # Response:
10. {
11.   "took" : 3,
12.   "timed_out" : false,
13.   "_shards" : {
14.     "total" : 1,
15.     "successful" : 1,
16.     "skipped" : 0,
17.     "failed" : 0
18.   },
19.   "hits" : {
20.     "total" : {
21.       "value" : 83,
22.       "relation" : "eq"
23.     },
24.     "max_score" : 0.88342106,
25.     "hits" : [
26.       {
27.         "_index" : "hotel",
28.         "_type" : "_doc",
29.         "_id" : "36934",
30.         "_score" : 0.88342106,
31.         "_source" : {
32.           "id" : 36934,
33.           "name" : "7天连锁酒店(上海宝山路地铁站店)",
34.           "address" : "静安交通路40号",
35.           "price" : 336,
36.           "score" : 37,
37.           "brand" : "7天酒店",
38.           "city" : "上海",
39.           "starName" : "二钻",
40.           "business" : "四川北路商业区",
41.           "location" : "31.251433, 121.47522",
42.           "pic" : "https://m.tuniucdn.com/fb2/t1/G1/M00/3E/40/Cii9EVkyLrKIXo1vAAHgrxo_pUcAALcKQLD688AAeDH564_w200_h200_c1_t0.jpg",
43.           "suggestion" : [
44.             "7天酒店",
45.             "四川北路商业区"
46.           ]
47.         }
48.       },
49.       {
50.         "_index" : "hotel",
51.         "_type" : "_doc",
52.         "_id" : "38609",
53.         "_score" : 0.88342106,
54.         "_source" : {
55.           "id" : 38609,
56.           "name" : "速8酒店(上海赤峰路店)",
57.           "address" : "广灵二路126号",
58.           "price" : 249,
59.           "score" : 35,
60.           "brand" : "速8",
61.           "city" : "上海",
62.           "starName" : "二钻",
63.           "business" : "四川北路商业区",
64.           "location" : "31.282444, 121.479385",
65.           "pic" : "https://m.tuniucdn.com/fb2/t1/G2/M00/DF/96/Cii-TFkx0ImIQZeiAAITil0LM7cAALCYwKXHQ4AAhOi377_w200_h200_c1_t0.jpg",
66.           "suggestion" : [
67.             "速8",
68.             "四川北路商业区"
69.           ]
70.         }
71.       }
72.     ]
73.   }
74. }
76. # TCP states:
77.   Established: 162
78.   TimeWait: 14
79.   SynSent: 4
80.   CloseWait: 13
81.   LastAck: 1
82.   FinWait1: 1
84. # ThreadPool statistics:
85.   Worker:
86.     Busy: 1
87.     Free: 32766
88.     Min: 12
89.     Max: 32767
90.   IOCP:
91.     Busy: 0
92.     Free: 1000
93.     Min: 1
94.     Max: 1000

复制代码

三、索引库操作

对于索引库操作本人更倾向于使用DSL语句去执行。高级客户端 NEST 可以通过访问客户端上的 .LowLevel 属性来获取 Elasticsearch.Net 低级客户端。
在某些场景下，低级客户端非常有用，比如你已经有了代表你想发送请求的JSON，此时并不想将其转换成Fluent API或对象初始化语法，又或者客户端中存在一个可以通过发送字符串请求或匿名类型来规避的bug。
通过 .LowLevel 属性使用低级客户端意味着你可以兼得两者之长：

• 利用高级客户端
  
• 在合适的情况下使用低级客户端，同时充分利用NEST中的所有强类型及其序列化器进行反序列化。
  

示例：

1. using Nest;
2. using Elasticsearch.Net;
3. using Elasticsearch.Net.Specification.IndicesApi;
5. namespace TianYaSharpCore.Elasticsearch
6. {
7.     /// <summary>
8.     /// ES帮助类
9.     /// </summary>
10.     public class ElasticsearchHelper : IElasticsearchHelper
11.     {
12.         /*
13.             1、高级客户端 NEST 可以通过访问客户端上的 .LowLevel 属性来获取 Elasticsearch.Net 低级客户端。
15.             2、在某些场景下，低级客户端非常有用，比如你已经有了代表你想发送请求的JSON，此时并不想将其转换成Fluent API或对象初始化语法，
16.                又或者客户端中存在一个可以通过发送字符串请求或匿名类型来规避的bug。
18.             3、通过 .LowLevel 属性使用低级客户端意味着你可以兼得两者之长：
19.                 *利用高级客户端
20.                 *在合适的情况下使用低级客户端，同时充分利用NEST中的所有强类型及其序列化器进行反序列化。
21.         */
23.         private readonly IElasticClientProvider _elasticClientProvider;
24.         public ElasticsearchHelper(IElasticClientProvider elasticClientProvider)
25.         {
26.             _elasticClientProvider = elasticClientProvider;
27.         }
29.         #region 索引库操作
31.         /// <summary>
32.         /// 判断某个索引库是否存在
33.         /// </summary>
34.         /// <param name="indexName">索引库名称</param>
35.         /// <returns>返回true表示已存在</returns>
36.         public async Task<bool> IsIndexExistsAsync(string indexName)
37.         {
38.             ExistsResponse existsResponse = await _elasticClientProvider.ElasticLinqClient.Indices
39.                 .ExistsAsync(indexName);
40.             return existsResponse.IsValid && existsResponse.Exists;
41.         }
43.         /// <summary>
44.         /// 创建索引库
45.         /// </summary>
46.         /// <param name="indexName">索引库名称</param>
47.         /// <param name="dsl">用于创建索引库的DSL语句</param>
48.         /// <returns>返回true表示创建索引库成功</returns>
49.         public async Task<bool> CreateIndexAsync(string indexName, string dsl)
50.         {
51.             // 发送PUT请求到 Elasticsearch 创建索引  
52.             CreateIndexResponse createIndexResponse = await _elasticClientProvider.ElasticJsonClient.Indices
53.                 .CreateAsync<CreateIndexResponse>(indexName, PostData.String(dsl));
54.             return createIndexResponse.IsValid && createIndexResponse.Acknowledged;
55.         }
57.         /// <summary>
58.         /// 创建索引库
59.         /// </summary>
60.         /// <param name="indexName">索引库名称</param>
61.         /// <param name="body">请求数据</param>
62.         /// <returns>返回true表示创建索引库成功</returns>
63.         public async Task<bool> CreateIndexAsync(string indexName, PostData body,
64.             CreateIndexRequestParameters requestParameters = null, CancellationToken ctx = default(CancellationToken))
65.         {
66.             // 发送PUT请求到 Elasticsearch 创建索引  
67.             CreateIndexResponse createIndexResponse = await _elasticClientProvider.ElasticJsonClient.Indices
68.                 .CreateAsync<CreateIndexResponse>(indexName, body, requestParameters, ctx);
69.             return createIndexResponse.IsValid && createIndexResponse.Acknowledged;
70.         }
72.         /// <summary>
73.         /// 修改索引库（注意：索引库和mapping一旦创建无法修改，但是可以添加新的字段。）
74.         /// </summary>
75.         /// <param name="indexName">索引库名称</param>
76.         /// <param name="dsl">用于修改索引库的DSL语句</param>
77.         /// <returns>返回true表示修改索引库成功</returns>
78.         public async Task<bool> PutMappingAsync(string indexName, string dsl)
79.         {
80.             PutMappingResponse putMappingResponse = await _elasticClientProvider.ElasticJsonClient.Indices
81.                 .PutMappingAsync<PutMappingResponse>(indexName, PostData.String(dsl));
82.             return putMappingResponse.IsValid && putMappingResponse.Acknowledged;
83.         }
85.         /// <summary>
86.         /// 修改索引库（注意：索引库和mapping一旦创建无法修改，但是可以添加新的字段。）
87.         /// </summary>
88.         /// <param name="indexName">索引库名称</param>
89.         /// <param name="body">请求数据</param>
90.         /// <returns>返回true表示修改索引库成功</returns>
91.         public async Task<bool> PutMappingAsync(string indexName, PostData body,
92.             PutMappingRequestParameters requestParameters = null, CancellationToken ctx = default(CancellationToken))
93.         {
94.             PutMappingResponse putMappingResponse = await _elasticClientProvider.ElasticJsonClient.Indices
95.                 .PutMappingAsync<PutMappingResponse>(indexName, body, requestParameters, ctx);
96.             return putMappingResponse.IsValid && putMappingResponse.Acknowledged;
97.         }
99.         /// <summary>
100.         /// 删除索引库
101.         /// </summary>
102.         /// <param name="indexName">索引库名称</param>
103.         /// <returns>返回true表示删除索引库成功</returns>
104.         public async Task<bool> DeleteIndexAsync(string indexName)
105.         {
106.             DeleteIndexResponse deleteIndexResponse = await _elasticClientProvider.ElasticLinqClient.Indices
107.                 .DeleteAsync(indexName);
108.             return deleteIndexResponse.IsValid && deleteIndexResponse.Acknowledged;
109.         }
111.         #endregion
113.         #region 文档操作
115.         /// <summary>
116.         /// 获取文档
117.         /// </summary>
118.         /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
119.         /// <param name="documentId">文档Id</param>
120.         /// <returns></returns>
121.         public async Task<GetResponse<TDocument>> GetAsync<TDocument>(DocumentPath<TDocument> documentId,
122.             Func<GetDescriptor<TDocument>, IGetRequest> selector = null, CancellationToken ct = default(CancellationToken))
123.             where TDocument : class
124.         {
125.             return await _elasticClientProvider.ElasticLinqClient.GetAsync(documentId, selector, ct);
126.         }
128.         /// <summary>
129.         /// 新增文档或全量修改文档
130.         /// </summary>
131.         /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
132.         /// <param name="document">文档</param>
133.         /// <returns>返回true表示操作成功</returns>
134.         public async Task<bool> IndexDocumentAsync<TDocument>(TDocument document, CancellationToken ct = default(CancellationToken))
135.             where TDocument : class
136.         {
137.             IndexResponse indexResponse = await _elasticClientProvider.ElasticLinqClient.IndexDocumentAsync(document, ct);
138.             return indexResponse != null && indexResponse.IsValid;
139.         }
141.         /// <summary>
142.         /// 新增文档或全量修改文档（需要设置额外的参数时使用该方法，例如：需要指定索引库）
143.         /// </summary>
144.         /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
145.         /// <param name="document">文档</param>
146.         /// <returns>返回true表示操作成功</returns>
147.         public async Task<bool> IndexAsync<TDocument>(TDocument document, Func<IndexDescriptor<TDocument>, IIndexRequest<TDocument>> selector,
148.             CancellationToken ct = default(CancellationToken)) where TDocument : class
149.         {
150.             IndexResponse indexResponse = await _elasticClientProvider.ElasticLinqClient.IndexAsync(document, selector, ct);
151.             return indexResponse != null && indexResponse.IsValid;
152.         }
154.         /// <summary>
155.         /// 局部修改（增量修改）文档字段，修改指定字段值
156.         /// </summary>
157.         /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
158.         /// <param name="indexName">索引库名称</param>
159.         /// <param name="documentId">文档Id</param>
160.         /// <param name="dsl">修改指定字段值的DSL语句</param>
161.         /// <returns>返回true表示修改成功</returns>
162.         public async Task<bool> UpdateAsync<TDocument>(string indexName, string documentId, string dsl)
163.             where TDocument : class
164.         {
165.             UpdateResponse<TDocument> updateResponse = await _elasticClientProvider.ElasticJsonClient
166.                 .UpdateAsync<UpdateResponse<TDocument>>(indexName, documentId, PostData.String(dsl));
167.             return updateResponse != null && updateResponse.IsValid;
168.         }
170.         /// <summary>
171.         /// 局部修改（增量修改）文档字段，修改指定字段值
172.         /// </summary>
173.         /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
174.         /// <param name="indexName">索引库名称</param>
175.         /// <param name="documentId">文档Id</param>
176.         /// <param name="body">请求数据</param>
177.         /// <returns>返回true表示修改成功</returns>
178.         public async Task<bool> UpdateAsync<TDocument>(string indexName, string documentId, PostData body,
179.             UpdateRequestParameters requestParameters = null, CancellationToken ctx = default(CancellationToken))
180.             where TDocument : class
181.         {
182.             UpdateResponse<TDocument> updateResponse = await _elasticClientProvider.ElasticJsonClient
183.                 .UpdateAsync<UpdateResponse<TDocument>>(indexName, documentId, body, requestParameters, ctx);
184.             return updateResponse != null && updateResponse.IsValid;
185.         }
187.         /// <summary>
188.         /// 删除文档
189.         /// </summary>
190.         /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
191.         /// <param name="documentId">文档Id</param>
192.         /// <returns>返回true表示删除文档成功</returns>
193.         public async Task<bool> DeleteAsync<TDocument>(DocumentPath<TDocument> documentId,
194.             Func<DeleteDescriptor<TDocument>, IDeleteRequest> selector = null, CancellationToken ct = default(CancellationToken))
195.             where TDocument : class
196.         {
197.             DeleteResponse deleteResponse = await _elasticClientProvider.ElasticLinqClient.DeleteAsync(documentId, selector, ct);
198.             return deleteResponse != null && deleteResponse.IsValid;
199.         }
201.         /// <summary>
202.         /// 批量新增文档
203.         /// </summary>
204.         /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
205.         /// <param name="objects">文档集合</param>
206.         /// <returns>返回true表示操作成功</returns>
207.         public async Task<bool> IndexManyAsync<TDocument>(IEnumerable<TDocument> objects, IndexName index = null,
208.             CancellationToken cancellationToken = default(CancellationToken)) where TDocument : class
209.         {
210.             BulkResponse bulkResponse = await _elasticClientProvider.ElasticLinqClient.IndexManyAsync(objects, index, cancellationToken);
211.             return bulkResponse != null && bulkResponse.IsValid;
212.         }
214.         /// <summary>
215.         /// 执行批量数据操作，包括新增、更新或删除多个文档，而只需发起一次HTTP请求
216.         /// </summary>
217.         /// <returns>返回true表示操作成功</returns>
218.         public async Task<bool> BulkAsync(Func<BulkDescriptor, IBulkRequest> selector, CancellationToken ct = default(CancellationToken))
219.         {
220.             BulkResponse bulkResponse = await _elasticClientProvider.ElasticLinqClient.BulkAsync(selector, ct);
221.             return bulkResponse != null && bulkResponse.IsValid;
222.         }
224.         #endregion
226.         #region 根据DSL语句查询
228.         /// <summary>
229.         /// 根据DSL语句查询
230.         /// </summary>
231.         /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
232.         /// <param name="queryDsl">DSL查询语句</param>
233.         /// <returns></returns>
234.         public async Task<ISearchResponse<TDocument>> SearchAsync<TDocument>(string queryDsl)
235.             where TDocument : class
236.         {
237.             return await SearchAsync<TDocument>(PostData.String(queryDsl));
238.         }
240.         /// <summary>
241.         /// 根据DSL语句查询
242.         /// </summary>
243.         /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
244.         /// <param name="indexName">索引库名称</param>
245.         /// <param name="queryDsl">DSL查询语句</param>
246.         /// <returns></returns>
247.         public async Task<ISearchResponse<TDocument>> SearchAsync<TDocument>(string indexName, string queryDsl)
248.            where TDocument : class
249.         {
250.             return await SearchAsync<TDocument>(indexName, PostData.String(queryDsl));
251.         }
253.         /// <summary>
254.         /// 根据DSL语句查询
255.         /// </summary>
256.         /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
257.         public async Task<ISearchResponse<TDocument>> SearchAsync<TDocument>(PostData body,
258.             SearchRequestParameters requestParameters = null, CancellationToken ctx = default(CancellationToken))
259.            where TDocument : class
260.         {
261.             return await _elasticClientProvider.ElasticJsonClient.SearchAsync<SearchResponse<TDocument>>(body, requestParameters, ctx);
262.         }
264.         /// <summary>
265.         /// 根据DSL语句查询
266.         /// </summary>
267.         /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
268.         /// <param name="indexName">索引库名称</param>
269.         public async Task<ISearchResponse<TDocument>> SearchAsync<TDocument>(string indexName, PostData body,
270.             SearchRequestParameters requestParameters = null, CancellationToken ctx = default(CancellationToken))
271.            where TDocument : class
272.         {
273.             return await _elasticClientProvider.ElasticJsonClient.SearchAsync<SearchResponse<TDocument>>(indexName, body, requestParameters, ctx);
274.         }
276.         #endregion
277.     }
278. }

复制代码

在此处，查询我使用的是DSL语句，但是响应的主体是高级客户端 NEST 返回的相同响应类型的具体实现。
NEST中提供的所有方法都提供了同步和异步两个版本，其中异步版本的方法名在末尾使用了标准的 *Async 后缀。
案例：根据提供的酒店数据创建索引库，索引库名称为hotel，mapping属性根据数据库表结构来定义。

其中 MySQL 数据库中 tb_hotel 酒店表的表结构如下所示：

1. CREATE TABLE `tb_hotel` (
2.   `id` bigint(20) NOT NULL COMMENT '酒店id',
3.   `name` varchar(255) NOT NULL COMMENT '酒店名称；例：7天酒店',
4.   `address` varchar(255) NOT NULL COMMENT '酒店地址；例：航头路',
5.   `price` int(10) NOT NULL COMMENT '酒店价格；例：329',
6.   `score` int(2) NOT NULL COMMENT '酒店评分；例：45，就是4.5分',
7.   `brand` varchar(32) NOT NULL COMMENT '酒店品牌；例：如家',
8.   `city` varchar(32) NOT NULL COMMENT '所在城市；例：上海',
9.   `star_name` varchar(16) DEFAULT NULL COMMENT '酒店星级，从低到高分别是：1星到5星，1钻到5钻',
10.   `business` varchar(255) DEFAULT NULL COMMENT '商圈；例：虹桥',
11.   `latitude` varchar(32) NOT NULL COMMENT '纬度；例：31.2497',
12.   `longitude` varchar(32) NOT NULL COMMENT '经度；例：120.3925',
13.   `pic` varchar(255) DEFAULT NULL COMMENT '酒店图片；例:/img/1.jpg',
14.   PRIMARY KEY (`id`)
15. ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

复制代码

分析其数据结构，创建相应的酒店数据索引库，对应的DSL语句如下所示：

1. # 创建酒店数据索引库
2. PUT /hotel
3. {
4.   "settings": {
5.     "analysis": {
6.       "analyzer": {
7.         "text_anlyzer": {
8.           "tokenizer": "ik_max_word",
9.           "filter": "py"
10.         },
11.         "completion_analyzer": {
12.           "tokenizer": "keyword",
13.           "filter": "py"
14.         }
15.       },
16.       "filter": {
17.         "py": {
18.           "type": "pinyin",
19.           "keep_full_pinyin": false,
20.           "keep_joined_full_pinyin": true,
21.           "keep_original": true,
22.           "limit_first_letter_length": 16,
23.           "remove_duplicated_term": true,
24.           "none_chinese_pinyin_tokenize": false
25.         }
26.       }
27.     }
28.   },
29.   "mappings": {
30.     "properties": {
31.       "id": {
32.         "type": "keyword"
33.       },
34.       "name": {
35.         "type": "text",
36.         "analyzer": "text_anlyzer",
37.         "search_analyzer": "ik_smart",
38.         "copy_to": "all"
39.       },
40.       "address": {
41.         "type": "keyword",
42.         "index": false
43.       },
44.       "price": {
45.         "type": "integer"
46.       },
47.       "score": {
48.         "type": "integer"
49.       },
50.       "brand": {
51.         "type": "keyword",
52.         "copy_to": "all"
53.       },
54.       "city": {
55.         "type": "keyword"
56.       },
57.       "starName": {
58.         "type": "keyword"
59.       },
60.       "business": {
61.         "type": "keyword",
62.         "copy_to": "all"
63.       },
64.       "location": {
65.         "type": "geo_point"
66.       },
67.       "pic": {
68.         "type": "keyword",
69.         "index": false
70.       },
71.       "all": {
72.         "type": "text",
73.         "analyzer": "text_anlyzer",
74.         "search_analyzer": "ik_smart"
75.       },
76.       "suggestion": {
77.         "type": "completion",
78.         "analyzer": "completion_analyzer"
79.       }
80.     }
81.   }
82. }

复制代码

当然，你既可以使用 NEST 高级客户端去创建索引库，也可以直接使用 kibana 等工具创建索引库。
其中需要特别注意的是：
1）此处的 id 并不是定义成 long 类型，这是因为在 ES 中 id 字段比较特殊，我们一般都会把它定义成固定的 keyword 类型。
2）此处的 index 属性表示该字段是否需要参与搜索，默认值为 true 表示需要参与搜索，如果该字段不需要参与搜索则可以手动把它设置成 false 。
3）数据库中的 longitude（经度）字段 和 latitude（纬度）字段 合并成了 ES 中的 location（地理坐标） 字段，字段类型为 geo_point ，它的值其实就是字符串类型，由经度和纬度的字段值使用英文逗号拼接而成。
4）字段拷贝，可以使用 copy_to 属性将当前字段拷贝到指定字段上（字段名称可以随意）。我们知道根据一个字段去搜索的效率要明显高于根据多个字段去搜索的效率，但是有些需求就是需要根据多个字段去搜索，这时候就可以使用 copy_to 属性了，可以将多个需要同时搜索的字段拷贝到某个指定的字段上，将来再根据这个指定的字段来搜索，这样子就可以提升查询效率了。copy_to 能够实现在一个字段里面搜索多个字段的内容，而且这种拷贝它还做了优化，它并不是真的把文档拷贝进去了，而只是基于它创建倒排索引，所以将来你去查的时候其实你是看不到这个字段的，虽然看不到但是搜索却能根据它搜，这就很完美了。
四、文档操作

首先我们需要创建与酒店数据相对应的实体类型，如下所示：
Hotel类（酒店数据，与MySQL数据库表字段相对应）：

1. using SqlSugar;
3. namespace Demo.Domain.Entities
4. {
5.     /// <summary>
6.     /// 酒店数据
7.     /// </summary>
8.     [SugarTable("tb_hotel")] //指定数据库表名
9.     public class Hotel
10.     {
11.         /// <summary>
12.         /// 酒店id
13.         /// </summary>
14.         [SugarColumn(IsPrimaryKey = true)] //数据库是主键需要加上IsPrimaryKey
15.         public long id { get; set; }
17.         /// <summary>
18.         /// 酒店名称
19.         /// </summary>
20.         public string name { get; set; }
22.         /// <summary>
23.         /// 酒店地址
24.         /// </summary>
25.         public string address { get; set; }
27.         /// <summary>
28.         /// 酒店价格
29.         /// </summary>
30.         public int price { get; set; }
32.         /// <summary>
33.         /// 酒店评分
34.         /// </summary>
35.         public int score { get; set; }
37.         /// <summary>
38.         /// 酒店品牌
39.         /// </summary>
40.         public string brand { get; set; }
42.         /// <summary>
43.         /// 所在城市
44.         /// </summary>
45.         public string city { get; set; }
47.         /// <summary>
48.         /// 酒店星级
49.         /// </summary>
50.         [SugarColumn(ColumnName = "star_name")] //指定数据库表字段
51.         public string starName { get; set; }
53.         /// <summary>
54.         /// 商圈
55.         /// </summary>
56.         public string business { get; set; }
58.         /// <summary>
59.         /// 纬度
60.         /// </summary>
61.         public string latitude { get; set; }
63.         /// <summary>
64.         /// 经度
65.         /// </summary>
66.         public string longitude { get; set; }
68.         /// <summary>
69.         /// 酒店图片
70.         /// </summary>
71.         public string pic { get; set; }
72.     }
73. }

复制代码

public class HotelHotelDoc类（酒店数据对应的ES文档）：

1. using System;
3. namespace Demo.Domain.Docs
4. {
5.     /// <summary>
6.     /// 酒店数据对应的ES文档
7.     /// </summary>
8.     public class HotelDoc
9.     {
10.         /// <summary>
11.         /// 酒店id
12.         /// </summary>
13.         public long id { get; set; }
15.         /// <summary>
16.         /// 酒店名称
17.         /// </summary>
18.         public string name { get; set; }
20.         /// <summary>
21.         /// 酒店地址
22.         /// </summary>
23.         public string address { get; set; }
25.         /// <summary>
26.         /// 酒店价格
27.         /// </summary>
28.         public int price { get; set; }
30.         /// <summary>
31.         /// 酒店评分
32.         /// </summary>
33.         public int score { get; set; }
35.         /// <summary>
36.         /// 酒店品牌
37.         /// </summary>
38.         public string brand { get; set; }
40.         /// <summary>
41.         /// 所在城市
42.         /// </summary>
43.         public string city { get; set; }
45.         /// <summary>
46.         /// 酒店星级
47.         /// </summary>
48.         public string starName { get; set; }
50.         /// <summary>
51.         /// 商圈
52.         /// </summary>
53.         public string business { get; set; }
55.         /// <summary>
56.         /// 纬度
57.         /// </summary>
58.         //public string latitude { get; set; }
60.         /// <summary>
61.         /// 经度
62.         /// </summary>
63.         //public string longitude { get; set; }
65.         /// <summary>
66.         /// 地理坐标字段（将经度和纬度字段合并成一个地理坐标字段）
67.         /// 将经度和纬度的字段值用英文逗号拼在一起，例如："40.048969, 116.619566"
68.         /// </summary>
69.         public string location { get; set; }
71.         /// <summary>
72.         /// 酒店图片
73.         /// </summary>
74.         public string pic { get; set; }
76.         /// <summary>
77.         /// 自动补全搜索字段
78.         /// </summary>
79.         public List<string> suggestion { get; set; }
80.     }
81. }

复制代码

public class HotelDocHotel类 和 HotelDoc类 二者的映射关系：

1. using AutoMapper;
2. using Demo.Domain.Docs;
3. using Demo.Domain.Entities;
5. namespace Demo.Domain.AutoMapperConfigs
6. {
7.     public class MyProfile : Profile
8.     {
9.         public MyProfile()
10.         {
11.             // 配置 mapping 规则
12.             CreateMap<Hotel, HotelDoc>()
13.                 .AfterMap((tbl, doc) =>
14.                 {
15.                     #region 地理坐标字段处理
17.                     if (!string.IsNullOrEmpty(tbl.latitude) && !string.IsNullOrEmpty(tbl.longitude))
18.                     {
19.                         //将经度和纬度的字段值用英文逗号拼在一起，例如："40.048969, 116.619566"
20.                         doc.location = string.Format(@"{0}, {1}", tbl.latitude, tbl.longitude);
21.                     }
23.                     #endregion
25.                     #region 自动补全搜索字段处理
27.                     var suggestionList = new List<string>();
28.                     if (!string.IsNullOrEmpty(tbl.brand))
29.                     {
30.                         //品牌
31.                         suggestionList.Add(tbl.brand);
32.                     }
34.                     if (!string.IsNullOrEmpty(tbl.business))
35.                     {
36.                         //商圈
37.                         if (tbl.business.Contains("/"))
38.                         {
39.                             suggestionList.AddRange(tbl.business.Split('/'));
40.                         }
41.                         else
42.                         {
43.                             suggestionList.Add(tbl.business);
44.                         }
45.                     }
47.                     doc.suggestion = suggestionList;
49.                     #endregion
50.                 });
51.         }
52.     }
53. }

复制代码

public class MyProfile实体类型创建好后，接下来我们就可以去操作ES的文档了。
1、新增文档或全量修改文档

1. /// <summary>
2. /// 新增文档或全量修改文档
3. /// </summary>
4. /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
5. /// <param name="document">文档</param>
6. /// <returns>返回true表示操作成功</returns>
7. public async Task<bool> IndexDocumentAsync<TDocument>(TDocument document, CancellationToken ct = default(CancellationToken))
8.     where TDocument : class
9. {
10.     IndexResponse indexResponse = await _elasticClientProvider.ElasticLinqClient.IndexDocumentAsync(document, ct);
11.     return indexResponse != null && indexResponse.IsValid;
12. }
14. /// <summary>
15. /// 新增文档或全量修改文档（需要设置额外的参数时使用该方法，例如：需要指定索引库）
16. /// </summary>
17. /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
18. /// <param name="document">文档</param>
19. /// <returns>返回true表示操作成功</returns>
20. public async Task<bool> IndexAsync<TDocument>(TDocument document, Func<IndexDescriptor<TDocument>, IIndexRequest<TDocument>> selector,
21.     CancellationToken ct = default(CancellationToken)) where TDocument : class
22. {
23.     IndexResponse indexResponse = await _elasticClientProvider.ElasticLinqClient.IndexAsync(document, selector, ct);
24.     return indexResponse != null && indexResponse.IsValid;
25. }

复制代码

示例：

1. /// <summary>
2. /// 新增文档或全量修改文档
3. /// </summary>
4. /// <returns></returns>
5. public async Task IndexAsync()
6. {
7.     var hotelDoc = new HotelDoc
8.     {
9.         id = 1,
10.         name = "7天连锁酒店",
11.         address = "永泰县",
12.         price = 100,
13.         score = 68,
14.         brand = "7天酒店",
15.         city = "上海",
16.         starName = "二钻",
17.         business = "龙岗中心区/大运新城",
18.         location = "40.048969, 116.619566",
19.         pic = "TF3PFkiIb27dAAEqdDcKl3YAAEViQGVWY0AASqM960_w200_h200_c1_t0.jpg",
20.         suggestion = new List<string> { "7天酒店", "龙岗中心区", "大运新城" }
21.     };
23.     // 新增文档或全量修改文档
24.     bool flag = await _elasticsearchHelper.IndexAsync(hotelDoc, i => i.Index("hotel"));
25. }

复制代码

2、局部修改（增量修改）文档

1. /// <summary>
2. /// 局部修改（增量修改）文档字段，修改指定字段值
3. /// </summary>
4. /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
5. /// <param name="indexName">索引库名称</param>
6. /// <param name="documentId">文档Id</param>
7. /// <param name="dsl">修改指定字段值的DSL语句</param>
8. /// <returns>返回true表示修改成功</returns>
9. public async Task<bool> UpdateAsync<TDocument>(string indexName, string documentId, string dsl)
10.     where TDocument : class
11. {
12.     UpdateResponse<TDocument> updateResponse = await _elasticClientProvider.ElasticJsonClient
13.         .UpdateAsync<UpdateResponse<TDocument>>(indexName, documentId, PostData.String(dsl));
14.     return updateResponse != null && updateResponse.IsValid;
15. }
17. /// <summary>
18. /// 局部修改（增量修改）文档字段，修改指定字段值
19. /// </summary>
20. /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
21. /// <param name="indexName">索引库名称</param>
22. /// <param name="documentId">文档Id</param>
23. /// <param name="body">请求数据</param>
24. /// <returns>返回true表示修改成功</returns>
25. public async Task<bool> UpdateAsync<TDocument>(string indexName, string documentId, PostData body,
26.     UpdateRequestParameters requestParameters = null, CancellationToken ctx = default(CancellationToken))
27.     where TDocument : class
28. {
29.     UpdateResponse<TDocument> updateResponse = await _elasticClientProvider.ElasticJsonClient
30.         .UpdateAsync<UpdateResponse<TDocument>>(indexName, documentId, body, requestParameters, ctx);
31.     return updateResponse != null && updateResponse.IsValid;
32. }

复制代码

示例：

1. /// <summary>
2. /// 局部修改（增量修改）文档字段
3. /// </summary>
4. /// <returns></returns>
5. public async Task UpdateAsync()
6. {
7.     // 修改指定字段值
8.     var updateFields = new
9.     {
10.         doc = new
11.         {
12.             price = 360,
13.             score = 59
14.         }
15.     };
17.     bool flag = await _elasticsearchHelper.UpdateAsync<HotelDoc>(indexName: "hotel",
18.         documentId: "1", body: PostData.Serializable(updateFields));
19. }

复制代码

3、获取文档

1. /// <summary>
2. /// 获取文档
3. /// </summary>
4. /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
5. /// <param name="documentId">文档Id</param>
6. /// <returns></returns>
7. public async Task<GetResponse<TDocument>> GetAsync<TDocument>(DocumentPath<TDocument> documentId,
8.     Func<GetDescriptor<TDocument>, IGetRequest> selector = null, CancellationToken ct = default(CancellationToken))
9.     where TDocument : class
10. {
11.     return await _elasticClientProvider.ElasticLinqClient.GetAsync(documentId, selector, ct);
12. }

复制代码

示例：

1. /// <summary>
2. /// 获取文档
3. /// </summary>
4. /// <returns></returns>
5. public async Task GetAsync()
6. {
7.     GetResponse<HotelDoc> getResponse = await _elasticsearchHelper.GetAsync<HotelDoc>(documentId: 1, g => g.Index("hotel"));
8.     if (getResponse != null && getResponse.Found)
9.     {
10.         // 获取文档成功
11.         var hotelDoc = getResponse.Source;
12.     }
13.     else
14.     {
15.         // 未获取到文档
16.     }
17. }

复制代码

4、删除文档

1. /// <summary>
2. /// 删除文档
3. /// </summary>
4. /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
5. /// <param name="documentId">文档Id</param>
6. /// <returns>返回true表示删除文档成功</returns>
7. public async Task<bool> DeleteAsync<TDocument>(DocumentPath<TDocument> documentId, Func<DeleteDescriptor<TDocument>, IDeleteRequest> selector = null,
8.     CancellationToken ct = default(CancellationToken)) where TDocument : class
9. {
10.     DeleteResponse deleteResponse = await _elasticClientProvider.ElasticLinqClient.DeleteAsync(documentId, selector, ct);
11.     return deleteResponse != null && deleteResponse.IsValid;
12. }

复制代码

示例：

1. /// <summary>
2. /// 删除文档
3. /// </summary>
4. /// <returns></returns>
5. public async Task DeleteAsync()
6. {
7.     bool flag = await _elasticsearchHelper.DeleteAsync<HotelDoc>(documentId: "1", d => d.Index("hotel"));
8. }

复制代码

5、批量新增文档 

1. /// <summary>
2. /// 批量新增文档
3. /// </summary>
4. /// <typeparam name="TDocument">索引库对应的文档类型</typeparam>
5. /// <param name="objects">文档集合</param>
6. /// <returns>返回true表示操作成功</returns>
7. public async Task<bool> IndexManyAsync<TDocument>(IEnumerable<TDocument> objects, IndexName index = null,
8.     CancellationToken cancellationToken = default(CancellationToken)) where TDocument : class
9. {
10.     BulkResponse bulkResponse = await _elasticClientProvider.ElasticLinqClient.IndexManyAsync(objects, index, cancellationToken);
11.     return bulkResponse != null && bulkResponse.IsValid;
12. }

复制代码

6、执行批量数据操作

1. /// <summary>
2. /// 执行批量数据操作，包括新增、更新或删除多个文档，而只需发起一次HTTP请求
3. /// </summary>
4. /// <returns>返回true表示操作成功</returns>
5. public async Task<bool> BulkAsync(Func<BulkDescriptor, IBulkRequest> selector, CancellationToken ct = default(CancellationToken))
6. {
7.     BulkResponse bulkResponse = await _elasticClientProvider.ElasticLinqClient.BulkAsync(selector, ct);
8.     return bulkResponse != null && bulkResponse.IsValid;
9. }

复制代码

示例：

1. /// <summary>
2. /// 执行批量数据操作，包括新增、更新或删除多个文档，而只需发起一次HTTP请求
3. /// </summary>
4. /// <returns></returns>
5. public async Task BulkAsync()
6. {
7.     var hotelDocList = new List<HotelDoc> {
8.         new HotelDoc
9.         {
10.             id = 1,
11.             name = "7天连锁酒店(上海宝山路地铁站店)",
12.             address = "静安交通路40号",
13.             price = 100,
14.             score = 38,
15.             brand = "7天酒店",
16.             city = "上海",
17.             starName = "二钻",
18.             business = "龙岗中心区/大运新城",
19.             location = "40.048969, 116.619566",
20.             pic = "TF3PFkiIb27dAAEqdDcKl3YAAEViQGVWY0AASqM960_w200_h200_c1_t0.jpg",
21.             suggestion = new List<string> { "7天酒店", "龙岗中心区", "大运新城" }
22.         },
23.         new HotelDoc
24.         {
25.             id = 2,
26.             name = "维也纳酒店（北京花园路店）",
27.             address = "海淀北太平庄花园路甲17号",
28.             price = 381,
29.             score = 85,
30.             brand = "维也纳",
31.             city = "北京",
32.             starName = "三钻",
33.             business = "马甸、安贞地区",
34.             location = "39.970837, 116.365244",
35.             pic = "https://m.tuniucdn.com/filebroker/cdn/res/17/00/1700926908bae6ba3e5ef96de7b7d4cc_w200_h200_c1_t0.jpg",
36.             suggestion = new List<string> { "维也纳", "马甸、安贞地区" }
37.         }
38.     };
40.     bool flag = await _elasticsearchHelper.BulkAsync(bulk => bulk
41.         .Index("hotel") // 指定索引库
42.         .IndexMany(hotelDocList) // 批量新增文档
43.     );
44. }

复制代码

五、文档查询

官方文档：https://www.elastic.co/guide/en/elasticsearch/client/net-api/7.17/writing-queries.html
示例1：

1. /// <summary>
2. /// 文档查询
3. /// </summary>
4. /// <returns></returns>
5. public async Task SearchAsync()
6. {
7.     var searchResponse = await _elasticClientProvider.ElasticLinqClient
8.         .SearchAsync<HotelDoc>(s => s
9.         .Source(sf => sf
10.             //指定返回的字段
11.             .Includes(i => i
12.                 .Fields(
13.                     f => f.id,
14.                     f => f.name,
15.                     f => f.score
16.                 )
17.             )
18.             //指定不返回的字段
19.             .Excludes(e => e
20.                 .Fields("pic*") //可以通过通配符模式来包含或排除字段
21.             )
22.         )
23.         .From(0)
24.         .Size(10)
25.         .Query(q => q
26.             .Match(m => m
27.                 .Field(f => f.name)
28.                 .Query("如家酒店")
29.             )
30.         )
31.     );
33.     if (searchResponse != null && searchResponse.IsValid)
34.     {
35.         var hotelDocs = searchResponse.Documents;
36.     }
37. }

复制代码

其生成的DSL语句如下所示：

1. GET /hotel/_search
2. {
3.   "from": 0,
4.   "size": 10,
5.   "query": {
6.     "match": {
7.       "name": {
8.         "query": "如家酒店"
9.       }
10.     }
11.   },
12.   "_source": {
13.     "excludes": [
14.       "pic*"
15.     ],
16.     "includes": [
17.       "id",
18.       "name",
19.       "score"
20.     ]
21.   }
22. }

复制代码

示例2：

1. /// <summary>
2. /// 布尔查询
3. /// </summary>
4. /// <returns></returns>
5. public async Task BooleanQueryAsync()
6. {
7.     //布尔查询
8.     var searchResponse = await _elasticClientProvider.ElasticLinqClient
9.         .SearchAsync<HotelDoc>(s => s
10.         .From(0)
11.         .Size(10)
12.         .Query(q => q
13.             .Bool(b => b
14.                 .Must(
15.                     mu => mu.Term(h => h.city, "上海"),
16.                     mu => mu.Bool(bl => bl
17.                         .Should(
18.                             bs => bs.Term(h => h.brand, "皇冠假日"),
19.                             bs => bs.Term(h => h.brand, "华美达")
20.                         )
21.                     )
22.                 )
23.             )
24.         )
25.     );
27.     //布尔查询简写
28.     searchResponse = await _elasticClientProvider.ElasticLinqClient.SearchAsync<HotelDoc>(s => s
29.         .From(0)
30.         .Size(10)
31.         .Query(q =>
32.             q.Term(h => h.city, "上海") && (q.Term(h => h.brand, "皇冠假日") || q.Term(h => h.brand, "华美达"))
33.         )
34.     );
36.     if (searchResponse != null && searchResponse.IsValid)
37.     {
38.         var hotelDocs = searchResponse.Documents;
39.     }
40. }

复制代码

其生成的DSL语句如下所示：

1. GET /hotel/_search
2. {
3.   "query": {
4.     "bool": {
5.       "must": [
6.         {
7.           "term": {
8.             "city": {
9.               "value": "上海"
10.             }
11.           }
12.         },
13.         {
14.           "bool": {
15.             "should": [
16.               {
17.                 "term": {
18.                   "brand": {
19.                     "value": "皇冠假日"
20.                   }
21.                 }
22.               },
23.               {
24.                 "term": {
25.                   "brand": {
26.                     "value": "华美达"
27.                   }
28.                 }
29.               }
30.             ]
31.           }
32.         }
33.       ]
34.     }
35.   },
36.   "from": 0,
37.   "size": 10
38. }

复制代码

更多查询写法可直接参考官网文档，此处就不做过多的介绍了。 
至此本文就全部介绍完了，如果觉得对您有所启发请记得点个赞哦！！！
 
Demo源码：

1. 链接：https://pan.baidu.com/s/1tv6VQ7nxqv-f7sEGUgYTPQ
2. 提取码：l30a

复制代码

此文由博主精心撰写转载请保留此原文链接：https://www.cnblogs.com/xyh9039/p/18200453
版权声明：如有雷同纯属巧合，如有侵权请及时联系本人修改，谢谢！！！

来源:https://www.cnblogs.com/xyh9039/p/18200453
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！