热门搜索:
您现在的位置是：首页 > 文章详情

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

日期：2014-01-15点击：581

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

 

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

对于一个数据库开发，很久没有写过C#代码，dot net菜鸟一个，本文简单分享了使用ElasticSearch的.net客户端驱动程序向索引中添加文档的代码片段，详细信息，请参考官方手册：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

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

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

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

1，连接到ElasticSearch引擎服务器

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

复制代码 
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"); } } }
复制代码

2，创建数据模型

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

复制代码 
public class MeetupEvents { public long eventid { get; set; } public string orignalid { get; set; } public string eventname { get; set; } public string description { get; set; } }
复制代码

3，更新文档

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

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

复制代码 
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; } }
复制代码

4，执行批量更新操作

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

复制代码 
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);
复制代码

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使用指南

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

.net ElasticSearch







本文转自悦光阴博客园博客，原文链接：http://www.cnblogs.com/ljhdo/p/5160329.html，如需转载请自行联系原作者

原文链接：https://yq.aliyun.com/articles/386212
关注公众号

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。

持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

转载内容版权归作者及来源网站所有，本站原创内容转载请注明来源。

相关文章

    文章评论

    共有0条评论来说两句吧...

    文章二维码

    扫描即可查看该文章

    点击排行

    推荐阅读

    最新文章