当前位置: 首页 > ds >正文

elasticsearch冷热数据读写分离!

一.  需求:

        面对elasticsearch每天存储大量数据且存储时间很长的情况下,比较突出的一个问题是:非常大量的读IO及聚合计算时,很可能会导致后端Load升高,从而阻塞新数据的写入,影响效率。庆幸的是:es提供了一套冷热数据分离的机制。即:将冷数据与热数据通过node隔离;这样,写操作集中在 N 台热数据节点上,大范围的读操作集中在 M 台冷数据节点上。提升检索(消耗cpu及磁盘io)效率的同时,避免了堵塞影响。

二. 冷热分离的核心概念:

   1. 热数据: 近期产生、频繁查询 / 写入的数据(如最近 7 天的日志、实时交易记录),对读写延迟敏感,需高性能存储(SSD)和计算资源。

   2. 冷数据: 历史数据(如 30 天前的日志、归档订单),访问频率低,对性能要求低,可存储在低成本介质(HDD),甚至压缩存储。

   可提升查询性能,也可降低存储成本。 

  3. 原理 :elasticsearch 通过节点属性标记和索引生命周期管理(ILM) 实现冷热分离,核心逻辑是:

      a).  节点按 “热 / 冷” 角色划分(通过自定义属性标记) 。

      b).   新索引自动分配到热节点,承担写入和高频查询。

      c).  当索引满足条件(如时间),通过 ILM 自动迁移到冷节点,并调整存储策略(如压缩、减少副本)。

三. 实现方式:

 1. 首先,我们需要定制各节点属性(tag),如这里的环境3(分离环境用3个是不合理的,后续解释)个节点, 其中1个节点用来做热数据存储,2个节点用来做冷数据存储,配置方法有两种:

             1). 通过elasticsearch.yml配置文件:

node.attr.size: "smail,medium"     #一个属性可以配置多个值(标签)big               #冷数据的标签#也可以通过启动参数指定:
bin/elasticsearch -Enode.attr.rack=rack1 -Enode.attr.size=big 

2. 配置默认index的标签template:

# curl -XPUT 'http://10.0.4.183:9201/_template/default_shards?pretty' -d 
‘{"index_patterns": ["logs-*", "transactions-*"],"settings": {"number_of_shards": 3,"number_of_replicas": 1,"index.routing.allocation.require.box_type": "smail","index.lifecycle.name": "hot-cold-ilm-policy",  # 关联ILM策略(后续定义)}
}’

3. 创建索引的冷热数据生命周期管理策略: 自动迁移冷数据

{"policy": {"phases": {"smail": {"min_age": "0ms","actions": {"rollover": {"max_age": "1d","max_docs": 10000000},"set_priority": { "priority": 100}}},"big": {  #"min_age": "7d","actions": {"allocate": { "require": {"box_type": "cold"}},"shrink": {"number_of_shards": 1},"forcemerge": {"max_num_segments": 1},"set_priority": {"priority": 50}}},"delete": {"min_age": "30d","actions": {"delete": {}}}}}
}#curl -X PUT "http://10.0.4.183:9200/_ilm/policy/hot-cold-ilm-policy" -H "Content-Type: application/json" -d @hot-cold-ilm-policy.json

新索引会自动应用模板中的 index.lifecycle.name,关联 ILM 策略。可通过以下 API 检查:

curl "http://10.0.4.183:9200/logs-2025-08-14/_ilm/explain?pretty"

注意: 需要考虑相关节点数的问题, 比如,我只有三个节点,如果分片需要配置replicas时,会有什么结果?  比如,在这个基础上, 我们的cluster有节点脱离(down)掉,会出现什么情况? 后续做了相关验证后,记录结论。 

-----------------------------------------------------------------------------------------------

                         深耕运维行业多年,擅长运维体系建设,方案落地。欢迎交流!

                                                    V: ywjw996

                                                    《 运维经纬 》

http://www.xdnf.cn/news/17952.html

相关文章:

  • 数学建模-非线性规划模型
  • Linux编程1:进程和线程
  • 目标检测-动手学计算机视觉12
  • 爱情的本质及模拟推演
  • 机器翻译:Hugging Face库详解
  • 模型选择与调优
  • Java 并发新范式:用 Structured Concurrency 优雅收拾多线程烂摊子
  • Linux软件编程:进程和线程
  • 【软考中级网络工程师】知识点之入侵防御系统:筑牢网络安全防线
  • Linux中Samba服务配置与使用指南
  • 计算机毕设大数据选题推荐 基于spark+Hadoop+python的贵州茅台股票数据分析系统【源码+文档+调试】
  • 百川开源大模型Baichuan-M2的医疗能力登顶第一?
  • Flink CDC 实战:实时监听 MySQL Binlog 并同步到 Kafka
  • 《贵州棒球百科》体育赛事排名·棒球1号位
  • 面试题:如何用Flink实时计算QPS
  • 【120页PPT】人工智能与数字化转型的业财融合(附下载方式)
  • 计算机视觉第一课opencv(二)保姆级教
  • 解决SQL Server连接失败:Connection refused: connect
  • H.264、H.265 到 H.266:编码标准演进、RTSP支持与实时视频系统实战
  • 嵌入式学习(day26)frambuffer帧缓冲
  • Vue内置组件全解析:从入门到面试通关
  • 三种DuckDB电子表格插件的union all查询性能对比
  • 基于C语言基础对C++的进一步学习_C和C++编程范式、C与C++对比的一些补充知识、C++中的命名空间、文件分层
  • 流处理 or 批处理?大数据架构还需要流批一体吗?
  • 看懂 Linux 硬件信息查看与故障排查
  • LRU缓存
  • ABP vNext 的工业时间序列治理:InfluxDB vs TimescaleDB 落地对比
  • C++ list模拟实现
  • 推荐系统论文分享之多任务模型--PLE(二)
  • 内存可见性和伪共享问题