ElasticSearch索引操作

本文使用DSL操作ES，SpringBoot操作ES
更多ElasticSearch入门到实战教程：点击查看

2.1 索引操作

ES索引是存储数据的容器，类似于数据库。

2.1.1 创建索引

1. DSL语法

PUT indexname
{"settings": {"number_of_shards": 1,"number_of_replicas": 1},"mappings": {"properties": {"name1":{"type": "text"},"name2":{"type": "integer"}}}
}
1. 参数说明：

settings：索引信息设置

number_of_shards：每个索引的主分片数，这个配置在索引创建后不能修改

number_of_replicas：每个主分片的副本数，这个配置可以随时修改。

  • 什么是分片？

Elasticsearch集群允许系统存储的数据量超过单机容量，这是通过shard实现的。在一个索引index中，数据（document）被分片处理（sharding）到多个分片上。也就是说：每个分片都保存了全部数据中的一部分。
一个分片是一个 Lucene 的实例，它本身就是一个完整的搜索引擎。文档被存储到分片内，但应用程序直接与索引而不是与分片进行交互。

  • 什么是副本？

为了解决访问压力过大时单机无法处理所有请求的问题，Elasticsearch集群引入了副本策略replica。副本策略对index中的每个分片创建冗余的副本。

  • 副本的作用如下：

  1. 提高系统容错性
    当分片所在的机器宕机时，Elasticsearch可以使用其副本进行恢复，从而避免数据丢失。

  2. 提高ES查询效率
    处理查询时，ES会把副本分片和主分片公平对待，将查询请求负载均衡到副本分片和主分片。

mappings：索引映射定义

properties：字段定义
properties里是json配置，key为字段名称（自定义名称），value是个嵌套json，type是指定字段的类型。

2. Java API

在第一章已经介绍过一些创建索引的代码了

    //从Spring容器获取client对象@Autowiredprivate RestHighLevelClient client;public Boolean createIndex(String indexName) {//创建索引请求类，构造函数参数为索引名称CreateIndexRequest request = new CreateIndexRequest(indexName);//设置source映射字符串，直接把语句复制里面request.source("{\n" +"  \"settings\": {\n" +"    \"number_of_shards\": 1,\n" +"    \"number_of_replicas\": 1\n" +"  },\n" +"  \"mappings\": {\n" +"    \"properties\": {\n" +"      \"name1\":{\n" +"         \"type\": \"text\"\n" +"      },\n" +"      \"name2\":{\n" +"        \"type\": \"integer\"\n" +"      }\n" +"    }\n" +"  }\n" +"}",XContentType.JSON);try {//调用创建索引语法client.indices().create(request, RequestOptions.DEFAULT);return true;} catch (IOException e) {e.printStackTrace();}return false;}

注意这里调用的方法是source，不是mapping

mapping方法是仅设置字段

source方法是带上settings内容一块调用的

2.1.2 删除索引

1. DSL语法

DELETE indexname

调用执行，以下返回结果为成功

{ - "acknowledged": true
}

2. Java API

    //从Spring容器获取client对象@Autowiredprivate RestHighLevelClient client;@RequestMapping("/deleteIndex")public Boolean deleteIndex(String indexName) {//删除索引请求类，构造函数参数为索引名称DeleteIndexRequest deleteIndexRequest = new DeleteIndexRequest(indexName);try {//调用删除索引语法client.indices().delete(deleteIndexRequest, RequestOptions.DEFAULT);return true;} catch (IOException e) {e.printStackTrace();}return false;}

2.1.3 开启/关闭索引

什么是 Elasticsearch 打开/关闭索引？

一旦索引被关闭，那么这个索引只能显示元数据信息，不能够进行读写操作。
再说说打开索引就好理解了。就是打开被关闭的索引，允许进行读写操作。

1. 关闭索引

1. DSL语法
POST indexname/_close

调用执行，以下返回结果为成功

{ - "acknowledged": true,"shards_acknowledged": true,"indices": { - "indexname": { - "closed": true}}
}
2. Java API
    @RequestMapping("/closeIndex")public Boolean closeIndex(String indexName) {CloseIndexRequest closeIndexRequest = new CloseIndexRequest(indexName);try {client.indices().close(closeIndexRequest, RequestOptions.DEFAULT);} catch (IOException e) {e.printStackTrace();}return true;}

2. 开启索引

1. DSL语法
POST indexname/_open

调用执行，以下返回结果为成功

{ - "acknowledged": true,"shards_acknowledged": true
}
2. Java API
    @RequestMapping("/openIndex")public Boolean openIndex(String indexName) {OpenIndexRequest openIndexRequest = new OpenIndexRequest(indexName);try {client.indices().open(openIndexRequest, RequestOptions.DEFAULT);} catch (IOException e) {e.printStackTrace();}return true;}

2.1.4 索引别名

索引别名概述：

在ES中，索引别名（index aliases）就像一个快捷方式或软连接，可以指向一个或多个索引。
别名有什么用？

  1. 给多个索引设置一个别名，可以使用这个别名同时查询多个索引的数据。

  2. 例如一个项目场景，每天要建立一个新的索引，程序要查询新的索引数据，程序必然要改变访问的索引名称，如果实现用户无感知切换，那么代码复杂度较高，很容易会对服务的使用者产生一定的影响，过程越复杂，BUG就越容易出现。
    那么有了别名后，可以一开始就给索引加上这个别名，程序只关注访问这个别名，建立新索引后，把别名切换到新索引，程序不用变更，但是后续访问到了新的索引，并且无需停止应用的运行。当然这只是一个场景，在项目开发中，别名还有很多的用途，在后续项目讲解中我们会更多的介绍索引。

字段也有别名，使用率不太高，这里不过多讲解

1. 添加别名

创建索引别名，将别名indexname_alias与索引indexname关联

1. DSL语法
  1. 请求方式1
PUT indexname/_alias/indexname_alias
  1. 请求方式2
POST _aliases
{"actions": [{"add": {"index": "indexname","alias": "indexname_alias"}}]
}
2. Java API语法
    @Autowiredprivate RestHighLevelClient client;@RequestMapping("/addAlias")public Boolean addAlias(String indexName, String aliasName) {IndicesAliasesRequest indicesAliasesRequest = new IndicesAliasesRequest();IndicesAliasesRequest.AliasActions aliasActions = new IndicesAliasesRequest.AliasActions(IndicesAliasesRequest.AliasActions.Type.ADD);aliasActions.index(indexName).alias(aliasName);indicesAliasesRequest.addAliasAction(aliasActions);try {client.indices().updateAliases(indicesAliasesRequest, RequestOptions.DEFAULT);} catch (IOException e) {e.printStackTrace();}return true;}

接口接收两个参数，indexName：索引名，aliasName：要增加的别名

打开地址调用接口
http://localhost:8080/addAlias?indexName=indexname&aliasName=indexname_alias

2. 删除别名

删除索引别名：解除别名indexname_alias与索引indexname的关联

1. DSL语法
  1. 请求方式1
DELETE indexname/_alias/indexname_alias
  1. 请求方式2
POST _aliases
{"actions": [{"remove": {"index": "indexname","alias": "indexname_alias"}}]
}
2. Java API语法
    @Autowiredprivate RestHighLevelClient client;@RequestMapping("/removeAlias")public Boolean removeAlias(String indexName, String aliasName) {IndicesAliasesRequest indicesAliasesRequest = new IndicesAliasesRequest();IndicesAliasesRequest.AliasActions aliasActions = new IndicesAliasesRequest.AliasActions(IndicesAliasesRequest.AliasActions.Type.REMOVE);aliasActions.index(indexName).alias(aliasName);indicesAliasesRequest.addAliasAction(aliasActions);try {client.indices().updateAliases(indicesAliasesRequest, RequestOptions.DEFAULT);} catch (IOException e) {e.printStackTrace();}return true;}

和增加一样，接口接收两个参数，indexName：索引名，aliasName：要增加的别名

打开地址调用接口
http://localhost:8080/removeAlias?indexName=indexname&aliasName=indexname_alias

3. 切换别名

切换一个别名是在同一个API中执行添加、删除操作。这个操作是原子的，不用担心别名不指向索引的短时间。

请读者自行创建两个索引 indexname1 和 indexname2，为了防止没必要的出错，请先给indexname2加上别名。

1. DSL语法
POST _aliases
{"actions": [{"add": {"index": "indexname1","alias": "indexname_alias"}},{"remove": {"index": "indexname2","alias": "indexname_alias"}}]
}
2. Java API语法
    @Autowiredprivate RestHighLevelClient client;@RequestMapping("/removeAlias")public Boolean removeAlias(String indexName, String aliasName) {IndicesAliasesRequest indicesAliasesRequest = new IndicesAliasesRequest();IndicesAliasesRequest.AliasActions aliasActions = new IndicesAliasesRequest.AliasActions(IndicesAliasesRequest.AliasActions.Type.REMOVE);aliasActions.index(indexName).alias(aliasName);indicesAliasesRequest.addAliasAction(aliasActions);try {client.indices().updateAliases(indicesAliasesRequest, RequestOptions.DEFAULT);} catch (IOException e) {e.printStackTrace();}return true;}

打开地址调用接口
http://localhost:8080/changeAlias

4. 查看别名

1. DSL语法
  1. 通过别名查询索引
GET _alias/indexname_alias

根据返回结果所示，indexname 索引下有这个别名

{ - "indexname": { - "aliases": { - "indexname_alias": { - }}}
}
  1. 通过索引查询别名
GET indexname/_alias
  1. 查看别名是否存在索引中
GET indexname/_alias/indexname_alias
2. Java API语法
  1. 通过别名查询索引
    @Autowiredprivate RestHighLevelClient client;@RequestMapping("/selectIndexByAlias")public Map selectIndexByAlias(String aliasName) {GetAliasesRequest getAliasesRequest = new GetAliasesRequest(aliasName);// 指定查看某一个索引的别名 不指定，则会搜索所有的别名getAliasesRequest.indices();try {GetAliasesResponse response = client.indices().getAlias(getAliasesRequest,RequestOptions.DEFAULT);Map<String, Set<AliasMetadata>> aliases;aliases = response.getAliases();return aliases;} catch (IOException e) {e.printStackTrace();}return null;}

打开地址调用接口，页面出现返回结果
http://localhost:8080/selectIndexByAlias?aliasName=indexname_alias

  1. 通过索引查询别名
    @Autowiredprivate RestHighLevelClient client;@RequestMapping("/selectIndexByAlias")public Map selectIndexByAlias(String aliasName) {GetAliasesRequest getAliasesRequest = new GetAliasesRequest();// 指定查看某一个索引的别名 不指定，则会搜索所有的别名getAliasesRequest.indices(indexName);try {GetAliasesResponse response = client.indices().getAlias(getAliasesRequest,RequestOptions.DEFAULT);Map<String, Set<AliasMetadata>> aliases;aliases = response.getAliases();return aliases;} catch (IOException e) {e.printStackTrace();}return null;}

打开地址调用接口，页面出现返回结果
http://localhost:8080/selectAliasByIndex?aliasName=indexname1

  1. 查看别名是否存在索引中
    @Autowiredprivate RestHighLevelClient client;@RequestMapping("/getAliasExist")public Boolean getAliasExist(String indexName,String aliasName) {GetAliasesRequest getAliasesRequest = new GetAliasesRequest(aliasName);// 指定查看某一个索引的别名 不指定，则会搜索所有的别名getAliasesRequest.indices(indexName);try {return client.indices().existsAlias(getAliasesRequest, RequestOptions.DEFAULT);} catch (IOException e) {e.printStackTrace();}return false;}

打开地址调用接口，页面出现返回结果
http://localhost:8080/getAliasExist?indexName=indexname&aliasName=indexname_alias

更多资料请看《ElasticSearch入门到实战教程》：点击查看

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/129917.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

InetAddress.getLocalHost() 执行非常慢

InetAddress.getLocalHost() 执行非常慢

昨天同事反馈网关的请求非常慢&#xff0c;一个获取的token的接口响应都超过了30s&#xff0c;还好只是测试环境。 经过验证&#xff0c;几乎所有接口响应都很慢&#xff0c;很多都响应超时。 排查步骤&#xff1a; 0. 本地启动项目测试&#xff0c;没有这个问题。而且生产环…
阅读更多...
Python基础之列表、元组和字典

Python基础之列表、元组和字典

一文拿捏Python基本数据类型“列表、数组和字典” 引言 Python中的 列表(英文叫list) 、 元组(英文叫tuple)和字典&#xff08;dictionary&#xff09; 也是 序列 特性的&#xff0c;它们也是非常常用的数据类型。 1、列表&#xff08;List&#xff09; 01、概述 列表&#…
阅读更多...
【Ubuntu】虚拟机安装系统与初始化配置

【Ubuntu】虚拟机安装系统与初始化配置

一、安装ubuntu系统 1、首先在虚拟机上安装一个虚拟机系统。 简单操作忽略&#xff0c;只贴出与安装linux不同的地方。 内存&#xff0c;处理器&#xff0c;磁盘等什么自己看着需要自己增加们这边不做过多说明。一直下一步&#xff0c;然后就安装好了。2、选择镜像位置然后启…
阅读更多...
华为RS设备状态及接口配置命令

华为RS设备状态及接口配置命令

1、查看硬件信息 ①查看序列号 查看整机序列号 display esn display sn ②、查看功率 电源功率 display power 查看光模块功率 display transceiver interface gigabitethernet 1/0/0 verbose ③、查看风扇 display fan ④、查看温度 display temperature all ⑤、查看硬…
阅读更多...
【MySQL】索引(下)

【MySQL】索引(下)

文章目录 1. 普通索引2. 索引操作创建主键索引查询索引删除索引唯一索引的创建删除唯一键索引普通索引的创建全文索引 1. 普通索引 MySQL除了会默认建立主键索引&#xff0c;也可能会按照其他列信息建立的索引&#xff0c;一般这种索引称为 普通索引 对于 储存引擎 myisam&…
阅读更多...
伊朗网络间谍组织针对中东金融和政府部门

伊朗网络间谍组织针对中东金融和政府部门

导语 近日&#xff0c;以色列网络安全公司Check Point与Sygnia发现了一起针对中东金融、政府、军事和电信部门的网络间谍活动。这一活动由伊朗国家情报和安全部门&#xff08;MOIS&#xff09;支持的威胁行为者发起&#xff0c;被称为"Scarred Manticore"。该组织被认…
阅读更多...
在Linux上通过NTLM认证连接到AD服务器（未完结）

在Linux上通过NTLM认证连接到AD服务器（未完结）

这篇文章目前还没有实现具体的功能&#xff0c;只实现了明文登录&#xff0c;因为我缺少一些数据&#xff0c;比如通过密码生成hash&#xff0c;以及通过challenge生成response&#xff0c;我不知道怎么实现&#xff0c;因此这篇文章也是一个交流的文章&#xff0c;希望大佬看见…
阅读更多...
【实战Flask API项目指南】之一 概述

【实战Flask API项目指南】之一 概述

实战Flask API项目指南之 概述 本系列文章将带你深入探索实战Flask API项目指南&#xff0c;通过跟随小菜的学习之旅&#xff0c;你将逐步掌握Flask在实际项目中的应用。让我们一起踏上这个精彩的学习之旅吧&#xff01; 前言 小菜是一个Python编程爱好者&#xff0c;他目前…
阅读更多...
蓝桥杯 （C++ 求和 等差数列 顺子日期 灌溉）

蓝桥杯 （C++ 求和 等差数列 顺子日期 灌溉）

目录 1、求和 题目&#xff1a; 思路&#xff1a; 代码&#xff1a; 2、等差数列 题目&#xff1a; 思路&#xff1a; 代码&#xff1a; 3、顺子日期 题目&#xff1a; 思路&#xff1a; 代码&#xff1a; 4、灌溉 题目&#xff1a; 代码&#xff1a; 1、求和…
阅读更多...
c#中使用METest单元测试

c#中使用METest单元测试

METest是一个用于测试C#代码的单元测试框架。单元测试是一种软件测试方法&#xff0c;用于验证代码的各个单元&#xff08;函数、方法、类等&#xff09;是否按照预期工作。METest提供了一种简单而强大的方式来编写和运行单元测试。 TestMethod&#xff1a;这是一个特性&#…
阅读更多...
KaiwuDB 内核解析 - SQL 查询的生命周期

KaiwuDB 内核解析 - SQL 查询的生命周期

一、概述 KaiwuDB 内核解析系列共分上下两部分&#xff0c;本文是该系列的第一部分&#xff0c;主要涵盖了网络协议到 SQL 执行器&#xff0c;解释 KaiwuDB 如何执行 SQL 查询&#xff0c;包括系统各个组件的执行路径&#xff08;网络协议、SQL 会话管理、解析器、执行计划及优…
阅读更多...
odoo 按钮打印pdf报表

odoo 按钮打印pdf报表

odoo打印一般是在动作里面进行的 所以此方法可用自定义按钮进行打印 <template id"report_sale_line_packing_template"> xxx </template><template id"report_sale_line_packing"><t t-call"web.basic_layout"><t …
阅读更多...
maven的settings.xml和pom.xml配置文件详解

maven的settings.xml和pom.xml配置文件详解

一、配置文件 maven的配置文件主要有 settings.xml 和pom.xml 两个文件。 其中在maven安装目录下的settings.xml&#xff0c;如&#xff1a;D:\Program Files\apache-maven-3.6.3\conf\settings.xml 是全局配置文件 用户目录的.m2子目录下的settings.xml&#xff0c;如&#…
阅读更多...
C++分治算法------ 砍树

C++分治算法------ 砍树

题目描述 伐木工人 Mirko 需要砍M米长的木材。对 Mirko 来说这是很简单的工作&#xff0c;因为他有一个漂亮的新伐木机&#xff0c;可以如野火一般砍伐森林。不过&#xff0c;Mirko 只被允许砍伐一排树。 Mirko 的伐木机工作流程如下&#xff1a;Mirko 设置一个高度参数H&…
阅读更多...
大模型帮我梳理的docker命令

大模型帮我梳理的docker命令

以下是一些常见的Docker命令&#xff1a; 1. docker run: 运行一个容器。示例&#xff1a;docker run <镜像名称> 2. docker pull: 下载一个镜像。示例&#xff1a;docker pull <镜像名称> 3. docker build: 构建一个镜像。示例&#xff1a;docker build -t <镜…
阅读更多...
Linear FC FFN MLP层学习

Linear FC FFN MLP层学习

一、Linear&#xff08;线性层&#xff09; 即神经网络的线性层&#xff0c;用于将输入映射到下一层的特征空间。它接受一个输入并与该层的权重的转置相乘。线性层没有激活函数。 公式&#xff1a; y x*W^T b&#xff0c;其中 W 是权重矩阵&#xff0c;b 是偏置向量。 pytorc…
阅读更多...
每日一题411数组中两个数的最大异或值(哈希表、前缀树：实现前缀树)

每日一题411数组中两个数的最大异或值(哈希表、前缀树：实现前缀树)

数组中两个数的最大异或值(哈希表、前缀树&#xff1a;实现前缀树) LeetCode题目&#xff1a;https://leetcode.cn/problems/maximum-xor-of-two-numbers-in-an-array/ 哈希表解法 本题使用哈希表方法主要运用到一个定理&#xff1a;异或满足算法交换律。即如果a^b c&#x…
阅读更多...
【Spring MVC】Spring MVC框架的介绍及其使用方法

【Spring MVC】Spring MVC框架的介绍及其使用方法

目录 一、MVC模式 1.1 MVC模式的发展 1.1.1 Model1 模型 1.1.2 Model2 模型 1.2 MVC模式简介 1.模型(Model) 2.视图(View) 3.控制器(Controller) 二、Spring MVC模型简介 三、Spring MVC 六大核心组件 3.1 六大组件简介 1.前端控制器 DispatcherServlet&#xff08…
阅读更多...
Notepad++下载、使用

Notepad++下载、使用

下载 https://notepad-plus-plus.org/downloads/ 安装 双击安装 选择安装路径 使用 在文件夹中搜索 文件类型可以根据需要设置 如 *.* 说明是所有文件类型&#xff1b; *.tar 说明是所有文件后缀是是tar的文件‘&#xff1b;
阅读更多...
多个PDF发票合并实现一张A4纸打印2张电子/数电发票功能

多个PDF发票合并实现一张A4纸打印2张电子/数电发票功能

python教程79--A4纸增值税电子发票合并打印_python 打印 发票设置_颐街的博客-CSDN博客文章浏览阅读7.9k次。接上篇https://blog.csdn.net/itmsn/article/details/121902974?spm1001.2014.3001.5501一张A4纸上下2张增值税电子发票实现办法。使用环境&#xff1a;python3.8、ma…
阅读更多...
最新文章

Copyright @ 2022~2023