ElasticSearch入门第四篇：使用C#添加和更新文档

素颜马尾好姑娘i 2023-06-01 03:26 11阅读 0赞

# [ElasticSearch入门 第四篇：使用C\#添加和更新文档][ElasticSearch_ _C] #

这是ElasticSearch 2.4 版本系列的第四篇：

*  [ElasticSearch入门 第一篇：Windows下安装ElasticSearch][ElasticSearch_ _Windows_ElasticSearch]
 *  [ElasticSearch入门 第二篇：集群配置][ElasticSearch_]
 *  [ElasticSearch入门 第三篇：索引][ElasticSearch_ 1]
 *  [ElasticSearch入门 第四篇：使用C\#添加和更新文档][ElasticSearch_ _C 1]
 *  [ElasticSearch入门 第五篇：使用C\#查询文档][ElasticSearch_ _C 2]
 *  [ElasticSearch入门 第六篇：复合数据类型——数组，对象和嵌套][ElasticSearch_ 2]
 *  [ElasticSearch入门 第七篇：分析器][ElasticSearch_ 3]
 *  [ElasticSearch入门 第八篇：存储][ElasticSearch_ 4]
 *  [ElasticSearch入门 第九篇：实现正则表达式查询的思路][ElasticSearch_ 5]

在ElasticSearch引擎中进行全文搜索是一件非常酷炫的事，而创建索引是最重要的事，必须要精心设计，建议使用head插件创建索引的映射（Mapping），而对索引文档数据的日常更新，可以使用C\#客户端程序，按照计划自动进行数据的同步和更新。

对于一个数据库开发，很久没有写过C\#代码，dot net菜鸟一个，本文简单分享了使用ElasticSearch的.net客户端驱动程序向索引中添加文档的代码片段，详细信息，请参考官方手册：[Elasticsearch.Net and NEST: the .NET clients \[5.x\] » Introduction][Elasticsearch.Net and NEST_ the .NET clients _5.x_ _ Introduction]

**一，ElasticSearch的.net客户端驱动程序**

ElasticSearch官方网站提供了两个.net客户端驱动程序，其中Elasticsearch.Net是一个非常底层且灵活的客户端驱动程序，用户需要手动创建请求（Request）和响应（Response）；而NEST是一个高层的客户端，其内部使用的依然是Elasticsearch.Net驱动程序，NEST拥有查询DSL（领域特定语言），能够映射所有请求和响应对象，使用起来比较方便。不同版本的NEST驱动程序，其提供的接口变化很大，在熟悉Nest之后，可以使用Elasticsearch.Net驱动程序来编写自己的代码，免受更新之苦。

首先，下载ElastiSearch的.net客户端驱动程序，打开VS的工具（Tools）菜单，通过NuGet包管理器控制台，输入命令安装NEST：

PM> Install-Package NEST

![628084-20170315202811807-1615386129.png][]

安装之后，系统引用三个DLL文件，楼主安装的驱动程序版本分别是：

*  Elasticsearch.Net.dll （版本 5.0.0.0）
 *  Nest.dll （版本 5.0.0.0）
 *  Newtonsoft.Json.dll （版本 9.0.0.0）

**二，NEST驱动程序的简单使用**

**1，连接到ElasticSearch引擎服务器**

注意，默认索引的名称必须小写，建议将索引名，文档类型名称，和字段名称都小写。

![复制代码][copycode.gif]

using Nest;    
    public static class Setting
    {
        public static string strConnectionString=@"http://localhost:9200";
        public static Uri Node
        {
            get
            {
                return new Uri(strConnectionString);
            }
        }
        public static ConnectionSettings ConnectionSettings
        {
            get
            {
                return new ConnectionSettings(Node).DefaultIndex("default");
            }
        }
    }

![复制代码][copycode.gif]

**2，创建数据模型**

注意，模型的字段名和创建的索引映射中的字段保持一致，推荐都使用小写字母。Nest驱动程序提供了模型属性，读者可以自行尝试。

![复制代码][copycode.gif]

public class MeetupEvents
    {
        public long eventid { get; set; }
        public string orignalid { get; set; }
        public string eventname { get; set; }
        public string description { get; set; }
    }

![复制代码][copycode.gif]

**3，更新文档**

NEST提供两种更新文档的方式，逐条更新和批量更新，函数PopulateIndex用于逐条更新索引，函数BulkPopulateIndex用于批量更新索引；

注意，在更新索引时，高亮显示的代码指定了索引的元字段\_id为meetupevent实体的主键eventid；

![复制代码][copycode.gif]

using Nest;
    public class ESProvider
    {
        public static ElasticClient client = new ElasticClient(Setting.ConnectionSettings);
        public static string strIndexName = @"meetup".ToLower();
        public static string strDocType = "events".ToLower();
    
        public bool PopulateIndex(MeetupEvents meetupevent)
        {
            var index = client.Index(meetupevent,i=>i.Index(strIndexName).Type(strDocType).Id(meetupevent.eventid));
            return index.Created;
        }
    
        public bool BulkPopulateIndex(List<MeetupEvents> posts)
        {
            var bulkRequest = new BulkRequest(strIndexName,strDocType) { Operations = new List<IBulkOperation>() };   
            var idxops = posts.Select(o => new BulkIndexOperation<MeetupEvents>(o) { Id=o.eventid}).Cast<IBulkOperation>().ToList();
            bulkRequest.Operations = idxops;
            var response = client.Bulk(bulkRequest);
            return response.IsValid;
        }
    }

![复制代码][copycode.gif]

**4，执行批量更新操作**

如果更新的数据量十分庞大，建议，首先对数据源分页，分batch更新ElasticSearch的索引。ElasticSearch在批量索引文档时，如果一批文档数量过大，会导致数据丢失，建议每次索引1000个文档。

![复制代码][copycode.gif]

ESProvider es = new ESProvider();
    List<MeetupEvents> pbs = new List<MeetupEvents>();
    
    foreach (DataRow dr in MeetupEventsTable.Rows)
    {
        MeetupEvents pb = new MeetupEvents();
        pb.eventid = long.Parse(dr["EventID"].ToString());
        pb.orignalid = dr["OriginalID"].ToString();
        pb.eventname = dr["EventName"].ToString();
        pb.description = dr["Description"].ToString();
    
        pbs.Add(pb);
    }          
    es.BulkPopulateIndex(pbs);

![复制代码][copycode.gif]

**5，总结NEST驱动程序的使用**

使用以下三段代码连接NEST客户端：

var node = new Uri("http://myserver:9200");
    var settings = new ConnectionSettings(node).DefaultIndex("default");
    var client = new ElasticClient(settings);

使用客户端的Index方法更新/添加单个文档：

Client.Index(student);

使用客户端的IndexMany函数更新/添加多个文档：

var list = new List<Student>();
    client.IndexMany<Student>(list);

使用客户端的Bulk方法批量更新文档，需要根据实体列表List构造一个BulkRequest参数：

client.Bulk(bulkRequest);

参考文档：

[NEST使用指南][NEST]

[elasticsearch.net search入门使用指南中文版][elasticsearch.net search]

[.net ElasticSearch][Elasticsearch.Net and NEST_ the .NET clients _5.x_ _ Introduction]

**作者**： [悦光阴][Link 1]

**出处**： [http://www.cnblogs.com/ljhdo/][Link 1]

本文版权归作者和博客园所有，欢迎转载，但未经作者同意，必须保留此段声明，且在文章页面醒目位置显示原文连接，否则保留追究法律责任的权利。

转载于:https://www.cnblogs.com/Jeely/p/11315314.html

[ElasticSearch_ _C]: https://www.cnblogs.com/ljhdo/p/5160329.html
[ElasticSearch_ _Windows_ElasticSearch]: http://www.cnblogs.com/ljhdo/p/4887557.html
[ElasticSearch_]: http://www.cnblogs.com/ljhdo/p/4959412.html
[ElasticSearch_ 1]: http://www.cnblogs.com/ljhdo/p/4981928.html
[ElasticSearch_ _C 1]: http://www.cnblogs.com/ljhdo/p/5160329.html
[ElasticSearch_ _C 2]: http://www.cnblogs.com/ljhdo/p/4550135.html
[ElasticSearch_ 2]: http://www.cnblogs.com/ljhdo/p/4904430.html
[ElasticSearch_ 3]: http://www.cnblogs.com/ljhdo/p/5012510.html
[ElasticSearch_ 4]: http://www.cnblogs.com/ljhdo/p/5016852.html
[ElasticSearch_ 5]: http://www.cnblogs.com/ljhdo/p/4911878.html
[Elasticsearch.Net and NEST_ the .NET clients _5.x_ _ Introduction]: https://www.elastic.co/guide/en/elasticsearch/client/net-api/5.x/introduction.html
[628084-20170315202811807-1615386129.png]: /images/20230601/ef9fc9eea6144f0babe0d2f9764e35f4.png
[copycode.gif]: /images/20230601/d13fdba78d88466287e7891a3beec09f.png
[NEST]: http://edu.dmeiyang.com/book/nestusing.html
[elasticsearch.net search]: http://www.51xuediannao.com/c_asp_net/elasticsearch_net.html
[Link 1]: http://www.cnblogs.com/ljhdo/