百木园一 项目描述
1.1 背景
MHA（Master HA）是一款开源的 MySQL 的高可用程序，它为 MySQL 主从复制架构提供了 automating master failover 功能。MHA 在监控到 master 节点故障时，会提升其中拥有最新数据的 slave 节点成为新的master 节点。自动FailOver的前置条件一定是MHA是启动运行的状态。在生产环境中，有时会因为没有及时开启或者运行异常停止而不知，导致MySQL主节点异常时，没有自动FailOver，影响了生产，或延长了处理时间，使故障升级。
此外，MHA发生FailOver后，MHA的运行状态会由 is running(0:PING_OK) 变更为stopped(2:NOT_RUNNING)，从运行反馈结果变化上，可以判断是否可能发生了主从切换。可以作为一个Warning处理。
综上，对MHA的运行状态的监控很有必要。
1.2 实现设计
MHA是运行在Manager 节点上的，一个Manager 节点可以管理数十个集群。目前，我们的监控体系是Telegraf + InfluxDB + Grafana，所以，需要在Manager 节点部署Telegraf，去收集MHA的运行状态，保存到 InfluxDB。在既有的Grafana MySQL Dashboard中，添加一个关于 masterha_check_status 的panel 即可。
1.2.1 之前的方法
在 《以实现MongoDB副本集状态的监控为例，看Telegraf系统中Exec输入插件如何编写部署》 一文中的第七部分，我们有介绍一种方法实现MySQL MHA的监控，但这种方法是每一个集群都需要手动维护，自动发现的功能不够好，增加维护成本，特别是集团的MHA集群比较多时。
1.2.2 优化后的方法
Manager 节点为每个监控的MHA集群提供一个专用的配置文件，优化后的监控方法，根据配置文件自动发现、自动调整监控，不再需要逐一配置和维护。
部署的步骤如下：
二.实现详情
2.1 编辑Python可执行文件
可执行文件为telegraf_checkmhastatus.py
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import os
import io
import re
import ConfigParser
Path=\'/cnf/mhacnf\'
#fout=open(\'输出文件名\',\'w\')
for Name in os.listdir(Path) :
Pathname= os.path.join(Path,Name)
## print(Pathname)
## print(Name)
config =ConfigParser.ConfigParser()
try:
config.read(Pathname)
server_item = config.sections()
server1_host = \'\' ##MHA cnf 配置文件中的节点1
server2_host = \'\' ##MHA cnf 配置文件中的节点2
server3_host = \'\' ##MHA cnf 配置文件中的节点3
mha_cnf_remark = \'\'
if \'server1\' in server_item:
server1_host = config.get(\'server1\',\'hostname\')
else:
server1_host = \'\'
mha_cnf_remark = mha_cnf_remark + \'Server1未配置;\'
if \'server2\' in server_item:
server2_host = config.get(\'server2\',\'hostname\')
else:
server2_host = \'\'
mha_cnf_remark = mha_cnf_remark + \'Server2未配置;\'
if \'server3\' in server_item:
server3_host = config.get(\'server3\',\'hostname\')
##print(mha_cnf_remark)
except Exception as e:
print(e)
mha_status_result =\'\'
if server1_host <> \'\' and server2_host <> \'\':
cmd_mha_status =\'/usr/local/bin/masterha_check_status --conf=\'+Pathname
with os.popen(cmd_mha_status) as mha_status:
mha_status_result = mha_status.read()
if \'running(0:PING_OK)\' in mha_status_result:
print(\'masterha_check_status,server=\'+server1_host+\' Status=1i\')
print(\'masterha_check_status,server=\'+server2_host+\' Status=1i\')
if \'stopped(2:NOT_RUNNING)\' in mha_status_result:
##else:
print(\'masterha_check_status,server=\'+server1_host+\' Status=0i\')
print(\'masterha_check_status,server=\'+server2_host+\' Status=0i\')
来源：https://www.cnblogs.com/xuliuzai/p/15387089.html
图文来源于网络，如有侵权请联系删除。