elasticsearch6.2.4 DSL java API 插入和获取数据

elasticsearch6.2.4 DSL java API 插入和获取数据

创建MAVEN项目,maven依赖如下:

<dependency>
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
<version>6.2.4</version>
</dependency>

<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>transport</artifactId>
<version>6.2.4</version>
</dependency>


查询方式如下:

RestClient restClient = RestClient.builder(new HttpHost("192.168.43.22", 9200, "http")).build();
System.out.println(123);
Map<String,String> params = new HashMap<String, String>();

HttpEntity entity = new NStringEntity("{\"query\":{\"bool\":{\"must\":[{\"term\":{\"host.keyword\":\"media-for-the-masses.theacademyofperformingartsandscience.org\"}}],\"must_not\":[],\"should\":[]}},\"from\":0,\"size\":10,\"sort\":[],\"aggs\":{}}",
ContentType.APPLICATION_JSON);

Response response = restClient.performRequest("GET", "/logstash-2015.05.20/_search", params, entity);
System.out.println(EntityUtils.toString(response.getEntity()));
logstash-2015.05.20为索引名称,json为DSL查询json语句,可在head中验证后直接查询


  • 发表于 2018-09-27 17:41
  • 阅读 ( 242 )
  • 分类:大数据

0 条评论

请先 登录 后评论
不写代码的码农
张鹏

大数据工程师

95 篇文章

作家榜 »

  1. 张鹏 95 文章
  2. 0 文章
  3. 赵科 0 文章
  4. 王孖珺397954227 0 文章