Elasticsearch学习记录

阅读前须知

        本文通过安装elasticsearch-7.17.0为基础,使用 kibana-7.17.0 对 elasticsearch 进行操作,本文中 es 是对 elasticsearch 的简写。

下载地址:elasticsearch_免费高速下载|百度网盘-分享无限制 (baidu.com)

1 初识Elasticsearch

概述:Elasticsearch是一个基于Lucene的搜索引擎,具有分布式特性,能够处理大规模数据的实时搜索和分析。它通过RESTful API提供强大的全文搜索能力,并支持复杂的查询、聚合分析和多种数据格式。Elasticsearch常用于日志分析、数据监控和搜索应用等场景,通常与Kibana和Logstash一起使用,形成ELK栈。


1.1 全文检索

概述

①、Elasticsearch是一个全文检索服务器,全文检索是一种非结构化数据的搜索方式

②、结构化数据一般存入数据库,使用sql语句即可快速查询。但由于非结构化数据的数据量大且格式不固定,我们需要采用全文检索的方式进行搜索。全文检索通过建立倒排索引加快搜索效率。


1.2 倒排索引

概述

①、将数据中的一部分信息提取出来,重新组织成一定的数据结构,我们可以根据该结构进行快速搜索,这样的结构称之为索引

②、索引即目录,例如字典会将字的拼音提取出来做成目录,通过目录即可快速找到字的位置。

③、索引分为正排索引倒排索引

正排索引:将文档 id 建立为索引,通过 id 快速可以快速查找数据。如数据库中的主键就会创建正排索引。

倒排索引:非结构化数据中我们往往会根据关键词查询数据。此时我们将数据中的关键词建立为索引,指向文档数据,这样的索引称为倒排索引。

创建倒排索引的流程


1.3 ES的数据结构

文档(Document):文档是可被查询的最小数据单元,一个 Document 就是一条数据。类似于关系型数据库中的记录的概念。

类型(Type):具有一组共同字段的文档定义成一个类型,类似于关系型数据库中的数据表的概念。

索引(Index):索引是多种类型文档的集合,类似于关系型数据库中的库的概念。

域(Fied):文档由多个域组成,类似于关系型数据库中的字段的概念。

:ES7.X之后删除了type的概念,一个索引不会代表一个库,而是代表一张表。

总结: ES中有很多概念与Mysql差不多,ES7及以上版本中,索引相当于Mysql中的表,文档相当于Mysql中的每一条记录(每个文档都有唯一的ID),域相当于Mysql中的每一列,域是文档中的具体数据项。


2 安装Elasticsearch

2.1 安装ES服务

①、准备一台装载有centos7的虚拟机,并能让xshell远程连接该虚拟机

创建好虚拟机后,首先修改虚拟机的网络配置文件:

vim /etc/sysconfig/network-scripts/ifcfg-ens33

修改的内容如下:

# 修改如下内容
BOOTPROTO="static"# 增加如下内容
IPADDR=192.168.1.123
NETMASK=255.255.255.0
GATEWAY=192.168.1.9
DNS1=8.8.8.8

接下来配置虚拟网络编辑器:vmware左上角的编辑 > 虚拟网络编辑器

接下来重启虚拟机网络:

systemctl restart network

最后测试网络是否配置成功:

ping baidu.com

运行结果如下:(能ping通就说明配置成功了)

接下来用xshell远程连接虚拟机即可:打开Xshell > 文件 > 新建

连接后结果如下:

②、关闭防火墙,方便访问ES

# 关闭防火墙
systemctl stop firewalld.service# 禁止防火墙自启动
systemctl disable firewalld.service

运行结果如下:

③、配置最大可创建文件数大小

# 打开系统文件
vim /etc/sysctl.conf# 添加以下配置
vm.max_map_count=655360# 生效修改的配置文件
sysctl -p

运行结果如下:

④、由于ES不能以root用户运行,需要创建一个非root用户,此处创建一个名为es的用户

useradd muxikeqi

运行结果如下:

⑤、通过rz命令将linux版的ES上传至虚拟机:

# 切换到根目录
cd /# 创建一个文件夹用于放置上传的文件
mkdir app# 进入创建的文件
cd app/# 通过rz命令上传文件,-be用于解决乱码问题
rz -be # 选择准备好的es的后缀为.tar.gz压缩包进行上传

运行结果如下:

⑥、解压ES

# 对上传的压缩包进行解压
tar -zxvf elasticsearch-7.17.0-linux-x86_64.tar.gz# 对解压后的目录进行重命名
mv elasticsearch-7.17.0 elasticsearch1# 将重命名后的文件夹移动到/usr/local/目录下
mv elasticsearch1 /usr/local# 由于es不能用root用户启动,所以要提取为该目录变更权限,后续用muxikeqi用户进行操作
chown -R muxikeqi:muxikeqi /usr/local/elasticsearch1/

运行结果如下:

⑦、启动ES服务

# 运行前先切换到指定用户
su muxikeqi# 进入指定目录
cd /usr/local/elasticsearch/# 前台运行es
./bin/elasticsearch# 推荐后台运行es 
./bin/elasticsearch &# 启动完成后通过如下命令查看es是否启动成功(原理是es默认占用9200端口)
curl 127.0.0.1:9200

运行结果如下:


2.2 安装ES的可视化工具(Kibana)

概述:Kibana是一款开源的数据分析和可视化平台,设计用于和Elasticsearch协作。我们可以使用Kibana对Elasticsearch索引中的数据进行搜索、查看、交互操作。

注意:Kibana的版本一定要与安装的ES版本一致。

①、上传并解压Kibana压缩包

# 切换到root用户
su root# 进入根目录下的app目录中
cd /app/# 通过rz命令将准备好的kibana压缩文件进行上传
rz -be # 直接将压缩包的内容解压到/usr/local/目录下
tar -zxvf kibana-7.17.0-linux-x86_64.tar.gz -C /usr/local/# 切换到/usr/local/目录下
cd /usr/local/# 对刚刚解压的文件进行重命名
mv kibana-7.17.0-linux-x86_64/ kibana1

运行结果如下:

②、修改kibana的配置文件

# 编辑kibana配置文件
vim ./kibana1/config/kibana.yaml# 文件中添加如下内容(注意:冒号后要空格,否则会报错)
server.host: "192.168.1.123"
elasticsearch.hosts: ["http://127.0.0.1:9200"]

运行结果如下:

③、启动kibana

提示:由于kibana也不能由root用户启动,因此也要改变kibana目录所属用户及其用户组。

# 在root用户下将kibana目录所属用户修改为muxikeqi
chown -R muxikeqi:muxikeqi /usr/local/kibana1/# 切换到muxikeqi用户
su muxikeqi# 进入kibana目录
cd /usr/local/kibana1/# 启动kibana 
./bin/kibana

运行结果如下:

④、访问kibana

概述:在浏览器的地址栏中输入http://虚拟机IP:5601即可访问kibana。

我在浏览器地址中填入的是http://192.168.1.123:5601,出现如下界面即成功:


3 Elasticsearch基操

3.1 索引操作

概述:Elasticsearch是使用RESTful风格的http请求访问操作的,请求参数和返回值都是Json格式的,我们可以使用kibana发送http请求操作ES。

3.1.1 创建没有结构的索引

路径:ip地址:端口号/索引名;

请求方式:PUT;

注意:由于 kibana 已经连接到ES,所以直接指定索引即可。


知识点1:创建索引的语法如下:

PUT /索引名

知识点2:为没有结构的索引添加结构的参考语法如下:(下面是为索引添加结构的参考语法,索引相当于SQL里的表,域名相当于SQL里的列,_mapping 和 "properties" 是为索引添加结构的固定语法。)

PUT /索引名/_mapping
{"properties":{"域名1":{"type":域的类型,"store":是否存储,"index":是否创建索引,"analyzer":分词器},"域名2":{ ...}}
}

实操1:演示如何通过 kibana 创建一个名为 student 且没有结构的索引。

首先在浏览器地址栏输入 http://虚拟机主机IP:5601,然后按下图所示步骤进行操作:

进入如下页面:

情况代码替换成如下代码:

PUT /student

参考图片如下:

运行完成后按下图步骤操作查看当前的索引:

进入新页面后按下图点击即可查看当前的索引:

运行结构如下:


实操2:演示如何为索引添加结构。

直接进入 kibana 的 Dev Tools 进行编码并运行,编码如下:

PUT /student/_mapping
{"properties":{"id":{"type":"integer"},"name":{"type":"text"},"age":{"type":"integer"}}
}

参考截图如下:

运行结果如下:

接下来通过 kibana 的 Static Management 来查看索引结构:

结构如下:


3.1.1 创建有结构的索引

概述:在上一小节中创建了没有结构的索引,并通过 _mapping 为索引添加了结构,本章节将演示如何直接创建有结构的索引(语法上基本一样)

知识点1:下面是直接创建有结构索引的参考语法:

PUT /索引名
{"mappings":{"properties":{"域名1":{"type":域的类型,"store":是否存储,"index":是否创建索引,"analyzer":分词器},"域名2":{ ...}}}
}

知识点2:删除索引的参考语法如下:

DELETE /索引名

实操3:通过 kibana 创建一个名为 student001 的有结构索引。(实操1和实操2中已详细展示了如何进入 kibana 的编辑页面,如何查看结构,所以后面的实操中将不演示)

PUT /student001
{"mappings": {"properties": {"id":{"type": "integer"},"name":{"type": "text"},"age":{"type": "integer"}}}
}

运行结果如下:


实操4:删除es中名为student的索引。

DELETE /student

运行结果如下:


3.2 文档操作

概述:文档操作就是对每条数据进行操作。

3.2.1 增删改查数据

知识点1:下面是新增/修改文档的参考语法:

# 在索引中添加文档 
POST /索引名/_doc/[_id值]
{# 在文档中指定对应的域(域就是文档中具体的值,允许有多条)"域名":域的值
}

注意:中括号中的 _id 值表示可省略,_id 值不写时自动生成文档 _id ,当设置的 _id 和已有 _id 重复时修改文档。


知识点2:下面是通过 _id 进行查询的参考语法:

GET /索引/_doc/_id值

知识点3:下面是删除文档的参考语法:

DELETE /索引/_doc/_id值

实操5:利用 kibana 创建一个名为 student 的索引,并为该索引添加几条数据,添加完成后查询新增的文档,然后尝试删除新增的文档。

POST /student/_doc/
{"name":"zs","id":1,"age":22
}

运行结果如下:

从结构中不难发现,即使创建文档时没有指定 _id ,创建时也会自动生成一个 _id 。

接下来尝试查询新增的文档:

GET /student/_doc/ocs1SJIBQG0lZjeULPJE

运行结构如下:

最后尝试删除创建的文档然后再对该文档进行查询:

DELETE /student/_doc/ocs1SJIBQG0lZjeULPJE

运行结果如下:

再次查询删除掉的文档:

GET /student/_doc/ocs1SJIBQG0lZjeULPJE

运行结果如下:


3.2.2 批量操作和修改部分字段

知识点1:根据ID批量查询文档的参考语法如下:

GET /索引/_mget
{"docs":[{"_id":_id值},{"_id":_id值}] 
}

知识点2:查询所有文档的参考语法如下:

GET /索引/_search
{"query": {"match_all": {}}
}

知识点3:修改文档部分域的语法如下:

POST /索引/_doc/_id值/_update
{ "doc":{ 域名:值} 
}

实操6:为student索引中添加多条文档,然后尝试查询所有文档和修改文档部分字段的操作。

首先为索引添加多条文档:

POST /student/_doc/1
{"name":"zs","age":20,"city":"cs"
}POST /student/_doc/2
{"name":"ls","age":21,"city":"bj"
}POST /student/_doc/3
{"name":"ww","age":22,"city":"gz"
}

运行结果如下:

接下来利用ID做批量查询的操作:

# 注意:最后一个大括号后面不要加逗号,否则会报错
GET /student/_mget
{"docs":[{"_id":1},{"_id":2},{"_id":3}]
}

运行结果如下:

接下来通过 _search 实现查询所有文档:

GET /student/_search
{"query": {"match_all": {}}
}

运行结果如下:

现突然发现 _id 为 3 的文档 city 值应该为 sc ,尝试修改该文档的 city 字段值:

POST /student/_doc/3/_update
{"doc":{"city":"sc"}
}

运行结果如下:

最后尝试单独查询 _id 为3的文档内容:

GET /student/_doc/3

运行结果如下:


注意事项

①、Elasticsearch执行删除操作时,ES先标记文档为deleted状态,而不是直接物理删除。当ES存储空间不足或工作空闲时,才会执行物理删除操作。

②、Elasticsearch执行修改操作时,ES不会真的修改Document中的数据,而是标记ES中原有的文档为deleted状态,再创建一个新的文档来存储数据。


3.3 域的属性

3.3.1 index

概述:index 用于指定该域是否创建倒排索引,当 index 的值设置为 true 时才能根据该域的关键词查询文档。

知识点1:根据关键词查询文档的参考语法如下:

GET /索引名/_search
{"query":{"term":{ 搜索字段: 关键字} }
}

实操7:分别创建两个索引,一个指定创建倒排索引,另一个不创建倒排索引,然后分别测试是否支持根据关键字进行查询。

首先创建两个索引:

PUT /student2
{"mappings":{"properties":{"name":{"type":"text","index": true}}}
}PUT /student3
{"mappings": {"properties": {"name":{"type": "text", "index": false}}}
}

运行结果如下:

接下来为两个新创建的索引插入数据:

POST /student2/_doc
{"name":"i like study spider"
}POST /student3/_doc
{"name":"i like study spider"
}

运行结果如下:

接下来尝试根据关键词查询student2文档:

GET /student2/_search
{"query": {"term": {"name": "spider"}}
}

运行结果如下:

最后尝试根据关键词查询student3文档:

GET /student3/_search
{"query": {"term": {"name": "spider"}}
}

运行结果如下:

总结:从本案例可以发现当文档创建了倒排索引就支持根据关键词进行查询,反之就不支持。


3.3.2 type

域的类型

核心类型具体类型
字符串类型text
整数类型long, integer, short, byte
浮点类型double, float
日期类型date
布尔类型boolean
数组类型array
对象类型object
不分词的字符串keyword

实操8:创建一个名为student4的索引,该索引包含一个字段即可,类型设置为keyword,并且设置倒排索引,测试该情况下是否能根据关键词进行查询。

首先创建student4的索引及其结构:

PUT /student4
{"mappings": {"properties": {"names":{"type": "keyword","index": true}}}
}

运行结果如下:

接下来为创建好的文档添加数据:

POST /student4/_doc
{"names":"i like study spider"
}

运行结果如下:

最后尝试做关键词查询:

GET /student4/_search
{"query": {"term": {"names": "spider"}}
}

运行结果如下:

注意:虽然并没有报错,但没有查询到拥有关键词的数据,原因就是keyword类型的字段不会根据空格做分词,names的整个值就是一整个词,所以拿其中的一部分是无法查询到的。

最后尝试用整个值去做查询:

GET /student4/_search
{"query": {"term": {"names": "i like study spider"}}
}

运行结果如下:

总结:当文档的类型设置为 keyword 时,用关键词对其做查询是查询不到数据的,因为 keyword 类型不会根据空格做分词,该类型一般用于手机号,身份证号等不适于分词的场景。


3.3.3 store

概述:store表示是否单独存储。如果设置为true,则该域能够单独查询。

知识点1:下面是单独查询某个域的参考语法:

GET /索引名/_search
{"stored_fields": ["域名"]
}

实操9:分别尝试对设置了store和没有设置store的文档做单独匹配。

首先创建两个索引及其结构:

PUT /student5
{"mappings": {"properties": {"age":{"type": "integer"},"name":{"type": "text","index": true, "store": true}}}
}PUT /student6
{"mappings": {"properties": {"age":{"type": "integer"},"name":{"type": "text","index": true, "store": false}}}
}

运行结果如下:

然后为两个索引添加对应的域:

POST /student5/_doc
{"age":18,"name":"i'm scrapy for baidu"
}POST /student6/_doc
{"age":20,"name":"i'm scrapy for google"
}

运行结果如下:

接下来对设置了 store 的 student5 索引做单独查询:

GET /student5/_search
{"stored_fields": ["name"]
}

运行结果如下:

最后对没有设置 store 的 student6 索引做域的单独查询:

GET /student6/_search
{"stored_fields": ["name"]
}

运行结果如下:

总结:如果所有的文档中设置了 store 将支持域的单独查询,如果对没有设置 store 的文档做域的单独查询虽然不会报错,但无法查询到域的数据,本设置一般用于经常需要查询的域。


4 分词器

概述:ES文档的数据拆分成一个个有完整含义的关键词,并将关键词与文档对应,这样就可以通过关键词查询文档。要想正确的分词,需要选择合适的分词器。


4.1 默认分词器

概述 :Elasticsearch 默认分词器 (standard analyzer) 会根据空格和标点符号对英文进行分词,会进行单词的大小写转换。

注意:默认分词器是英文分词器,对中文的分词是一字一词。

知识点:查看分词效果的参考语法如下:

GET /_analyze
{"text":测试语句, "analyzer":分词器
}

实操10:尝试查看默认分词器的效果:

GET /_analyze
{"text": ["crawl by scrapy"], "analyzer": "standard"
}

运行结果如下:

下面尝试利用默认分词器对中文进行分词:

GET /_analyze
{"text": ["爬虫"], "analyzer": "standard"
}

运行结果如下:


4.2 IK分词器

4.2.1 IK分词器的安装

概述:IKAnalyzer是一个开源的,基于java语言开发的轻量级的中文分词工具包。提供了两种分词算法:

  • ik_smart:最少切分

  • ik_max_word:最细粒度划分


实操11:安装IK分词器:

①、关闭ES

# 暂停正在运行的es
Ctrl + z# 切换到root用户
su# 查看es的相关进程
ps -ef | grep elasticsearch# 根据上一步获取的进程号强行杀死该进程
kill -9 获取的进程号1 获取的进程号2 ...

运行结果如下:

②、通过 rz 命令将 IK 分词器上传到虚拟机:(IK分词器的版本要与ES的版本一致)

# 进入上传文件的暂存目录/app
cd /app/# 通过rz命令上传文件
rz -be

运行结果如下:

③、将压缩文件解压到ES目录下plugins目录中

unzip elasticsearch-analysis-ik-7.17.0.zip -d /usr/local/elasticsearch1/plugins/analysis-ik

运行结果如下:

④、启动ES和Kibana

# 切换到其它用户
su muxikeqi# 进入es和kibana所在目录
cd /usr/local/# 后台运行es
./elasticsearch1/bin/elasticsearch -d# 运行kibana
./kibana1/bin/kibana 

运行结果如下:

⑤、进入Kibana测试IK分词器

首先尝试 ik_smart 进行分词:

GET /_analyze
{"text": ["今天天气真不错"],"analyzer": "ik_smart"
}

运行结果如下:

接下来尝试用 ik_max_word 进行分词:

GET /_analyze
{"text": ["今天天气真不错"],"analyzer": "ik_max_word"
}

运行结果如下:


4.2.2 IK分词器词典

概述:IK分词器根据词典进行分词,词典文件在IK分词器的config目录中:

  • main.dic:IK中内置的词典。记录了IK统计的所有中文单词。

  • IKAnalyzer.cfg.xml:用于配置自定义词库。


实操12:由于 IK 分词器并不会囊括所有的词语,所以可以通过修改 IKanalyzer.cfg.xml 文件实现自定义词库,本实操主要讲解如何操作自定义词库。

首先看一下 IK分词器 内置的词典包括多少字词:

# 进入IK分词器所在路径
cd /usr/local/elasticsearch1/plugins/analysis-ik/config/# 通过cw命令查看main.dic文件有多少行,每一行就是一个字/词
wc -l main.dic

运行结果如下:

接下来尝试设置一个自定义词库,首先编辑 IKAnalyzer.cfg.xml 文件:

# 编辑自定义词库的配置文件
vim ./IKAnalyzer.cfg.xml# 完整文件内容如下,主要是设置了扩展字典和停止词字典
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE properties SYSTEM "http://java.sun.com/dtd/properties.dtd">
<properties><comment>IK Analyzer 扩展配置</comment><!--用户可以在这里配置自己的扩展字典 --><entry key="ext_dict">ext_word.dic</entry><!--用户可以在这里配置自己的扩展停止词字典--><entry key="ext_stopwords">ext_stopword.dic</entry><!--用户可以在这里配置远程扩展字典 --><!-- <entry key="remote_ext_dict">words_location</entry> --><!--用户可以在这里配置远程扩展停止词字典--><!-- <entry key="remote_ext_stopwords">words_location</entry> -->
</properties># 创建并编辑ext_word.dic (扩展字典)
vim ext_word.dic# 创建并编辑ext_stopword.dic (停用字典:就是遇到停用词典里的词后将不会分词)
vim ext_stopword.dic

参考代码如下:

修改完成后需要重启 ES 和 kibana :

# 过滤elastic相关的端口号
ps -ef | grep elastic# 通过上面获取的端口号强行杀死进程
kill -9 端口1 端口2 ...

参考截图如下:

然后启用ES和kibana即可:

# 切换到其它用户
su muxikeqi# 进入es与kibana所在目录
cd /usr/local/# 后台启动es
./elasticsearch1/bin/elasticsearch -d# 启动kibana
./kibana1/bin/kibana

参考截图如下:

进入kibana测试是否能使用自定义的词典:

GET /_analyze
{"text": ["小孩哥小孩姐"],"analyzer": "ik_max_word"
}

运行结果如下:


4.3 拼音分词器

概述:拼音分词器可以将中文分成对应的全拼,全拼首字母等。

实操13:安装并测试拼音分词器:

①、关闭ES服务

# 获取elastic相关的进程号
ps -ef | grep elastic# 强制杀掉相关的进程号
kill -9 进程号1 进程号2 ...

参考截图如下:

②、利用rz命令将拼音分词器上传至虚拟机并解压:(版本需与ES一致)

# 进入暂存目录
cd /app# 通过rz命令上传压缩包
rz -be# 将上传的压缩包解压到es目录下的plugins目录中unzip elasticsearch-analysis-pinyin-7.17.0.zip -d /usr/local/elasticsearch1/plugins/analysis-pinyin

运行结果如下:

③、启动ES和kibana

# 切换到其它用户
su muxikeqi # 进入es和kibana所在的目录
cd /usr/local/# 后台启动es
./elasticsearch1/bin/elasticsearch -d# 启动kibana
./kibana1/bin/kibana

运行结果如下:

④、测试效果

进入kibana测试如下代码:

GET /_analyze
{"text": ["小孩哥"],"analyzer": "pinyin"
}

运行结果如下:


4.4 自定义分词器

概述:真实开发中我们往往需要对一段内容既进行文字分词,又进行拼音分词,此时我们需要自定义ik+pinyin分词器。

知识点:在创建索引时自定义分词器的参考代码如下:

PUT /索引名
{"settings" : {"analysis" : {"analyzer" : {"自定义分词器名" : { "tokenizer":"ik_max_word", // 基本分词器"filter":"pinyin_filter" // 配置分词器过滤}},"filter" : { // 分词器过滤时配置另一个分词器,相当于同时使用两个分词器"pinyin_filter" : { "type" : "pinyin", // 另一个分词器// 拼音分词器的配置"keep_separate_first_letter" : false, // 是否分词每个字的首字母"keep_full_pinyin" : true, // 是否分词全拼"keep_original" : true, // 是否保留原始输入"remove_duplicated_term" : true // 是否删除重复项}}}},"mappings":{"properties":{"域名1":{"type":域的类型,"store":是否单独存储,"index":是否创建倒排索引,"analyzer":选择自定义的分词器},"域名2":{ ...}}}
}

实操14:创建一个自定义分词器并进行测试。

首先创建一个拥有自定义分词器的索引:

PUT /student7
{"settings": {"analysis": {"analyzer": {"ik_pinyin":{"tokenizer":"ik_max_word","filter":"pinyin_filter"}},"filter": {"pinyin_filter":{"type":"pinyin","keep_separate_first_letter" : false, "keep_full_pinyin" : true, "keep_original" : true, "remove_duplicated_term" : true }}}},"mappings":{"properties":{"name":{"type":"text","store":true,"index":true,"analyzer":"ik_pinyin"},"age":{"type": "integer"}}}
}

运行结果如下:

注意:由于自定义分词器绑定到指定索引,所以测试时要指定对哪个索引进行测试:

GET /student7/_analyze
{"text": ["小孩哥小孩姐"],"analyzer": "ik_pinyin"
}

运行结果如下:


5 ES搜索文档

5.1 前期准备工作

概述:为了本章节能更好的运用已学知识和测试命令效果,所以提前在本章节创建索引,并向索引中添加多个文档。

知识点:文档搜索的语法如下:

GET /索引/_search
{"query":{搜索方式:搜索参数}
}

实操15:准备文档搜索章节的测试索引及其文档:

创建索引:

PUT /students
{"mappings":{"properties":{"id": {"type": "integer","index": true},"name": {"type": "text","store": true,"index": true,"analyzer": "ik_smart"},"info": {"type": "text","store": true,"index": true,"analyzer": "ik_smart"}}}
}

运行结果如下:

添加文档:

POST /students/_doc/
{"id":1,"name":"niko","info":"世界第一步枪手"
}POST /students/_doc/
{"id":2,"name":"donk","info":"cs2的新生代突破手"
}POST /students/_doc/
{"id":3,"name":"zywoo","info":"牢底坐穿王"
}POST /students/_doc/
{"id":4,"name":"tyloo","info":"未来可期,先荣为敬"
}POST /students/_doc/
{"id":5,"name":"jks","info":"廉颇老矣,尚能饭否"
}POST /students/_doc/
{"id":6,"name":"总监","info":"发型越飘逸,战力越难测"
}

运行结果如下:


5.2 搜索方式

5.2.1 match & match_all

知识点1:match_all 用于查询所有文档,参考语法如下:

{"query":{"match_all":{}}
}

知识点2:match 用于全文检索,将查询条件分词后再进行搜索,参考语法如下:

{"query":{"match":{搜索字段:搜索条件}}
}

知识点3:在搜索时关键词有可能会输入错误,ES搜索提供了自动纠错功能,即ES的模糊查询。使用match方式可以实现模糊查询。模糊查询对中文的支持效果一般,我们使用英文数据测试模糊查询,参考语法如下:

{"query": {"match": {"域名": {"query": 搜索条件,"fuzziness": 最多错误字符数,不能超过2}}}
}

实操16:查询students索引中所有的文档:

GET /students/_search
{"query": {"match_all": {}}
}

运行结果如下:


实操17:查询students索引中info对应的内容中包含关键词 "世界" 的域:

GET /students/_search
{"query": {"match": {"info": "世界"}}
}

运行结果如下:


实操18:演示 match 如何通过一句话做关联查询:(先对整句话做分词,然后再对指定的域做匹配)

GET /students/_search
{"query": {"match": {"info": "世界最顶级的cs比赛"}}
}

运行结果如下:


实操19:测试 match 方法的纠错功能:(最多支持两个字母纠错,以下情况都算一个字母的纠错:多一个字母,少一个字母,两个字母的位置放反了)

GET /students/_search
{"query": {"match": {"name": {"query": "tyl","fuzziness": 2}}}
}

运行结果如下:


5.2.2 range & match_phrase & term/terms

知识点1:range用于对数字类型的字段进行范围搜索,参考代码如下:

{"query":{"range":{搜索字段:{ "gte":最小值,"lte":最大值} }}
}
# gt/lt:大于/小于
# gte/lte:大于等于/小于等于

知识点2:match_phrase 用于短语检索。搜索条件不做任何分词解析,在搜索字段对应的倒排索引中精确匹配,参考语法如下:

{"query":{"match_phrase":{搜索字段:搜索条件}}
}

注意:match 方法会对提供的关键词进行分词,然后针对分词后的单个字或词做检索,但match_phrase 不会做分词处理,它会根据提供的关键词直接去做检索。


知识点3:term/terms 用于单词/词组搜索,搜索条件不做任何分词解析,在搜索字段对应的倒排索引中精确匹配 (效果和 match_phrase 相差不大),参考语法如下:

{"query":{"term":{ 搜索字段: 搜索条件}}
}{"query":{"terms":{ 搜索字段: [搜索条件1,搜索条件2]}}
}

注意:term 与 terms 的区别就是 term 只能跟一个搜索条件,而 terms 能跟多个搜索条件。


实操20:查询students索引中 id 字段的值为 3~4 的数据。

GET /students/_search
{"query": {"range": {"id": {"gte": 3,"lte": 4}}}
}

运行结果如下:


实操21:查询各域中info字段中有关 cs2 的数据。

GET /students/_search
{"query": {"match_phrase": {"info": "cs2"}}
}

运行结果如下:


5.3 复合搜索

知识点:复合搜索的参考语法如下:

GET /索引/_search
{ "query": { "bool": {  // 复合搜索通过bool关键字实现// 必须满足的条件 "must": [ 搜索方式:搜索参数,搜索方式:搜索参数],// 多个条件有任意一个满足即可"should": [搜索方式:搜索参数,搜索方式:搜索参数],// 必须不满足的条件"must_not":[搜索方式:搜索参数,搜索方式:搜索参数]} } 
}

注意:复合搜索并不是要同时实现 must , should 和 must_not,任意选择一个实现即可,当然同时选择这三个选项也是可以的。


实操22:实现复合搜索。

GET /students/_search
{"query": {"bool": {"must": [{"match": {"info": "世界最顶级的cs比赛"}},{"range": {"id": {"gte": 2}}}]}}
}

运行结果如下:


5.4 结果排序

概述:ES中默认使用相关度分数实现排序,可以通过搜索语法定制化排序,参考语法如下:

GET /索引/_search
{ "query": 搜索条件,"sort": [{"字段1":{"order":"asc"} },{ "字段2":{ "order":"desc" } }] 
}

注意:由于ES对text类型字段数据会做分词处理,使用哪一个单词做排序都是不合理的,所以 ES中默认不允许对text类型的字段做排序。如果需要使用字符串做结果排序,可以使用 keyword类型的字段作为排序依据,因为keyword字段不做分词处理。


实操23:尝试对 id 字段做结果排序:

GET /students/_search
{"query": {"match": {"info": "世界最顶级的cs比赛"}},"sort": [{"id": {"order": "asc"}}]
}

运行结果如下:


5.5 分页查询

知识点:分页查询的参考语法如下:

GET /索引/_search
{ "query": 搜索条件,"from": 起始下标,"size": 查询记录数
}

实操24:尝试对查询结果做分页处理。

GET /students/_search
{"query": {"match_all": {}},"from": 0,"size": 2
}

运行结果如下:


5.6 高亮查询

概述:在进行关键字搜索时,搜索出的内容中的关键字会显示不同的颜色,称之为高亮。

知识点:我们可以在关键字左右加入标签字符串,数据传入前端即可完成高亮显示,ES可以对查询出的内容中关键字部分进行标签和样式的设置,参考语法如下:

GET /索引/_search
{ "query":搜索条件,"highlight":{"fields": { "高亮显示的字段名": {// 返回高亮数据的最大长度"fragment_size":100,// 返回结果最多可以包含几段不连续的文字"number_of_fragments":5} },"pre_tags":["前缀"], "post_tags":["后缀"]} 
}

实操25:尝试实现高亮查询:

GET /students/_search
{"query": {"match": {"info": "世界最顶级的cs比赛"}},"highlight": {"fields": {"info": {"fragment_size": 20,"number_of_fragments": 5}},"pre_tags": ["<em>"],"post_tags": ["</em>"]}
}

运行结果如下:


5.7 SQL查询

知识点:在ES7之后,支持SQL语句查询文档 (不完全支持所有SQL语句),参考语法如下:

GET /_sql?format=txt
{"query": SQL语句
}

实操26:尝试利用 sql 语句查询 students 索引中所有的数据:

GET /_sql?format=txt
{"query": """SELECT * FROM "students""""
}

运行结果如下:

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

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

相关文章

阿里巴巴开源的FastJson 1反序列化漏洞复现攻击保姆级教程

免责申明 本文仅是用于学习检测自己搭建的靶场环境有关FastJson1反序列化漏洞的原理和攻击实验,请勿用在非法途径上,若将其用于非法目的,所造成的一切后果由您自行承担,产生的一切风险和后果与笔者无关;本文开始前请认真详细学习《‌中华人民共和国网络安全法》‌及其所在…

【重学 MySQL】四十五、数据库的创建、修改与删除

【重学 MySQL】四十五、数据库的创建、修改与删除 一条数据存储的过程数据输入数据验证数据处理数据存储数据持久化反馈与日志注意事项 标识符命名规则基本规则长度限制保留字与特殊字符命名建议示例 MySQL 中的数据类型创建数据库创建数据库时指定字符集和排序规则 查看数据库…

Ubuntu安装Hadoop3.4

1、创建Hadoop用户 sudo adduser hadoop 将Hadoop加进sudo用户组,赋予更高权限: sudo usermod -G sudo hadoop 3、安装JDK(略) 查看JDK安装路径:which java 和 ls -al 3、配置SSH免密登录 在Hadoop分布式集群环境中,各个机器之间的通信通常需要使用SSH的方式进行连…

探索Python网络世界的利器:Requests-HTML库

文章目录 探索Python网络世界的利器&#xff1a;Requests-HTML库背景&#xff1a;为何选择Requests-HTML&#xff1f;什么是Requests-HTML&#xff1f;如何安装Requests-HTML&#xff1f;5个简单库函数的使用方法3个场景下库的使用示例常见Bug及解决方案总结 探索Python网络世界…

【多线程】多线程(8):单例模式:阻塞队列

【阻塞队列】 阻塞队列是在普通的“先进先出”队列的基础上&#xff0c;做出了扩充&#xff0c;可以组成「生产者消费者模型」 1.线程安全性 标准库是原有的队列Queue和其子类&#xff0c;默认都是“线程不安全的”&#xff0c;而阻塞队列是“线程安全的” 2.具有阻塞特性 …

基于STM32的智能风扇控制系统设计

引言 本项目将基于STM32微控制器设计一个智能风扇控制系统&#xff0c;通过温度传感器实时检测环境温度&#xff0c;并根据预设的温度范围自动调节风扇的转速。该系统展示了STM32的PWM输出、传感器接口以及自动控制应用的实现。 环境准备 1. 硬件设备 STM32F103C8T6 开发板…

Java | Leetcode Java题解之第457题环形数组是否存在循环

题目&#xff1a; 题解&#xff1a; class Solution {public boolean circularArrayLoop(int[] nums) {int n nums.length;for (int i 0; i < n; i) {if (nums[i] 0) {continue;}int slow i, fast next(nums, i);// 判断非零且方向相同while (nums[slow] * nums[fast]…

51单片机的宠物自动投喂系统【proteus仿真+程序+报告+原理图+演示视频】

1、主要功能 该系统由AT89C51/STC89C52单片机LCD1602显示模块温湿度传感器DS1302时钟模块蓝牙步进电机按键、蜂鸣器等模块构成。适用于猫猫/狗狗宠物自动喂食器等相似项目。 可实现基本功能: 1、LCD1602实时显示北京时间和温湿度 2、温湿度传感器DHT11采集环境温湿度 3、时…

MySQL 实验1:Windows 环境下 MySQL5.5 安装与配置

MySQL 实验1&#xff1a;Windows 环境下 MySQL5.5 安装与配置 目录 MySQL 实验1&#xff1a;Windows 环境下 MySQL5.5 安装与配置一、MySQL 软件的下载二、安装 MySQL三、配置 MySQL1、配置环境变量2、安装并启动 MySQL 服务3、设置 MySQL 字符集4、为 root 用户设置登录密码 一…

【Docker】配置文件

问题 学习Docker期间会涉及到docker的很多配置文件&#xff0c;可能会涉及到的会有&#xff1a; /usr/lib/systemd/system/docker.service 【docker用于被systemd管理的配置文件】 /etc/systemd/system/docker.service.d【覆盖配置文件的存放处】 /etc/systemd/system/mul…

828华为云征文|部署音乐流媒体服务器 mStream

828华为云征文&#xff5c;部署音乐流媒体服务器 mStream 一、Flexus云服务器X实例介绍二、Flexus云服务器X实例配置2.1 重置密码2.2 服务器连接2.3 安全组配置2.4 Docker 环境搭建 三、Flexus云服务器X实例部署 mStream3.1 mStream 介绍3.2 mStream 部署3.3 mStream 使用 四、…

【MySQL】Ubuntu环境下MySQL的安装与卸载

目录 1.MYSQL的安装 2.MYSQL的卸载 1.MYSQL的安装 首先我们要看看我们环境里面有没有已经安装好的MySQL 我们发现是默认是没有的。 我们还可以通过下面这个命令来确认有没有mysql的安装包 首先我们得知道我们当前的系统版本是什么 lsb_release -a 我们在找apt源的时候&a…

20241004给荣品RD-RK3588-AHD开发板刷Rockchip原厂的Android12时永不休眠的步骤

20241004给荣品RD-RK3588-AHD开发板刷Rockchip原厂的Android12时永不休眠的步骤 2024/10/4 19:22 1、 Z:\rk3588s4_3588a12\device\rockchip\common\device.mk ifeq ($(strip $(BOARD_HAVE_BLUETOOTH_RTK)), true) include hardware/realtek/rtkbt/rtkbt.mk endif ifeq ($(str…

【文件增量备份系统】MySQL百万量级数据量分页查询性能优化

&#x1f3af; 导读&#xff1a;本文针对大数据量下的分页查询性能问题进行了深入探讨与优化&#xff0c;最初查询耗时长达12秒&#xff0c;通过避免全表计数及利用缓存保存总数的方式显著提升了浅分页查询速度。面对深分页时依然存在的延迟&#xff0c;采用先查询倒数第N条记录…

【机器学习】探索GRU:深度学习中门控循环单元的魅力

目录 &#x1f354; GRU介绍 &#x1f354; GRU的内部结构图 2.1 GRU结构分析 2.2 GRU工作原理 2.4 Bi-GRU介绍 2.3 使用Pytorch构建GRU模型 2.5 GRU优缺点 &#x1f354; 小结 学习目标 &#x1f340; 了解GRU内部结构及计算公式. &#x1f340; 掌握Pytorch中GRU工具…

【开源免费】基于SpringBoot+Vue.JS洗衣店订单管理系统(JAVA毕业设计)

本文项目编号 T 068 &#xff0c;文末自助获取源码 \color{red}{T068&#xff0c;文末自助获取源码} T068&#xff0c;文末自助获取源码 目录 一、系统介绍二、演示录屏三、启动教程四、功能截图五、文案资料5.1 选题背景5.2 国内外研究现状5.3 可行性分析 六、核心代码6.1 顾…

【Python】Uvicorn:Python 异步 ASGI 服务器详解

Uvicorn 是一个为 Python 设计的 ASGI&#xff08;异步服务器网关接口&#xff09;Web 服务器。它填补了 Python 在异步框架中缺乏一个最小化低层次服务器/应用接口的空白。Uvicorn 支持 HTTP/1.1 和 WebSockets&#xff0c;是构建现代异步Web应用的强大工具。 ⭕️宇宙起点 &a…

界星空科技漆包线行业称重系统

万界星空科技为漆包线行业提供的称重系统是其MES制造执行系统解决方案中的一个重要组成部分。以下是对该系统的详细介绍&#xff1a; 一、系统概述 万界星空科技漆包线行业称重系统&#xff0c;是集成在MES系统中的一个功能模块&#xff0c;专门用于漆包线生产过程中的重量检…

数据结构-LRU缓存(C语言实现)

遇到困难&#xff0c;不必慌张&#xff0c;正是成长的时候&#xff0c;耐心一点&#xff01; 目录 前言一、题目介绍二、实现过程2.1 实现原理2.2 实现思路2.2.1 双向链表2.2.2 散列表 2.3 代码实现2.3.1 结构定义2.3.2 双向链表操作实现2.3.3 实现散列表的操作2.3.4 内存释放代…