草庐IT

ES-API开发常用功能

大脸猫- 2023-04-12 原文

ES-API开发常用功能

创建索引

1.创建索引的索引名称必须为小写，大写会报错。
2.当没有为创建的索引指定Mapping时，es会为索引指定默认的Mapping（eg：字符串默认给keyword）。当查询的时候发现查不到，就有可能是忘记设置Mapping导致类型不对，无法进行分词检索。
3.当索引需要使用别名查询或者删除时，在创建索引的时候要为索引起别名。

es.addAlias([索引名], [别名]);

插入索引

1.将list插入索引中，使用现有框架的方法异步插入即可，注意数据类型的正确性（eg：数值类型的字段如果写成keyword将不能区间查询）。

查询索引

通过KQL进行查询

GET /temp.alias/_search
{
  "query": {
    "bool": {
      "must": [
        {
          "term": {
            "projName": {
              "value": "帅气"
            }
          }
        }
      ]
    }
  }
}

通过ES的Java-API对索引文档进行条件查询

1.首先创建搜索请求对象SearchRequest

SearchRequest searchRequest = new SearchRequest(TEMP_ALIAS);

2.创建BoolQueryBuilder对象，进行筛选条件填充（类似于sql的where的条件查询must[and]should[or]）。BoolQueryBuilder可以多次定义，嵌套使用。

BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();

3.创建SearchSourceBuilder查询对象，并进行查询

SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
sourceBuilder.query(boolQueryBuilder);

4.分页（类似于mysql的limit）

sourceBuilder.from((page - 1) * pageSize).size(pageSize);

5.排序（类似于sql的order by）

sourceBuilder.sort(orderColumn, SortOrder.ASC);

6.设置查询的超时时间

sourceBuilder.timeout(new TimeValue(10, TimeUnit.SECONDS));

7.set进搜索请求对象

searchRequest.source(sourceBuilder);

8.发起请求进行搜索

SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
部分响应字段：
RestStatus status = searchResponse.status();//响应状态
TimeValue took = searchResponse.getTook();//查询时间
Boolean terminatedEarly = searchResponse.isTerminatedEarly();//请求是否提前终止
boolean timedOut = searchResponse.isTimedOut();//是否超时
response.getHits().totalHits;//命中次数

9.以Json-String或者map的形式获得查询结果。

String sourceAsString = hit.getSourceAsString();
Map<String, Object> sourceAsMap = hit.getSourceAsMap();

一般用法

//声明接收结果的集合
List<TempDto> tempList = new ArrayList<>();
//遍历结果
Arrays.stream(response.getHits().getHits()).forEach(i -> {
	try {
		//通过jackson的ObjectMapper转化为对象
		TempDtoDoc d = new ObjectMapper().readValue(i.getSourceAsString(),TempDtoDoc.class);
		TempDto temp= new TempDto();
		BeanUtils.copyProperties(d, temp);
		//add到我们需要的list中
		tempList.add(temp);
	} catch (IOException e) {
		logger.error(e.getMessage());
	}
});

推荐

在代码调试的过程中发现代码查不到数据，可以在拼接好查询条件后search之前打断点，拿到sourceBuilder的Json串，放到Kibana界面进行查询，寻找原因，这样可以更加直观的看到各个条件之间的逻辑关系。

用功ES-APIquotgtlt

有关ES-API开发常用功能的更多相关文章

  1. ruby - 使用 C 扩展开发 ruby​​gem 时，如何使用 Rspec 在本地进行测试？ - 2

    我正在编写一个包含C扩展的gem。通常当我写一个gem时，我会遵循TDD的过程，我会写一个失败的规范，然后处理代码直到它通过，等等......在“ext/mygem/mygem.c”中我的C扩展和在gemspec的“扩展”中配置的有效extconf.rb，如何运行我的规范并仍然加载我的C扩展？当我更改C代码时，我需要采取哪些步骤来重新编译代码？这可能是个愚蠢的问题，但是从我的gem的开发源代码树中输入“bundleinstall”不会构建任何native扩展。当我手动运行rubyext/mygem/extconf.rb时，我确实得到了一个Makefile(在整个项目的根目录中)，然后当

  2. Ruby Sinatra 配置用于生产和开发 - 2

    我已经在Sinatra上创建了应用程序，它代表了一个简单的API。我想在生产和开发上进行部署。我想在部署时选择，是开发还是生产，一些方法的逻辑应该改变，这取决于部署类型。是否有任何想法，如何完成以及解决此问题的一些示例。例子:我有代码get'/api/test'doreturn"Itisdev"end但是在部署到生产环境之后我想在运行/api/test之后看到ItisPROD如何实现？ 最佳答案 根据SinatraDocumentation:EnvironmentscanbesetthroughtheRACK_ENVenvironm

  3. ruby-on-rails - ActionController::RoutingError: 未初始化常量 Api::V1::ApiController - 2

    我有用于控制用户任务的Rails5API项目，我有以下错误，但并非总是针对相同的Controller和路由。ActionController::RoutingError:uninitializedconstantApi::V1::ApiController我向您描述了一些我的项目，以更详细地解释错误。应用结构路线scopemodule:'api'donamespace:v1do#=>Loginroutesscopemodule:'login'domatch'login',to:'sessions#login',as:'login',via::postend#=>Teamroutessc

  4. ruby - 是否可以覆盖 gemfile 进行本地开发？ - 2

    我们的git存储库中目前有一个Gemfile。但是，有一个gem我只在我的环境中本地使用(我的团队不使用它)。为了使用它，我必须将它添加到我们的Gemfile中，但每次我checkout到我们的master/dev主分支时，由于与跟踪的gemfile冲突，我必须删除它。我想要的是类似Gemfile.local的东西，它将继承从Gemfile导入的gems，但也允许在那里导入新的gems以供使用只有我的机器。此文件将在.gitignore中被忽略。这可能吗？ 最佳答案 设置BUNDLE_GEMFILE环境变量:BUNDLE_GEMFI

  5. ruby - 在 Windows 机器上使用 Ruby 进行开发是否会适得其反？ - 2

    这似乎非常适得其反，因为太多的gem会在window上破裂。我一直在处理很多mysql和ruby​​-mysqlgem问题(gem本身发生段错误，一个名为UnixSocket的类显然在Windows机器上不能正常工作，等等)。我只是在浪费时间吗？我应该转向不同的脚本语言吗？ 最佳答案 我在Windows上使用Ruby的经验很少，但是当我开始使用Ruby时，我是在Windows上，我的总体印象是它不是Windows原生系统。因此，在主要使用Windows多年之后，开始使用Ruby促使我切换回原来的系统Unix，这次是Linux。Rub

  6. ruby-on-rails - 在 Rails 开发环境中为 .ogv 文件设置 Mime 类型 - 2

    我正在玩HTML5视频并且在ERB中有以下片段:mp4视频从在我的开发环境中运行的服务器很好地流式传输到chrome。然而firefox显示带有海报图像的视频播放器，但带有一个大X。问题似乎是mongrel不确定ogv扩展的mime类型，并且只返回text/plain，如curl所示:$curl-Ihttp://0.0.0.0:3000/pr6.ogvHTTP/1.1200OKConnection:closeDate:Mon,19Apr201012:33:50GMTLast-Modified:Sun,18Apr201012:46:07GMTContent-Type:text/plain

  7. 世界前沿3D开发引擎HOOPS全面讲解——集3D数据读取、3D图形渲染、3D数据发布于一体的全新3D应用开发工具 - 2

    无论您是想搭建桌面端、WEB端或者移动端APP应用，HOOPSPlatform组件都可以为您提供弹性的3D集成架构，同时，由工业领域3D技术专家组成的HOOPS技术团队也能为您提供技术支持服务。如果您的客户期望有一种在多个平台（桌面/WEB/APP，而且某些客户端是“瘦”客户端）快速、方便地将数据接入到3D应用系统的解决方案，并且当访问数据时，在各个平台上的性能和用户体验保持一致，HOOPSPlatform将帮助您完成。利用HOOPSPlatform，您可以开发在任何环境下的3D基础应用架构。HOOPSPlatform可以帮您打造3D创新型产品，HOOPSSDK包含的技术有：快速且准确的CAD

  8. 【鸿蒙应用开发系列】- 获取系统设备信息以及版本API兼容调用方式 - 2

    在应用开发中，有时候我们需要获取系统的设备信息，用于数据上报和行为分析。那在鸿蒙系统中，我们应该怎么去获取设备的系统信息呢，比如说获取手机的系统版本号、手机的制造商、手机型号等数据。1、获取方式这里分为两种情况，一种是设备信息的获取，一种是系统信息的获取。1.1、获取设备信息获取设备信息，鸿蒙的SDK包为我们提供了DeviceInfo类，通过该类的一些静态方法，可以获取设备信息，DeviceInfo类的包路径为：ohos.system.DeviceInfo.具体的方法如下：ModifierandTypeMethodDescriptionstatic StringgetAbiList​()Obt

  9. 使用canal同步MySQL数据到ES - 2

    文章目录一、概述简介原理模块二、配置Mysql使用版本环境要求1.操作系统2.mysql要求三、配置canal-server离线下载在线下载上传解压修改配置单机配置集群配置分库分表配置1.修改全局配置2.实例配置垂直分库水平分库3.修改group-instance.xml4.启动监听四、配置canal-adapter1修改启动配置2配置映射文件3启动ES数据同步查询所有订阅同步数据同步开关启动4.验证五、配置canal-admin一、概述简介canal是Alibaba旗下的一款开源项目，Java开发。基于数据库增量日志解析，提供增量数据订阅&消费。Git地址：https://github.co

  10. ruby-on-rails - Mandrill API 模板 - 2

    我正在使用Mandrill的RubyAPIGem并使用以下简单的测试模板:testastic按照Heroku指南中的示例，我有以下Ruby代码:require'mandrill'm=Mandrill::API.newrendered=m.templates.render'test-template',[{:header=>'someheadertext',:main_section=>'Themaincontentblock',:footer=>'asdf'}]mail(:to=>"JaysonLane",:subject=>"TestEmail")do|format|format.h

随机推荐