[ElasticSearch]Java API 之索引文档 (Index API)-低调大师

[ElasticSearch]Java API 之索引文档 (Index API)

2016-10-12 591

Index API 允许我们存储一个JSON格式的文档，使数据可以被搜索。文档通过index、type、id唯一确定。我们可以自己提供一个id，或者也使用Index API 为我们自动生成一个。

这里有几种不同的方式来产生JSON格式的文档(document)：

（1）手动方式，使用原生的byte[]或者String

（2）使用Map方式，会自动转换成与之等价的JSON

（3）使用第三方库来序列化beans，如Jackson

（4）使用内置的帮助类 XContentFactory.jsonBuilder()

1. 手动方式

/**
* 手动方式产生JSON 索引文档
* @param client
* @param index
* @param type
* @param id
* @param json
*/
public static boolean indexDocByJSON(Client client, String index, String type, String id, String json) {
// Index
IndexRequestBuilder indexRequestBuilder = client.prepareIndex();
indexRequestBuilder.setIndex(index);
indexRequestBuilder.setType(type);
indexRequestBuilder.setId(id);
indexRequestBuilder.setSource(json);
indexRequestBuilder.setTTL(8000);
// 执行
IndexResponse indexResponse = indexRequestBuilder.get();
return indexResponse.isCreated();
}

测试，下面代码存储梅西信息到索引为football-index，类型为football-type，id为1的文档中：

@Test
public void indexDocByJSON() throws Exception {
String index = "football-index";
String type = "football-type";
String id = "1";
String json = "{" +
"\"club\":\"巴萨罗那\"," +
"\"country\":\"阿根廷\"," +
"\"name\":\"梅西\"" +
"}";
boolean result = IndexDocAPI.indexDocByJSON(client, index, type , id, json);
logger.info("--------- indexDocByJSON {}", result);
}

2. Map方式

/**
* 使用Map 产生JSON 索引文档
* @param client
* @param index
* @param type
* @param id
*/
public static boolean indexDocByMap(Client client, String index, String type, String id, Map<String, Object> map) {
// Index
IndexRequestBuilder indexRequestBuilder = client.prepareIndex();
indexRequestBuilder.setIndex(index);
indexRequestBuilder.setType(type);
indexRequestBuilder.setId(id);
indexRequestBuilder.setSource(map);
indexRequestBuilder.setTTL(8000);
// 执行
IndexResponse indexResponse = indexRequestBuilder.get();
return indexResponse.isCreated();
}

测试，下面代码存储穆勒信息到索引为football-index，类型为football-type，id为2的文档中：

@Test
public void indexDocByMap() throws Exception {
String index = "football-index";
String type = "football-type";
String id = "2";
Map<String, Object> map = Maps.newHashMap();
map.put("name", "穆勒");
map.put("club", "拜仁慕尼黑俱乐部");
map.put("country", "德国");
boolean result = IndexDocAPI.indexDocByMap(client, index, type , id, map);
logger.info("--------- indexDocByMap {}", result);
}

3. 序列化方式

/**
* 利用Json序列化产生JSON 索引文档
*
* @param client
* @param index
* @param type
* @param id
*/
public static boolean indexDocByBean(Client client, String index, String type, String id, Object bean) {
// Bean转换为字节
ObjectMapper mapper = new ObjectMapper();
byte[] json;
try {
json = mapper.writeValueAsBytes(bean);
} catch (JsonProcessingException e) {
logger.error("---------- json 转换失败 Bean:{}", bean.toString());
return false;
}
// Index
IndexRequestBuilder indexRequestBuilder = client.prepareIndex();
indexRequestBuilder.setIndex(index);
indexRequestBuilder.setType(type);
indexRequestBuilder.setId(id);
indexRequestBuilder.setSource(json);
indexRequestBuilder.setTTL(8000);
// 执行
IndexResponse response = indexRequestBuilder.get();
return response.isCreated();
}

测试，下面代码存储卡卡信息到索引为football-index，类型为football-type，id为3的文档中：

@Test
public void indexDocByBean() throws Exception {
String index = "football-index";
String type = "football-type";
String id = "3";
FootballPlayer footballPlayer = new FootballPlayer();
footballPlayer.setName("卡卡");
footballPlayer.setClub("奥兰多城俱乐部");
footballPlayer.setCountry("巴西");
boolean result = IndexDocAPI.indexDocByBean(client, index, type , id, footballPlayer);
logger.info("--------- indexDocByBean {}", result);
}

4. XContentBuilder帮助类方式

ElasticSearch提供了一个内置的帮助类XContentBuilder来产生JSON文档

/**
* 使用帮助类XContentBuilder 产生JSON 索引文档
* @param client
* @param index
* @param type
* @param id
* @param xContentBuilder
* @return
*/
public static boolean indexDocByXContentBuilder(Client client, String index, String type, String id, XContentBuilder xContentBuilder) {
// Index
IndexRequestBuilder indexRequestBuilder = client.prepareIndex();
indexRequestBuilder.setIndex(index);
indexRequestBuilder.setType(type);
indexRequestBuilder.setId(id);
indexRequestBuilder.setSource(xContentBuilder);
indexRequestBuilder.setTTL(8000);
// 执行
IndexResponse response = indexRequestBuilder.get();
return response.isCreated();
}

测试，下面代码存储托雷斯信息到索引为football-index，类型为football-type，id为4的文档中：

@Test
public void indexDocByXContentBuilder() throws Exception {
String index = "football-index";
String type = "football-type";
String id = "4";
XContentBuilder xContentBuilder;
try {
xContentBuilder = XContentFactory.jsonBuilder();
xContentBuilder
.startObject()
.field("name", "托雷斯")
.field("club", "马德里竞技俱乐部")
.field("country", "西班牙")
.endObject();
} catch (IOException e) {
logger.error("----------indexDocByXContentBuilder create xContentBuilder failed", e);
return;
}
boolean result = IndexDocAPI.indexDocByXContentBuilder(client, index, type, id, xContentBuilder);
logger.info("--------- indexDocByXContentBuilder result {}", result);
}

备注：

你还可以通过startArray(string)和endArray()方法添加数组。.field()方法可以接受多种对象类型。你可以给它传递数字、日期、甚至其他XContentBuilder对象。

参考：https://www.elastic.co/guide/en/elasticsearch/client/java-api/current/java-docs-index.html#java-docs-index-generate

微信关注我们

原文链接：https://yq.aliyun.com/articles/632234

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

Yarn application has already exited with state FINISHED

如果在运行spark-sql时遇到如下这样的错误，可能是因为yarn-site.xml中的配置项 yarn.nodemanager.vmem-pmem-ratio值偏小，它的默认值为2.1，可以尝试改大一点再试。 ERRORcluster.YarnClientSchedulerBackend:YarnapplicationhasalreadyexitedwithstateFINISHED! 16/10/1310:23:19ERRORclient.TransportClient:FailedtosendRPC7614640087981520382to/10.143.136.231:34800:java.nio.channels.ClosedChannelException java.nio.channels.ClosedChannelException 16/10/1310:23:19ERRORcluster.YarnSchedulerBackend$YarnSchedulerEndpoint:SendingRequestExecutors(0,0,Map())toAMwasun...

2016-10-13

563

阿里云E-Mapreduce动态 E-Mapreduce团队 1.6.0版本交互式查询（支持hive、spark）资讯阿里、Databricks、Intel的十位专家和你细聊Hadoop技术实践及生态2016年10月16日云栖小镇 D5厅不见不散大数据领域开源技术除了Hadoop你还知道哪些众所周知，大数据正在以惊人的速度增长，几乎触及各行各业，许多组织都被迫寻找新的创造性方法来管理和控制如此庞大的数据，当然这么做的目的不只是管理和控制数据，而是要分析和挖掘其中的价值，来促进业务的发展我们该如何看待空间大数据的未来？4D数据是测绘地理信息人的全部吗?答案不应该是肯定的。过去，我们对传统地信企业和部门，尤其是诸如测绘院等传统机构的印象，多停留在地理国情普查等庞大的职能上，我们认为他们应该把握最全面和精确的数据，那么除此之外呢大数据

2016-10-13

673

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。