Zabbix监控MySQL的MGR群集状态教程

字数 4997阅读 368评论 0赞 0

内容摘要：

文章介绍了如何通过Zabbix监控MySQL的MGR群集状态，包括创建监控模板和监控节点状态和同步状态出现错误的情况。

当前摘要为AI生成

作者  广东乐维软件有限公司  许远
MySQL的MGR（MySQL Group Replication）是MySQL官方提供的一种高可用性和高可靠性的集群解决方案。MGR通过使用基于组复制的方式，实现了多个MySQL实例之间的数据同步和故障转移，从而提供了自动故障恢复和负载均衡的功能。 本文将介绍如何通过Zabbix监控 MySQL 的MGR群集状态。
**1.****给M****GR群集内的数据库****监控账号赋权(这里用的zbx****user)******
 grant select on performance_schema.replication_group_members to ' zbxuser '@'%';
 刷新mysql配置
 flush privileges;
**2. 在pymys.py内添加MGR监控脚本******
 cd /itops/zabbix/share/zabbix/externalscripts #zabbix的外部检查目录
 vim pymys.py 写入以下内容：
!/usr/bin/env python3
encoding=utf-8
edit by yang hao
version 0.1
import argparse
import pymysql
import inspect
import json
import re
class Checks(object):
    def mysql_mgr_state(self):
        #print('11')
        #print(self.args.text)
        #sql = 'select * from performance_schema.replication_group_members;'
        sqlhost = 'select MEMBER_HOST from performance_schema.replication_group_members;'
        self.cur.execute(sqlhost)
        res = self.cur.fetchall()
        key = ['{#MEMBERHOST}']
        lst = []
        for i in res:
            d = dict(zip(key, i))
            lst.append(d)
        print(json.dumps({'data': lst}))

def mysql_mgr_status(self):
        name = self.args.text
        #print(name)
        sql = "select MEMBER_STATE from performance_schema.replication_group_members where MEMBER_HOST='%s'" % (name)+ ";"
        if self.cur.execute(sql):
            res = self.cur.fetchall()[0][0]
            print(res)
        else:
            print("Empty set")

def mysql_mgr_id(self):
        name = self.args.text
        #print(name)
        sql = "select MEMBER_ID from performance_schema.replication_group_members where MEMBER_HOST='%s'" % (name)+ ";"
        if self.cur.execute(sql):
            res = self.cur.fetchall()[0][0]
            print(res)
        else:
            print("Empty set")

class Main(Checks):
    def __init__(self):
        parser = argparse.ArgumentParser()
        parser.add_argument('--ip')
        parser.add_argument('--username')
        parser.add_argument('--password')
        parser.add_argument('--port')
        parser.add_argument('--database')
        parser.add_argument('--text')

subparsers = parser.add_subparsers()

for name in dir(self):
            if not name.startswith("_"):
                p = subparsers.add_parser(name)
                method = getattr(self, name)
                argnames = inspect.getargspec(method).args[1:]
                for argname in argnames:
                    p.add_argument(argname)
                p.set_defaults(func=method, argnames=argnames)
        self.args = parser.parse_args()

def db_connect(self):
        a = self.args
        ip = a.ip
        username = a.username
        password = a.password
        port = int(a.port)
        database = a.database
        self.db = pymysql.connect(host = ip, port = port, user = username,passwd = password, db = database)
        self.cur = self.db.cursor()

def db_close(self):
        self.cur.close()
        self.db.close()

def __call__(self):
        try:
            a = self.args
            callargs = [getattr(a, name) for name in a.argnames]
            self.db_connect()
            try:
                return self.args.func(*callargs)
            finally:
                self.db_close()
        except Exception as err:
            print("0")
            print(str(err))

if __name__ == "__main__":
    main = Main()
    main()

vim pymys 写入以下内容：
```
#!/usr/bin/bash
/usr/bin/python3 /itops/zabbix/share/zabbix/externalscripts/pymys.py —ip $1 —username $2 —password $3 —port $4 —database $5 $6 $7 $8
```
**3. 测试命令参考：******
 ./pymys 数据库地址  用户名  密码  端口号  库名 mysql_mgr_state //返回数据类似下图即可
![](/home/attachment/202403/27/1235613_171151995255321.png)
测试拿群集状态信息： ./pymys 数据库地址  用户名  密码  端口号  库名 --text 节点名称 mysql_mgr_status
![](/home/attachment/202403/27/1235613_171151997942641.png)
**4. 在mysql监控模板创建自动发现规则******
 名称： MGR监控
 类型：外部检查
 键值： pymys[{$ADDRESS},{$USERNAME},{$PASSWORD},{$PORT},{$DATABASE},mysql_mgr_state]
![](/home/attachment/202403/27/1235613_171151999032199.png)
**5. 创建监控项原型一******
 名称： {#MEMBERHOST}的节点ID
 类型：外部检查
 键值： pymys[{$ADDRESS},{$USERNAME},{$PASSWORD},{$PORT},{$DATABASE},--text,{#MEMBERHOST},mysql_mgr_id]
![](/home/attachment/202403/27/1235613_171152001035347.png)
**6. 创建监控项原型二******
 名称： {#MEMBERHOST}的状态
 类型：外部检查
 键值： pymys[{$ADDRESS},{$USERNAME},{$PASSWORD},{$PORT},{$DATABASE},--text,{#MEMBERHOST},mysql_mgr_status]
![](/home/attachment/202403/27/1235613_171152002346824.png)
**7. 创建触发器类型******
![](/home/attachment/202403/27/1235613_171152003857859.png)
名称: [数据库:MYSQL]{#MEMBERHOST}此节点与其他节点同步状态出现错误
 表达式 :
 V： OFFLINE|ERROR|UNREACHABLE
![](/home/attachment/202403/27/1235613_171152005194329.png)
上就是这一期的Zabbix技术分享内容。

监控 Zabbix

著作权归作者所有

如果觉得我的文章对您有用，请点赞。您的支持将鼓励我继续创作！

添加新评论0 条评论

Ctrl+Enter 发表

匿名评论

Zabbix监控MySQL的MGR群集状态教程

添加新评论0 条评论

文章目录展开目录

作者其他文章

相关文章

相关问题

相关资料