首页 > 其他分享 >天元突破-ElasticSearch性能究极进化

天元突破-ElasticSearch性能究极进化

时间:2024-03-31 21:01:25浏览次数:22  
标签:究极 translog 写入 索引 ElasticSearch 分片 天元 size

前言

ElasticSearch系列的完结篇,本篇会尽可能地罗列出性能优化的手段,给出我自己的点评。以官方推荐优化为主,个人常用手段为辅,部分配置因篇幅和时间不会有实战数据对比,仅列出配置说明参考。从我个人实践而言,ElasticSearch本身的优化已经很好了,做好推荐的系统配置后,其实其他软配置大部分效果不会质变,真正质变的是加ElasticSearch的内存,所以终极大招只有一个,加资源。除此之外,给ElasticSearch集群中的各个节点划分职责明确的角色也是很重要的优化手段。文中提到的理论和面试知识点请看ElasticSearch理论体系构建,基础操作和一般场景的设计请看ElasticSearch开发指北和场景题分析,结合以上两篇再看本篇体验更佳。

硬件及系统配置优化

常规推荐

ElasticSearch官方推荐生产系统配置,关于系统配置这块真的没啥好操作的,你在网上其他地方看到的性能优化文章大部分都是官方文档的翻译,那为什么不直接看官方文档呢,是吧。系统配置这方面只要是用于生产环境,严格按照官方指示的去做就行了,不要怀疑。

除此之外,还有一些值得说的系统配置可以调整。

  1. ElasticSearch最好单独部署,并且机器内存32G以上,JVM堆内存配置可用内存的一半最好。除非数据量很少,否则堆内存至少8G,太少会导致各种各样的奇怪问题,详见我之前的实战文章。过小的堆内存可能导致频繁的GC操作,而过大的堆内存可能导致长时间的GC暂停,影响性能,垃圾回收器可按需选择,默认G1
  2. Elasticsearch是一个CPU密集型的应用程序,因此建议使用高性能的多核CPU。较高的CPU频率和较多的核心数可以提高搜索和聚合操作的性能。
  3. 硬盘就是能用固态用固态,现在固态价格也被国产打下来了,这对比机械硬盘优势可太大了。

filesystem cache(文件系统缓存)

你往 ElasticSearch 里写的数据,实际上都写到磁盘文件里去了,查询的时候,操作系统会将磁盘文件里的数据自动缓存到 filesystem cache 里面去。es 的搜索引擎严重依赖于底层的 filesystem cache,官方推荐至少将一半可用内存提供给filesystem cache。

这里需要注意的是,文件系统缓存是由操作系统管理的,Elasticsearch 无法直接控制其内部行为。因此,优化文件系统缓存需要在操作系统级别上进行调整和优化,如果只是普通的应用,直接加内存就行了,别调参。

索引及映射配置优化

索引类比于常规关系型数据库的表,但不同于MySQL的表配置那样没啥可操作的,分布式架构下的ElasticSearch索引提供了丰富的配置,能相当大程度的进行性能上的优化。以下是一个待写入大量数据的索引极限配置,接下来会对各个参数进行讲解。

https://www.elastic.co/guide/en/elasticsearch/reference/8.9/tune-for-indexing-speed.html,官方对于提升索引速度也有一个推荐配置,但是不太全面也比较简略,建议还是看我写的比较好。对了,先叠个甲,以下所有我推荐的配置均需按照你自己的机器配置进行调整,最好配合监控,比如Kibana、Prometheus。

{
  "settings": {
    "number_of_shards": n,//分片尽量设置多一些,能提高加载速度
    "number_of_replicas": 0,//副本设置为0,丧失数据安全性
    "refresh_interval": "-1",//刷新时间设置为-1,丧失数据实时性
    "translog.durability": "async",//异步
    "translog.flush_threshold_size": "2gb",//这个参数表示在当未提交的translog日志达到该阈值的时候进行一次刷盘操作。
    "translog.sync_interval": "100s"
  },
  "mappings": {
    "_doc": {
      "properties": {
        "name": {
          "type": "keyword",
          "doc_values":false, //不存储doc,丧失聚合排序等功能
          "index":false  //不索引,丧失查询功能
        }
      }
    }
  }
}

https://www.elastic.co/guide/en/elasticsearch/reference/8.9/index-modules.html,官方的索引模块配置在这里。但对于我们开发者来说,做性能优化只用关注我上面提到的这些,其他的参数并不太影响最后的性能,触发了边际效应,性价比不高。

索引分片配置

https://www.elastic.co/guide/en/elasticsearch/reference/8.9/size-your-shards.html,官方列举了一大堆,反正结论是看你机器配置,我会结合我自己的经验进行讲解以供参考。number_of_shards,分片数量在3-50个最佳,单个分片在2亿数据量以下,大小在50G以内最好,受到索引数据量、删改操作频繁程度和机器硬件影响。

  1. 索引数据量不大的话,其实一小组大分片会比一大组小分片消耗更少的资源,其中性能的差距也不会很明显,但资源的消耗明显,因为分片本身也有信息需要存储且需要被管理。
  2. 增删改操作如果很频繁,会涉及到分片的重新分配和数据迁移,这会引入额外的开销和延迟,一小组大分片的性能会更好。
  3. 如果机器配置比较好的话,一个节点上可以分配多个分片,多个分片会一定程度上提升性能。

索引副本配置

number_of_replicas,副本的选择一般是按你机器配置和使用场景来配置,如果是不太重要的数据或者有别的持久化手段,副本数1就行了。通常会受到如下几个方面的影响:

  1. 读写场景分析,副本数量与读取速度成正相关,与写入速度成反相关。可以把副本当作从库理解,越多副本读取的速度越快,但是写入时更多的副本会带来更多的写入开销和延迟。
  2. 增删改操作频繁的情况下,不适合有过多的部分,会严重影响操作速度。比如上面这个写入性能优化的极端例子,将副本数量暂时设置为0,会极大地提高写入速度,但是因为副本数是动态字段,可以随时调整,大量写入完成后,改成正常的副本数即可,ES会自动创建副本。

索引刷新间隔调整

refresh_interval,索引刷新是将内存中的文档写入磁盘并使其可搜索的过程。这个默认是每秒进行刷新,这也是ElasticSearch是近实时的原因,当然我觉得这对于搜索引擎来说足够了,我自己做的日志收集系统,一般是设置5s。

增加刷新间隔可以减少磁盘写入的频率,减少对磁盘的负载,提高写入性能。较长的刷新间隔可以将多个文档的写入操作合并为一个较大的批量写入操作,减少写入操作的开销。上面这个极端的例子中直接设置为"-1",也就是不刷新数据,这是正式上面不能用的,意味着你新写入的数据是不能被搜索到的,但是无刷新会带来一定程度上的写入性能提升。

综上所述,我们在调整刷新间隔时需要平衡数据可用性和写入性能之间的需求,根据自己的业务场景进行调整。

事务日志配置优化

Elasticsearch的translog(事务日志)是用于持久化未刷新到磁盘的索引操作的机制。

  • “index.translog.durability”,Elasticsearch提供了两种translog持久化策略:request(默认)和async。request策略在每次写入操作后都会调用fsync,将数据持久化到磁盘,提供更高的数据可靠性,但会引入较高的写入延迟。async策略将数据异步地写入磁盘,提供更高的写入性能,但在发生故障时可能会丢失一部分数据。
  • “index.translog.sync_interval”, Translog 多长时间同步到磁盘并提交一次。默认为 5s ,不允许小于 100ms 的值。增加刷新间隔可以减少磁盘写入的频率,从而提高写入性能。然而,较长的刷新间隔会增加数据丢失的风险。
  • “index.translog.flush_threshold_size”,默认为512MB。当translog的大小达到阈值时,会触发translog刷新操作。增加translog的大小可以减少translog刷新的频率,提高写入性能。然而,较大的translog会占用更多的磁盘空间,并且在发生故障时可能会丢失更多的数据。

translog是Elasticsearch重要的持久化机制,因此如果我们能容忍部分数据丢失,那就可以进行调整优化写入性能。

映射配置优化

Elasticsearch默认提供动态映射和显式映射两种配置方式。当我们不知道具体数据格式,可以直接将数据写入索引,Elasticsearch会自动创建映射配置来适配。当然最好还是通过显式映射进行配置,得到最好的性能效果。

  1. 选择合适且尽量准确的数据类型,避免不必要的类型转换开销。数据类型选择时要尽量精简,比如String类型,能用keyword就不要用text。
  2. mapping允许为字段定义各种特性,如索引、存储、排序、分词等。禁用不需要的字段特性可以减少索引和查询的开销

映射这块很重要,配置的时候直接影响索引的大小和速度。补充一下,如果是不常用的字段,可以考虑用运行时字段。

ElasticSearch.yml优化

这个我觉得有必要在安装的时候就做好配置,不像索引修改那么方便了,而且这些配置还挺重要的。

索引缓冲区配置

indices.memory.index_buffer_size: 10%
设置百分比 or 字节大小值。默认为10%,意味着10%分配给节点的总堆将用作所有分片共享的索引缓冲区大小。
indices.memory.min_index_buffer_size: 48m
如果index_buffer_size设置为百分比,则可以使用此设置指定最小值。默认为48mb。
indices.memory.max_index_buffer_size
如果index_buffer_size设置为百分比,则可以使用此设置指定最大值。默认为无限制。

https://www.elastic.co/guide/en/elasticsearch/reference/8.9/indexing-buffer.html,已经索引好的文档会先存放在内存缓存中,等待被写到到段(segment)中。缓存满的时候会触发段刷盘(吃i/o和cpu的操作)。这个索引缓冲区有点类似于MySQL的Buffer Pool,给的越多查询和聚合分析能力越强,这个值一般设置30%或者多一些都可以,这个百分比是设置的Java堆内存百分比。

设置index、merge、bulk、search的线程数和队列数

https://www.elastic.co/guide/en/elasticsearch/reference/8.9/modules-threadpool.html#node.processors,网上其他博客写的线程池数量修改都过时了,新版的参数都是随运行时核数进行调整,而且合理了很多,如无必要,无需修改。

设置FieldDataCache大小

https://www.elastic.co/guide/en/elasticsearch/reference/8.9/modules-fielddata.html,Elasticsearch 的 fielddata 缓存用于存储字段数据的加载和分析结果,以便在查询过程中快速访问。它主要用于支持聚合、排序、脚本计算等需要对字段进行分析和计算的操作。

设置节点之间的故障检测配置

https://www.elastic.co/guide/en/elasticsearch/reference/8.9/modules-discovery-settings.html,官方配置还是太保守了,生产时候不调大点,真的很容易报错和丢节点。

discovery.zen.ping_timeout: 60s      //超时时间,默认3s
discovery.zen.fd.ping_interval: 30s    //节点多久ping一次master,默认1s
discovery.zen.fd.ping_timeout: 60s    //等待响应时间,默认30s
discovery.zen.fd.ping_retries: 6       //失败或超时后重试的次数,默认3

场景方案专项优化

设计阶段调优

  1. 基于数据+时间滚动创建索引,每天递增数据。控制单个索引的量,一旦单个索引很大,存储等各种风险也随之而来,所以要提前考虑及早避免。
  2. 使用别名进行索引管理,方便索引变更之类的切换。
  3. 每天凌晨定时对索引做force_merge操作,以释放空间。
  4. 采取冷热分离机制,热数据存储到SSD,提高检索效率。冷数据定期进行转移到数据库备份,以缩减存储。
  5. 索引和映射配置能优化的进行优化。

写入调优

https://www.elastic.co/guide/en/elasticsearch/reference/8.9/tune-for-indexing-speed.html,以下是我参考官方文档结合自己实践所得。

  1. 写入前副本数设置为0,写入前关闭refresh_interval设置为-1,禁用刷新机制,写入后恢复副本数和刷新间隔。
  2. 写入时采取多线程以及Bulk API批量写入,但也要注意单次写入数据大小不能过大。
  3. 文档ID采用自动生成,Elasticsearch对自动生成的ID有优化,避免了版本查找带来的检查开销。

按照上面的索引和硬件配置进行优化…

查询调优

https://www.elastic.co/guide/en/elasticsearch/reference/8.9/tune-for-search-speed.html,以下是我参考官方文档结合自己实践所得。

  1. 需要大量拉取数据的场景,可以采用search_after 或者 scroll api来实现,而不是from/size一个大范围。
  2. 充分利用文件系统缓存,做一个预热子系统,对热数据定时访问,刷入到缓存。

按照上面的索引和硬件配置进行优化…

分页性能优化

干货 | 全方位深度解读 Elasticsearch 分页查询
关于分页的优化,Elasticsearch目前提供了三种,from + size、scroll和search_after。在小分页,也就是未筛选的查询结果集不超过1W条(Elasticsearch默认只让查1W,但是可配置index.max_result_window)的情况下,用普通的from + size即可。from + size在深度分页场景下,性能差的原因是查询时会创建一个 from+size 的空优先队列,每个分片会返回 from+size 条数据,默认只包含文档 ID 和得分 Score 给协调节点。 如果有 N 个分片,则协调节点再对(from+size)×n 条数据进行二次排序,然后选择需要被取回的文档。当 from 很大时,排序过程会变得很沉重,占用 CPU 资源严重。举几个案例来解释前面这段话:

  1. 我们可以假设在一个有 5 个主分片的索引中搜索。当我们请求结果的第一页(结果从 1 到 10 ),每一个分片产生前 10 的结果,并且返回给 协调节点 ,协调节点对 50 个结果排序得到全部结果的前 10 个。
  2. 现在假设我们请求第 1000 页—结果从 10001 到 10010 。所有都以相同的方式工作除了每个分片不得不产生前10010个结果以外。然后协调节点对全部 50050 个结果排序最后丢弃掉这些结果中的 50040 个结果。

Elasticsearch7之前大家一般用scroll也就是滚动查询来解决这个问题,但从7.*版本开始官方不再推荐使用Scroll方法来进行深分页,而是推荐使用带PIT的search_after来进行查询,参见官网https://www.elastic.co/guide/en/elasticsearch/reference/8.9/paginate-search-results.html#search-after。使用方面见仁见智吧,个人总结如下,按需使用。

分页方式性能优点缺点场景
from + size灵活性好,实现简单深度分页问题,官方不推荐查询超过1W条数据数据量比较小,能容忍深度分页问题
scroll1.解决了深度分页问题,性能相对较好。
2.每个Scroll请求,可以分成多个Slice请求,可以理解为切片,各Slice独立并行,比用Scroll遍历要快很多倍。1.无法反应数据的实时性(快照版本)维护成本高,需要维护一个 scroll_id
2.维护快照会占用较多资源,因为同样是两阶段获取,一阶段初始化获取全部筛选结果的文档ID,二阶段根据ID获取具体数据快照读最友好的场景肯定是导出啦
search_after(ES5+)1.性能最好,能够反映数据的实时变更
2.不需要维护scroll_id,不需要维护快照,因此可以避免消耗大量的资源1.由于无状态查询,因此在查询期间的变更可能会导致跨页面的不一值。(ES7+增加时间点(PIT)来保留索引状态)
2.排序顺序可能会在执行期间发生变化,具体取决于索引的更新和删除。
3.至少需要制定一个唯一的不重复字段来排序。
4.它不适用于大幅度跳页查询,或者全量导出,对第N页的跳转查询相当于对es不断重复的执行N次search after,而全量导出则是在短时间内执行大量的查询。海量数据的分页

外链好文

消息积压问题难?思路代码优化细节全公开

消息积压问题难?思路代码优化细节全公开–2988阅读64赞104收藏

这一篇和本篇相关联的地方在于验证了我前言所说的,给Elasticsearch集群节点划分具体的角色会一定程度上影响整个集群的性能。除此之外,里面也有几个Elasticsearch实战时遇到问题的解决方法,总的来说值得一看。

ElasticSearch不停机重建索引引申来的优化与思考

ElasticSearch不停机重建索引引申来的优化与思考–5175阅读29点赞44收藏,本篇的阅读数超乎我预料的高,让我有点没想到。从我个人写文的出发点来看,本篇并不属于我推崇的体系文章,算是纯纯的实战文章,有大量的问题和详细的操作步骤,和本篇的性能一说有那么点关系,感兴趣的可以看看。

标签:究极,translog,写入,索引,ElasticSearch,分片,天元,size
From: https://blog.csdn.net/skyqiyunhun/article/details/137092067

相关文章

  • ElasticSearch 简单认识
    概念elastic的集群相当于mysql的数据库elastic的索引相当于mysql的表elastic的文档相当于mysql的数据行elastic的字段相当于mysql的列下列操作是在kibana中执行的。我的腾讯云中的用docker拉了elasticsearch和kibana了,通过http://43.143.182.32:9200/访问el......
  • Elasticsearch
    Elasticsearch​ Elasticsearch是一个基于ApacheLucene构建的开源搜索引擎。它提供了一个分布式、多用户能里的全文搜索引擎,基于RESTfulWeb接口。Kibana​ Kibana是一个开源的数据可视化平台,通常与Elasticsearch配合使用,用于搜索、分析和可视化数据。虽然Kinaba......
  • ElasticSearch的监控与优化
    本篇不详写prometheus、grafana的搭建,需要可以翻阅linux监控篇ElasticSearch入门篇一、监控docker-compose.ymlelasticsearch_exporter:#监控image:quay.io/prometheuscommunity/elasticsearch-exporter:v1.3.0command:-'--es.uri=http://elasticsearch:9200'-'......
  • Postgresql同步数据到Elasticsearch
    Postgresql同步数据到es需要借助中间工具连接器,连接器部署主要有两种方式,一种是基于Elastic云托管的连接器(Nativeconnectors),另外一种自己安装管理的连接器(self-managedconnector). 托管方式连接器的使用方法文档:https://www.elastic.co/guide/en/enterprise-search/8.13/......
  • ElasticSearch
    ElasticSearch概述Elasticsearch,简称为es,es是一个开源的高扩展的分布式全文检索引擎,他可以近乎实时的存储、检索数据;本身扩展性很好,可以扩展到上百台服务器,处理PB级别(大数据时代)的数据。es也是用Java开发并使用Lucene作为其核心来实现所有索引和搜索的功能,但是它的目的是通过简......
  • table有关td的究极大坑(同一列的td宽度必定相同,按tr中你td的序号来算)
    0.问题 <fieldsetstyle="border:solid1px#aaa;padding:3px"> <legend>新增产品信息</legend> <divstyle="padding:5px"> <table> <tr> <tdalign="right"> <label......
  • ElasticSearch搜索引擎介绍+性能监控及调优
    ElasticSearch搜索引擎介绍一、概述搜索在现代日常生活场景中都非常常见,如百度、京东、天猫等等。数据量都是庞大的,所以直接基于数据库搜索必定不是他们的首选,在这些场景下,要完成数据的高效搜索,都会基于搜索引擎实现。而对于搜索实现来说,市面上常见三种技术:Lucene、Solr......
  • elasticsearch基础使用
    索引操作mapping映射属性type:字段数据类型,字符串:text(可分词的文本),keyword(精确值,不可以分词的文本)如下图,邮箱就是keyword,名字就是tex数值:long,integer,short,byte,double,float布尔:boolean日期:dateindex:是否创建倒排索引,默认是trueanalyzer:使用哪种分词器properti......
  • Elasticsearch入门及常用命令和Spring中的常用操作
    入门官网简介一个分布式的、Restful风格的搜索引擎。支持对各种类型的数据的检索。搜索速度快,可以提供实时的搜索服务。便于水平扩展,每秒可以处理PB级海量数据。常用术语索引:与MySQL数据库中的Database相对应类型:与MySQL数据库中的Table相对应文档:相当于MySQL中的一......
  • springboot 集成elasticsearch Ik分词
    前提是我们elasticsearch服务已经集成了IK分词,具体集成下载对应的elasticsearchIK分词插件,在es插件包下创建IK文件夹,将下载好的IK包上传上去解压后重启es1、pom引入co.elastic.clientselasticsearch-java7.16.2jakarta.jsonjakarta.json-api2.0.1org.springframew......