RestHighLevelClient操作Elasticsearch 7.10

Stella981
• 阅读 357

很多时候需要利用java api读取Elasticsearch. 目前官方首推的是RestHighLevelClient. 所以可以尝试使用这个客户端进行简单的语句生成和操作.

首先在Maven的pom中添加dependency

<dependency>
   <groupId>org.elasticsearch.client</groupId>
   <artifactId>elasticsearch-rest-high-level-client</artifactId>
   <version>7.10.1</version>
</dependency>

之后, 在java中可以直接写入一下代码. 创建client,指定2个端口,具体原因不知道.但是官方文档中有参考.

我才用的是 boolQueryBuilder,生成2个filter的效果. 做了范围查询和关键词匹配. filter不需要计算成绩,性能好点.

设置了fetchSource,这样只会include指定的field,减少返回数据.

rangeQuery可以用于数值和时间段查询

RestHighLevelClient client = new RestHighLevelClient(RestClient
        .builder(new HttpHost("localhost", 9200, "http"), new HttpHost("localhost", 9201, "http")));
    SearchRequest searchRequest = new SearchRequest("all_indices");
    SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
    searchSourceBuilder.fetchSource(new String[] {"date_search", "message"}, new String[] {});
    // searchSourceBuilder.from(0).size(1);
    BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
    boolQueryBuilder.filter(QueryBuilders.termQuery("tags", "exception_text"));
    boolQueryBuilder.filter(QueryBuilders.rangeQuery("date_search").gte("now-1d/d").lte("now/d"));

    searchSourceBuilder.query(boolQueryBuilder);
    searchRequest.source(searchSourceBuilder);
    try {
      SearchResponse rp = client.search(searchRequest, RequestOptions.DEFAULT);
      SearchHits hits = rp.getHits();

      hits.forEach(test -> {
       Map<String, Object> sourceAsMap = test.getSourceAsMap();
       String message = (String) sourceAsMap.get("message");
      });
      
      client.close();
      client = null;
    } catch (IOException e) {
      e.printStackTrace();
    }

最后生成的dsl类似:

{
    "query": {
        "bool": {
            "filter": [
                {
                    "term": {
                        "tags": {
                            "value": "exception_text", 
                            "boost": 1
                        }
                    }
                }, 
                {
                    "range": {
                        "date_search": {
                            "from": "now-1d/d", 
                            "to": "now/d", 
                            "include_lower": true, 
                            "include_upper": true, 
                            "boost": 1
                        }
                    }
                }
            ], 
            "adjust_pure_negative": true, 
            "boost": 1
        }
    }, 
    "_source": {
        "includes": [
            "date_search", 
            "message"
        ], 
        "excludes": [ ]
    }
}
点赞
收藏
评论区
推荐文章
浅梦一笑 浅梦一笑
2个月前
初学 Python 需要安装哪些软件?超级实用,小白必看!
编程这个东西是真的奇妙。对于懂得的人来说,会觉得这个工具是多么的好用、有趣,而对于小白来说,就如同大山一样。其实这个都可以理解,大家都是这样过来的。那么接下来就说一下python相关的东西吧,并说一下我对编程的理解。本人也是小白一名,如有不对的地方,还请各位大神指出01名词解释:如果在编程方面接触的比较少,那么对于软件这一块,有几个名词一定要了解,比如开发环
技术小男生 技术小男生
2个月前
linux环境jdk环境变量配置
1:编辑系统配置文件vi /etc/profile2:按字母键i进入编辑模式,在最底部添加内容: JAVAHOME/opt/jdk1.8.0152 CLASSPATH.:$JAVAHOME/lib/dt.jar:$JAVAHOME/lib/tools.jar PATH$JAVAHOME/bin:$PATH3:生效配置
光头强的博客 光头强的博客
2个月前
Java面向对象试题
1、 请创建一个Animal动物类,要求有方法eat()方法,方法输出一条语句“吃东西”。 创建一个接口A,接口里有一个抽象方法fly()。创建一个Bird类继承Animal类并实现 接口A里的方法输出一条有语句“鸟儿飞翔”,重写eat()方法输出一条语句“鸟儿 吃虫”。在Test类中向上转型创建b对象,调用eat方法。然后向下转型调用eat()方
刚刚好 刚刚好
2个月前
css问题
1、 在IOS中图片不显示(给图片加了圆角或者img没有父级) <div<img src""/</div div {width: 20px; height: 20px; borderradius: 20px; overflow: h
blmius blmius
1年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录 问题 用navicat导入数据时,报错: 原因这是因为当前的MySQL不支持datetime为0的情况。 解决修改sql\mode: sql\mode:SQL Mode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。 全局s
晴空闲云 晴空闲云
2个月前
css中box-sizing解放盒子实际宽高计算
我们知道传统的盒子模型,如果增加内边距padding和边框border,那么会撑大整个盒子,造成盒子的宽度不好计算,在实务中特别不方便。boxsizing可以设置盒模型的方式,可以很好的设置固定宽高的盒模型。 盒子宽高计算假如我们设置如下盒子:宽度和高度均为200px,那么这会这个盒子实际的宽高就都是200px。但是当我们设置这个盒子的边框和内间距的时候,那
艾木酱 艾木酱
1个月前
快速入门|使用MemFire Cloud构建React Native应用程序
> MemFire Cloud是一款提供云数据库,用户可以创建云数据库,并对数据库进行管理,还可以对数据库进行备份操作。它还提供后端即服务,用户可以在1分钟内新建一个应用,使用自动生成的API和SDK,访问云数据库、对象存储、用户认证与授权等功能,可专
Easter79 Easter79
1年前
Twitter的分布式自增ID算法snowflake (Java版)
概述 == 分布式系统中,有一些需要使用全局唯一ID的场景,这种时候为了防止ID冲突可以使用36位的UUID,但是UUID有一些缺点,首先他相对比较长,另外UUID一般是无序的。 有些时候我们希望能使用一种简单一些的ID,并且希望ID能够按照时间有序生成。 而twitter的snowflake解决了这种需求,最初Twitter把存储系统从MySQL迁移
helloworld_34035044 helloworld_34035044
4个月前
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。 uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid() 或 uuid(sep)参数说明:sep 布尔值,生成的uuid中是否包含分隔符'',缺省为
helloworld_28799839 helloworld_28799839
2个月前
常用知识整理
# Javascript ## 判断对象是否为空 ```js Object.keys(myObject).length === 0 ``` ## 经常使用的三元运算 > 我们经常遇到处理表格列状态字段如 `status` 的时候可以用到 ``` vue