实战结合官方文档进行学习效果更佳,可以参考本人另一篇简书-官方文档-监控集群(Monitor)翻译。
Monitoring学习方法:在官方文档与源码阅读基础之上进行实战操作

1 Monitoring原理讲解

Monitoring是elastic stack的监控模块,可以用来监控ELKB,监控信息存在es索引中,并且可以通过kibana进行可视化的展示。(收集监控数据的方式从6.5版本起由Collectors-Exporters模式逐步迁移到使用Metricbeat进行收集。)

a 官方文档

学习任何模块都可以从阅读官方文档开始,可以参考本人的官方文档翻译辅助学习。7.10版本官方文档结构如下:

b 源码阅读

旧版本的collector方式源码位于es源码之中,由于目前基于metricbeat方式收集数据维度仍比旧版本小,且二者原理都是调用ELKB提供的API收集,es源码也更具备学习价值,所以这里主要讨论旧版本的源码
Monitoring的源码一共分为两部分:一部分位于xpack.core包中,主要是元数据信息类型代码;一部分位于xpack.monitoring中包,主要是数据收集、导出及索引生命周期策略等实操模块。

Monitor模块按组件分为四类,通过MonitoredSystem枚举区分,每条监控记录都是一条es文档,文档基类为MonitoringDoc,规定了监控记录的统一元数据信息部分(es的监控模块又分为集群,节点,索引,分片等模块,分别继承了MonitoringDoc类,每个单元都有自己独立的数据结构,具体后文详细分析),如下图所以:

实操模块源码包含以下单元:

  • cleaner包:CleanerService实现了监控数据的生命周期管理,默认监控数据按天分索引保留七天,每天凌晨1点会进行全部索引的排查,统一删除过期索引。
  • collector包:Collector类为es监控各个模块的收集器基类,每个模块都以一个独立Collector继承Collector类。主要实现方式是调用es系统提供的监控API获取response构造成对应的MonitoringDoc子类文档。
  • exporter:exporter为数据的导出包,分为两类:导出到本地集群或者导出到专门的监控集群(http方式)。实现方式为es的bulk请求。
  • 监控服务类:MonitoringService和Monitoring类为主要服务实现调度类。主要进行参数设置,收集器导出器配置,并采用单线程调度方式使每个收集器在收集周期(默认10s)内运行一次。

具体源码结构如下图:

c 具体实现

接下来我们具体看一下monitor索引内容以及kibana自带的监控功能

  • monitor索引
    es的监控数据是以统一的索引模板构造的按天分区索引存储的,如下如所示:

    默认索引只保留最近七天的数据,每隔10s会生成一个新的文档。
    .monitoring-es模板mapping包含一些元数据信息如集群id、时间戳和hosts信息等,当前文档类型由type字段标记。每类的数据都有自己独立的一些mapping,如索引信息汇总类数据indices_stats具有主分片和总的数据量、存储占用以及加载查询数据量统计信息。如下图所示:
  • kibana监控功能
    kibana监控模块通过调用es索引存储的监控数据,制作了许多开箱即用报表供用户使用。主要分为集群层面、节点层面和索引层面。


    kibana通过es索引中存储的数据计算出了许多指标报表,如上图所示包含了查询(加载)速率查询(加载)延时,除此之外还有cpu、内存、存储以及负载占用等等许多指标。
    #2 kibana可视化实战
    接下来我们具体分析上图的四个指标并通过kibana的TSVB(时间序列的可视化报表)实现这四个指标。
  • 查询速率
    对于单个索引,它是每秒的查询次数(分片级别,不是请求级别),也就意味着一次查询请求命中的分片数越多,值越大。对于多个索引,它是每个索引的搜索速率的总和。
    (例:一个2分片1副本的索引,进行一个查询操作, 索引中的查询数量指标index_stats.total.search.query_total
    增加2(与副本数量无关。只与分片数量有关)。Kibana监控界面10分钟间隔时间段内有20个统计点,每个统计点时间间隔为600s/20=30s,计算速度为:Total Shards:2/30=0.067/s)
  • 加载速率
    对于单个索引,它是每秒索引文档的数量;对于多个索引,它是每个索引的索引速率之和。
    (例:一个3分片1副本的索引,加载三条数据入库, index_stats.primaries.indexing.index_total会增加3条,index_stats.total.indexing.index_total会增加6条。Kibana监控界面10分钟间隔时间段内有20个统计点,每个统计点时间间隔为600s/20=30s,计算速度为:Primary Shards:3/30=0.1/s Total Shards:6/30=0.2/s)
  • 查询延时
    查询的平均延时,为执行查询消耗的时间除以查询数量,考虑主副分片。
    (例:index_stats.total.search.query_time_in_millis增长2,index_stats.total.search.query_total增长1,则计算结果为2/1=2,且由于query_time_in_millis和query_total可能在某段时间不变,所以图像不连续)
  • 加载延时
    加载延时,为执行加载消耗的时间除以文档数量,只考虑主分片。
    (例:index_stats.primaries.indexing.index_time_in_millis增长6,index_stats.primaries.indexing.index_total增长5,则计算结果为6/5=1.2。且由于index_time_in_millis和index_total可能在某段时间不变,所以图像不连续)

通过TSVB进行报表实现索引级别四个指标报表:

  1. 首选选定报表需要使用的索引,以及时间序列使用的时间字段和统计时间间隔:

    我们使用通配符匹配存储es监控数据的索引,并以时间戳为时间序列字段,每隔30s生成一个数据点。(Drop last bucket含义为去掉最后一个统计点,因为es数据实时可见性具有一个延时refresh_interval,所以可能造成最后一个统计点不准的问题,所以我们可以去掉最后一个统计点保证图像的可靠性。)
  2. 构造报表函数,通过上一章节对四个指标的分析,使用对应的指标项进行函数构造。
    • 查询速率的构造是基于index_stats.total.search.query_total指标项,我们将其对时间进行求导得出的即为查询速率,将其结果进行按索引名分组,即可显示每个索引的查询速率。
    • 查询延时的构造是基于index_stats.total.search.query_time_in_millisindex_stats.total.search.query_total两个指标,我们将其差值做比即可得到查询延时,将其结果进行按索引名分组,即可显示每个索引的查询查询。(除了差值Serial Difference做比,求导Derivative做比也同样可以获得结果)

      加载速率和加载延时你是否可以自己做出?动手实现吧

es实战-Monitoring原理讲解及kibana可视化实战相关推荐

  1. python实战讲解_Python数据可视化实战讲解

    前言 本文的文字及图片来源于网络,仅供学习.交流使用,不具有任何商业用途,版权归原作者所有,如有问题请及时联系我们以作处理. 开运张 | 作者 知乎专栏 | 来源 三个步骤:确定问题,选择图形 转换数 ...

  2. JVM实战与原理--前言及索引

    JVM实战与原理 大纲 在Java入门课中,我们编写HelloWorld.java文件,用命令行运行javac后生成HelloWorld.class,之后用java命令运行HelloWorld.cla ...

  3. 大数据图书分享-Python数据可视化实战课程

    Python数据可视化实战课程内容以实践出发,全面地介绍了数据可视化流程和Python数据可视化的应用,并详细阐述了使用Python解决企业实际问题的方法. 全书设计思路以应用为导向,让用户明确如何利 ...

  4. 刘永鑫:20分钟讲解微生物组数据分析与可视化实战

    编者按: 2020 年 12 月 21 日,国内著名英文期刊 Protein & Cell 与热心肠研究院合作,成功举办了"Protein & Cell人类微生物组专刊线上论 ...

  5. Kibana可视化管理页面详细使用说明

    Kibana可视化管理页面详细使用说明 使用浏览器访问 ip:5601 默认端口,进入首页 Discover:日志管理视图  主要进行搜索和查询 Visualize:统计视图      构建可视化的图 ...

  6. 《D3.js数据可视化实战手册》——2.5 使用子选择器

    本节书摘来异步社区<D3.js数据可视化实战手册>一书中的第2章,第2.5节,作者: [加拿大]Nick Qi Zhu,更多章节内容可以访问云栖社区"异步社区"公众号查 ...

  7. JVM实战与原理---内存回收策略

    JVM实战与原理 目录 内存回收策略 1. 堆的划分 2. 判断对象是否存活的算法介绍 2.1 引用计数算法 2.2 可达性分析算法 3. 可回收的内存区域清理的算法介绍 3.1 标记-清除算法 3. ...

  8. JVM实战与原理---字节码执行引擎

    JVM实战与原理 目录 字节码执行引擎 1. 方法区 2. 栈帧 2.1 局部变量表 2.2 操作数栈 2.3 动态连接 2.4 方法返回地址 字节码执行引擎 章节目的:虚拟机是如何找到正确的方法,如 ...

  9. 《D3.js数据可视化实战手册》—— 1.1 简介

    本节书摘来异步社区<D3.js数据可视化实战手册>一书中的第1章,第1.1节,作者: [加拿大]Nick Qi Zhu,更多章节内容可以访问云栖社区"异步社区"公众号查 ...

最新文章

  1. OpenStack collectd的从零安装服务端
  2. Redis进阶-Redis的惰性删除
  3. 畅享云游戏,AWS云峰会邀你零距离体验强化学习!
  4. 库洛游戏首次公开分享:《战双帕弥什》的动作打击感是怎么做出来的
  5. BoltDB 源码分析
  6. 【C语言笔记】关于数组的一个陷阱!
  7. 大数据ab 测试_在真实数据上进行AB测试应用程序
  8. 计算机网络(十六)-轮询访问介质访问控制
  9. Java 蓝桥杯 字符串基本用法
  10. 摆脱jquery,用自己的JS库实现ajax功能
  11. 如何在Mac上批量转换和调整图像大小
  12. Atitit 歌词成语提取项目 nlp 人工智能项目 目录 1.1. 流程 首先搜集3w成语词库 1 1.2. 歌词常用成语400个 按照拼音排序 1 1.1.流程 首先搜集3w成语词库 放入m
  13. 德国Taufenbach激光打标机电源维修RFE020详解
  14. 香港90年代电视剧推荐
  15. stm32项目实战ST7735环境质量检测仪
  16. 2019年12月份统考计算机应用基础题库,2019年12月网络教育统考《计算机应用基础》模拟题...
  17. 【Bugku】Misc2
  18. 新闻资讯博客小程序源码/支持微信、QQ、百度小程序/支持流量主
  19. docx转换为doc格式,公式变成图片问题,word2016
  20. 企业选择服务器托管好吗

热门文章

  1. 鼠标右键失灵怎么办鼠标右键失灵原因与解决办法怎么启用javascri
  2. linux invalid argument_Linux | 那些年学习Linux你被坑过的故障集合
  3. Java API文档
  4. 微信公众号开发(消息推送)
  5. poi下载模板含下拉框
  6. Xilinx FPGA平台GTX简易使用教程(汇总篇)
  7. 408计算机组成思维导图(各章节清晰详细可下载导图文件)
  8. 数据中台到底是解决什么问题的
  9. shell脚本编程笔记(十二)—— gawk程序
  10. 脑机接口基础学习03-认识及创建Epoch