还不会ES?Elasticsearch快速入门实操指南送上

2024-03-01 16:50

本文主要是介绍还不会ES?Elasticsearch快速入门实操指南送上,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

前言

本文主要介绍ES的常用请求,让大家能快速上手ES的使用

主要参考官网的Quick start指引。


一、请求方式

向Elasticsearch发送请求主要有2种方式:
1、使用rest api发送http请求,比如curl命令

curl -X GET -u elastic:123456  "localhost:9200/?pretty"

2、使用Kibana’s console的请求工具
进入kibana界面,打开控制台——》开发工具
在这里插入图片描述

官网中的示例代码可以直接拷贝到Kibana中执行,也可以Copy as curl复制到服务器上执行curl请求。
在这里插入图片描述
通过设置按钮,还可以配置对应的kibana控制台的相关信息。这样当点击View in Console就能直接跳转到
我们自己安装的kibana的控制台。
在这里插入图片描述

这里为了请求的方便和简洁性,下面的演示中都是采用Kibana’s console的请求工具向ES发送请求。

二、创建索引

创建索引时,注意一下三点:
1、设置索引的settings属性
2、设置索引的mappings属性
3、设置索引的别名

官方文档:https://www.elastic.co/guide/en/elasticsearch/reference/7.13/indices-create-index.html

方式一:只创建索引

PUT my-index-000001

方式二:创建索引并同时指定settings、mappings、aliases

PUT my-index-000001
{"settings": {"number_of_shards": "4","number_of_replicas": "0","index": {"refresh_interval": "30s"}},"mappings": {"properties": {"content": {"type": "text","analyzer": "ik_max_word","search_analyzer": "ik_smart"},"name": {"type": "keyword"},"age": {"type": "integer"},"@timestamp" : {"type" : "date"}}},"aliases": {"alias1": {}}
}

说明:
采用PUT命令创建索引my-index-000001,并同时设置索引的settings和mappings。

settings主要用来配置索引的一些全局属性,比如分片数,副本数,刷新频次,等。示例中通过number_of_shards指定了索引的分片数为1。

mappings主要用来声明索引中包含的字段和类型,对应关系型数据库中的表结构声明。

三、设置setting

number_of_shards
说明:索引分片数量
索引分片数在索引创建好了之后就不能调整了,只能重建索引

number_of_replicas
说明:用来控制索引的副本数量

index.refresh_interval
说明:索引刷新频率
数据写入后几秒可以被搜索到,默认是 1s。每次索引的 refresh 会产生一个新的 lucene 段, 这会导致频繁的合并行为,如果业务需求对实时性要求没那么高,可以将此参数调大,实际调优告诉我,该参数确实很给力,cpu 使用率直线下降。

设置settings:

PUT /my-index-000001
{"settings": {"index": {"number_of_shards": 3,  "number_of_replicas": 2 }}
}

也可以简写成:

PUT /my-index-000001
{"settings": {"number_of_shards": 3,"number_of_replicas": 2}
}

修改settings:
说明:修改索引的副本数目。

PUT my-index-000001/_settings
{"number_of_replicas": "2"
}

查看索引的详情:

GET /my-index-000001/

查看索引的settings:

GET /my-index-000001/_settings

查看索引的mapping:

GET /my-index-000001/_mapping

注意⚠️:
分片数number_of_shards的属性在索引创建后就不能修改了。

四、设置mapping

说明:
映射是定义文档及其包含的字段如何存储和索引的过程。
每个文档都是字段的集合,每个字段都有自己的数据类型。 映射数据时,您创建一个映射定义,其中包含与文档相关的字段列表。 映射定义还包括元数据字段,例如 _source 字段,用于自定义处理文档相关元数据的方式。
mapping属性主要用来设置索引中的字段名称和字段类型以及text字段的分词策略。

官网对mapping的介绍:
https://www.elastic.co/guide/en/elasticsearch/reference/7.13/mapping.html

mapping主要有2种类型:
1、自动映射 Dynamic mapping
当 Elasticsearch 在文档中检测到新字段时,它默认动态地将该字段添加到类型映射中。
也就是添加数据时,发现新的字段会自动添加类型映射。

2、精确映射 Explicit mapping
由用户自己定义索引的映射,这种方式会更加精准。

注意⚠️:
ES的mapping可以新增字段,但是对于已经存在的字段,只能添加属性,不能修改字段的类型。
如果需要修改已经存在的字段的type类型,只能进行重建索引reindex
ES的mapping并不是不能修改,只是不能对已经存在的字段类型进行修改。

获取索引的mapping信息

GET /my-index-000001/_mapping

获取索引中单个字段的mapping信息

GET /my-index-000001/_mapping/field/content

设置mapping信息

PUT /my-index-000001/_mapping
{"dynamic": false, "properties": {"content": {"type": "text","analyzer": "ik_max_word","search_analyzer": "ik_smart"},"name": {"type": "keyword"},"age": {"type": "integer"},"@timestamp" : {"type" : "date","format": "yyyy-MM-dd HH:mm:ss"}}
}

PUT /my-index-000001
{"mappings": {"dynamic": false, "properties": {"content": {"type": "text","analyzer": "ik_max_word","search_analyzer": "ik_smart"},"name": {"type": "keyword"},"age": {"type": "integer"},"@timestamp" : {"type" : "date","format": "yyyy-MM-dd HH:mm:ss"}}}
}

说明:
给索引添加4个字段,content、name、age、@timestamp。
其中content类型为text,会进行分词匹配,设置分词器为ik_max_word,查询分词器为ik_smart。

如果时间字段需要指定多种格式,可以采用如下方式声明:

"create_time" : {"type" : "date","format" : "yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||epoch_millis"
}

dynamic 参数控制是否动态添加新字段,并接受以下参数:

  • true
    新字段被添加到映射中(默认)。

  • runtime
    新字段作为运行时字段添加到映射中。 这些字段未编入索引,并在查询时从 _source 加载。

  • false
    新字段将被忽略。 这些字段不会被索引或可搜索,但仍会出现在返回命中的 _source 字段中。 这些字段不会添加到映射中,必须显式添加新字段。

  • strict
    如果检测到新字段,则会抛出异常并拒绝文档。 新字段必须显式添加到映射中。

给索引增加一个新的字段映射:

PUT /my-index-000001/_mapping
{"properties": {"email": {"type": "keyword"}}
}

五、设置索引别名

官网介绍:https://www.elastic.co/guide/en/elasticsearch/reference/7.13/indices-aliases.html

索引别名是用于引用一个或多个现有索引的辅助名称。
大多数 Elasticsearch API 接受索引别名来代替索引。

一个索引别名能关联多个索引。可以用索引别名来代替真实索引名称查询。

方式一:创建索引时指定别名

PUT /my-index-000001
{"aliases": {"alias_1": {}}
}

方式二:给已经存在的索引新增索引别名

POST /_aliases
{"actions" : [{ "add" : { "index" : "my-index-000001", "alias" : "alias1" } }]
}

移除索引别名:

POST /_aliases
{"actions" : [{ "remove" : { "index" : "my-index-000001", "alias" : "alias1" } }]
}

重命名索引别名:

POST /_aliases
{"actions" : [{ "remove" : { "index" : "my-index-000001", "alias" : "alias1" } },{ "add" : { "index" : "my-index-000001", "alias" : "alias2" } }]
}

六、添加数据

1、单条添加

  • 指定索引ID添加单条数据
PUT /my-index-000001/_doc/1
{"content": "小天今天在研究大数据", "name": "小天", "age": 25,"@timestamp": "2018-05-08 16:25:42"}
  • 自动生成索引ID添加单条数据
POST my-index-000001/_doc
{"content": "小天尝试通过POST添加单条数据", "name": "小天", "age": 25,"@timestamp": "2018-05-08 16:25:42"}POST /my-index-000001/_doc?op_type=create
{"content": "小天今天去钓鱼", "name": "小天", "age": 25,"@timestamp": "2018-05-08 16:25:42"}

2、批量添加

通过bulk命令实现批量添加数据,可以通过create属性指定id,如果不指定则自动生成索引ID。

PUT /my-index-000001/_bulk
{ "create": { } }
{"content": "小明同学觉得java是最好的编程语言", "name": "小明", "age": 20,"@timestamp": "2020-05-08 16:25:42"}
{ "create":  {  "_id": "20210602060517329146" }}
{"content": "小明同学今天学习编程5个小时", "name": "小明", "age": 20,"@timestamp": "2020-05-08 16:25:42"}

通过添加refresh,批量添加数据后,立刻刷新索引。保证大批量的添加数据后,索引立刻刷新,可以立刻被检索到。

PUT /my-index-000001/_bulk?refresh
{ "create": { } }
{"content": "路见不平,拔刀相助", "name": "小李", "age": 29,"@timestamp": "2019-05-08 16:25:42"}

七、关闭索引

POST /my-index-000001/_close?wait_for_active_shards=0

八、开启索引

POST /my-index-000001/_open

九、删除索引

删除索引及索引中的数据

DELETE /my-index-000001

根据id删除单条索引数据

DELETE /my-index-000001/_doc/20210602060517329146

根据查询结果删除数据:

POST /my-index-000001/_delete_by_query?pretty
{"query": {"match_all": {}}
}

十、基础查询

1、查询全部

无条件查询,如果返回数据量过多,会自动分页。

GET /my-index-000001/_search

等同于match_all

GET /my-index-000001/_search
{"query": {"match_all": {}}
}

2、指定返回字段

GET my-index-000001/_search
{"query": {"match_all": { }},"fields": ["@timestamp"],"_source": false,"sort": [{"@timestamp": "desc"}]
}

说明:
有时候我们不希望返回索引中的全部字段,那么可以通过fields属性指定需要返回的字段。
这里注意,如果通过fields指定了需要返回的字段,最好同时将_source属性设置为false,否则仍会会返回_source。

2、term精确查询

查看年龄age为25岁的记录:

GET my-index-000001/_search
{"query":{"term":{"age":25}}
}

查询姓名为小龙的记录:

GET my-index-000001/_search
{"query":{"term":{"name" : "小龙"}}
}

3、match分词匹配查询

GET my-index-000001/_search
{"query":{"match":{"content" : "Java编程"}}
}

结果:

{"took" : 1,"timed_out" : false,"_shards" : {"total" : 1,"successful" : 1,"skipped" : 0,"failed" : 0},"hits" : {"total" : {"value" : 2,"relation" : "eq"},"max_score" : 2.9542089,"hits" : [{"_index" : "my-index-000001","_type" : "_doc","_id" : "rYv3ZXoBD69AlULo3Bnk","_score" : 2.9542089,"_source" : {"content" : "小明同学觉得java是最好的编程语言","name" : "小明","age" : 20,"@timestamp" : "2020-05-08 16:25:42"}},{"_index" : "my-index-000001","_type" : "_doc","_id" : "20210602060517329146","_score" : 1.1599741,"_source" : {"content" : "小明同学今天学习编程5个小时","name" : "小明","age" : 20,"@timestamp" : "2020-05-08 16:25:42"}}]}
}

说明:
只有text类型的字段才能进行分词匹配。输入的关键字“Java编程”被分解成了 “JAVA”、“编程”后才去和content分词解析后的数据进行匹配。

4、分页

GET my-index-000001/_search
{"from":0,"size":2,"query": {"match_all": { }},"sort": [{"@timestamp": "asc"}]
}

说明:
from和size是起到分页的作用。from指定起始记录行,size指定返回多少条数据。

5、排序

GET my-index-000001/_search
{"query": {"match_all": { }},"sort": [{"@timestamp": "desc"}]
}

说明:
通过sort属性指定排序字段,desc倒序,asc正序。

6、范围查询

GET /my-index-000001/_search
{"query": {"range": {"@timestamp": {"gte": "2020-01-08 16:25:42","lt": "2020-10-08 16:25:42"}}},"fields": ["@timestamp"],"_source": false,"sort": [{"@timestamp": "desc"}]
}

说明:
通过range实现范围查询。
范围操作符包含:

  • gt : 大于
  • gte : 大于等于
  • lt : 小于
  • lte : 小于等于

7、聚合查询

按年龄统计记录数

GET /my-index-000001/_search
{"size": 0, "aggs": {"my-agg-name": {"terms": {"field": "age"}}}
}

注意⚠️:
这类聚合统计一定要指定size为0

结果:

{"took" : 2,"timed_out" : false,"_shards" : {"total" : 1,"successful" : 1,"skipped" : 0,"failed" : 0},"hits" : {"total" : {"value" : 8,"relation" : "eq"},"max_score" : null,"hits" : [ ]},"aggregations" : {"my-agg-name" : {"doc_count_error_upper_bound" : 0,"sum_other_doc_count" : 0,"buckets" : [{"key" : 25,"doc_count" : 5},{"key" : 20,"doc_count" : 2},{"key" : 29,"doc_count" : 1}]}}
}

总结

本文主要是参考官网的Quick start快速入门ES的实操指南,希望对大家快速上手ES有所帮助。

这篇关于还不会ES?Elasticsearch快速入门实操指南送上的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/763142

相关文章

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门(一):登录与退出》 《Spring-Security-入门(二):基于数据库验证》 《Spring-Security-入门(三):密码加密》 《Spring-Security-入门(四):自定义-Filter》 《Spring-Security-入门(五):在 Sprin

基于MySQL Binlog的Elasticsearch数据同步实践

一、为什么要做 随着马蜂窝的逐渐发展,我们的业务数据越来越多,单纯使用 MySQL 已经不能满足我们的数据查询需求,例如对于商品、订单等数据的多维度检索。 使用 Elasticsearch 存储业务数据可以很好的解决我们业务中的搜索需求。而数据进行异构存储后,随之而来的就是数据同步的问题。 二、现有方法及问题 对于数据同步,我们目前的解决方案是建立数据中间表。把需要检索的业务数据,统一放到一张M

电脑桌面文件删除了怎么找回来?别急,快速恢复攻略在此

在日常使用电脑的过程中,我们经常会遇到这样的情况:一不小心,桌面上的某个重要文件被删除了。这时,大多数人可能会感到惊慌失措,不知所措。 其实,不必过于担心,因为有很多方法可以帮助我们找回被删除的桌面文件。下面,就让我们一起来了解一下这些恢复桌面文件的方法吧。 一、使用撤销操作 如果我们刚刚删除了桌面上的文件,并且还没有进行其他操作,那么可以尝试使用撤销操作来恢复文件。在键盘上同时按下“C

Retrieval-based-Voice-Conversion-WebUI模型构建指南

一、模型介绍 Retrieval-based-Voice-Conversion-WebUI(简称 RVC)模型是一个基于 VITS(Variational Inference with adversarial learning for end-to-end Text-to-Speech)的简单易用的语音转换框架。 具有以下特点 简单易用:RVC 模型通过简单易用的网页界面,使得用户无需深入了

数论入门整理(updating)

一、gcd lcm 基础中的基础,一般用来处理计算第一步什么的,分数化简之类。 LL gcd(LL a, LL b) { return b ? gcd(b, a % b) : a; } <pre name="code" class="cpp">LL lcm(LL a, LL b){LL c = gcd(a, b);return a / c * b;} 例题:

Java 创建图形用户界面(GUI)入门指南(Swing库 JFrame 类)概述

概述 基本概念 Java Swing 的架构 Java Swing 是一个为 Java 设计的 GUI 工具包,是 JAVA 基础类的一部分,基于 Java AWT 构建,提供了一系列轻量级、可定制的图形用户界面(GUI)组件。 与 AWT 相比,Swing 提供了许多比 AWT 更好的屏幕显示元素,更加灵活和可定制,具有更好的跨平台性能。 组件和容器 Java Swing 提供了许多

【IPV6从入门到起飞】5-1 IPV6+Home Assistant(搭建基本环境)

【IPV6从入门到起飞】5-1 IPV6+Home Assistant #搭建基本环境 1 背景2 docker下载 hass3 创建容器4 浏览器访问 hass5 手机APP远程访问hass6 更多玩法 1 背景 既然电脑可以IPV6入站,手机流量可以访问IPV6网络的服务,为什么不在电脑搭建Home Assistant(hass),来控制你的设备呢?@智能家居 @万物互联

poj 2104 and hdu 2665 划分树模板入门题

题意: 给一个数组n(1e5)个数,给一个范围(fr, to, k),求这个范围中第k大的数。 解析: 划分树入门。 bing神的模板。 坑爹的地方是把-l 看成了-1........ 一直re。 代码: poj 2104: #include <iostream>#include <cstdio>#include <cstdlib>#include <al

hdu 4565 推倒公式+矩阵快速幂

题意 求下式的值: Sn=⌈ (a+b√)n⌉%m S_n = \lceil\ (a + \sqrt{b}) ^ n \rceil\% m 其中: 0<a,m<215 0< a, m < 2^{15} 0<b,n<231 0 < b, n < 2^{31} (a−1)2<b<a2 (a-1)^2< b < a^2 解析 令: An=(a+b√)n A_n = (a +

MySQL-CRUD入门1

文章目录 认识配置文件client节点mysql节点mysqld节点 数据的添加(Create)添加一行数据添加多行数据两种添加数据的效率对比 数据的查询(Retrieve)全列查询指定列查询查询中带有表达式关于字面量关于as重命名 临时表引入distinct去重order by 排序关于NULL 认识配置文件 在我们的MySQL服务安装好了之后, 会有一个配置文件, 也就