阿里云-云小站(无限量代金券发放中)
【腾讯云】云服务器、云数据库、COS、CDN、短信等热卖云产品特惠抢购

通过修改Zabbix官方redis模板监控微软云Azure上多台MySQL实例

147次阅读
没有评论

共计 6959 个字符,预计需要花费 18 分钟才能阅读完成。

由于微软云上的 MySQL 实例无法安装插件来导出数据,因此参考上一篇   通过 Zabbix 官方模板监控微软云 Azure 上多台 Redis 实例,我们可以修改 zabbix 官方 redis 脚本,通过 show status 等命令获取到 mysql 的状态指标,用 trap-messages 模式发送给 zabbix 来监控微软云上的 MySQL 实例。

1. 运行环境:

OS:CentOS 7.3 / Python: 2.7.3/ Pip: 9.0.1  / Zabbix:3.2.8 / MySQL: 微软云 MySQL 5.7

Zabbix 官方提供的 redis 监控模板,我们修改官方提供的 python 脚本来监控 MySQL。

项目地址:https://github.com/blacked/zbx_redis_template

Zabbix 所有官方模板:http://www.zabbix.org/wiki/Zabbix_Templates

2. 部署 

trap-messages 方式的说明请参考上一篇   通过 Zabbix 官方模板监控微软云 Azure 上多台 Redis 实例。

1> 安装 Python 依赖

# yum -y install python-pip
# pip install argparse
# pip install pymysql

2> 将 zbx_redis_stats.py 放到 zabbix 服务器上某路径下并重命名,如 /etc/zabbix/script/mysql/zbx_mysql_stats.py。

3> 修改脚本,下面是我修改的脚本,监控了 show status 获取的信息以及数据库表占用的空间等信息,可以直接拷贝,或者添加自己需要监控的其他信息。

# !/usr/bin/python

import sys, pymysql, json, re, struct, time, socket, argparse

parser = argparse.ArgumentParser(description=’Zabbix MySQL status script’)
parser.add_argument(‘mysql_hostname’, nargs=’?’)
parser.add_argument(‘metric’, nargs=’?’)
parser.add_argument(‘db’, default=’none’, nargs=’?’)
parser.add_argument(‘-p’, ‘–port’, dest=’mysql_port’, action=’store’, help=’MySQL server port’, default=3306, type=int)
parser.add_argument(‘-a’, ‘–auth’, dest=’mysql_pass’, action=’store’, help=’MySQL server pass’, default=None)
parser.add_argument(‘-u’, ‘–user’, dest=’mysql_user’, action=’store’, help=’MySQL server user’, default=None)
args = parser.parse_args()

zabbix_host = ‘127.0.0.1’  # Zabbix Server IP
zabbix_port = 10051  # Zabbix Server Port

# Name of monitored server like it shows in zabbix web ui display
mysql_hostname = args.mysql_hostname if args.mysql_hostname else socket.gethostname()

class Metric(object):
    def __init__(self, host, key, value, clock=None):
        self.host = host
        self.key = key
        self.value = value
        self.clock = clock

    def __repr__(self):
        result = None
        if self.clock is None:
            result = ‘Metric(%r, %r, %r)’ % (self.host, self.key, self.value)
        else:
            result = ‘Metric(%r, %r, %r, %r)’ % (self.host, self.key, self.value, self.clock)
        return result

def value_format(value):
    if value.isdigit() is True:
        value = int(value)
    return value

def send_to_zabbix(metrics, zabbix_host=’127.0.0.1′, zabbix_port=10051):
    result = None
    j = json.dumps
    metrics_data = []
    for m in metrics:
        clock = m.clock or (‘%d’ % time.time())
        metrics_data.append(
            (‘{“host”:%s,”key”:%s,”value”:%s,”clock”:%s}’) % (j(m.host), j(m.key), j(m.value), j(clock)))
    json_data = (‘{“request”:”sender data”,”data”:[%s]}’) % (‘,’.join(metrics_data))
    data_len = struct.pack(‘<Q’, len(json_data))
    packet = ‘ZBXD\x01’ + data_len + json_data

    # For debug:
    # print(packet)
    # print(‘:’.join(x.encode(‘hex’) for x in packet))

    try:
        zabbix = socket.socket()
        zabbix.connect((zabbix_host, zabbix_port))
        zabbix.sendall(packet)
        resp_hdr = _recv_all(zabbix, 13)
        if not resp_hdr.startswith(‘ZBXD\x01’) or len(resp_hdr) != 13:
            print(‘Wrong zabbix response’)
            result = False
        else:
            resp_body_len = struct.unpack(‘<Q’, resp_hdr[5:])[0]
            resp_body = zabbix.recv(resp_body_len)
            zabbix.close()

            resp = json.loads(resp_body)
            # For debug
            # print(resp)
            if resp.get(‘response’) == ‘success’:
                result = True
            else:
                print(‘Got error from Zabbix: %s’ % resp)
                result = False
    except:
        print(‘Error while sending data to Zabbix’)
        result = False
    finally:
        return result

def _recv_all(sock, count):
    buf = ”
    while len(buf) < count:
        chunk = sock.recv(count – len(buf))
        if not chunk:
            return buf
        buf += chunk
    return buf

def main():
    if mysql_hostname and args.metric:

        client = pymysql.connect(host=mysql_hostname, user=args.mysql_user, password=args.mysql_pass)
        cursor = client.cursor()
        cursor.execute(“show status”)
        data = cursor.fetchall()
        dict_local = {}
        for k, v in data:
            dict_local[k] = v

        cursor.execute(“select SCHEMA_NAME from information_schema.schemata “)
        db = cursor.fetchall()
        dblist = []
        for i in db:
            dblist.append(i[0])

        if args.metric:
            def list_db():
                if args.db in dblist:
                    print(dblist)
                else:
                    print(‘database_detect’)

            def default():
                if args.metric in dict_local.keys():
                    print(dict_local[args.metric])

            {
                ‘list_db’: list_db
            }.get(args.metric, default)()

        else:
            print(‘Not selected metric’)
    else:
        client = pymysql.connect(host=mysql_hostname, user=args.mysql_user, password=args.mysql_pass)
        cursor = client.cursor()
        cursor.execute(“show status”)
        data = cursor.fetchall()

        a = []
        for k, v in data:
            k = k.lower()
            v = value_format(v)
            a.append(Metric(mysql_hostname, (‘azuremysql[%s]’ % k), v))

        # cursor.execute(“show processlist;”)
        cursor.execute(“select count(*) from information_schema.processlist;”)
        processdata = cursor.fetchall()
        # process_count = len(processdata)
        process_count = processdata[0][0]
        a.append(Metric(mysql_hostname, ‘azuremysql[process_count]’, process_count))

        cursor.execute(
            “select table_schema,round(sum(data_length+index_length)/1024/1024,4) from information_schema.tables group by table_schema;”)
        spacedata = cursor.fetchall()
        totalspace = 0
        for k, v in spacedata:
            a.append(Metric(mysql_hostname, (‘azuremysql[%s]’ % k), float(v)))
            totalspace += float(v)
        a.append(Metric(mysql_hostname, ‘azuremysql[totalspace]’, totalspace))

        # Send packet to zabbix
        send_to_zabbix(a, zabbix_host, zabbix_port)
        # for i in a:
        #  print(i)
        cursor.close()
        client.close()

if __name__ == ‘__main__’:
    main()

 

zbx_mysql_stats.py可以到 Linux 公社资源站下载:

—————————————— 分割线 ——————————————

免费下载地址在 http://linux.linuxidc.com/

用户名与密码都是www.linuxidc.com

具体下载目录在 /2017 年资料 /10 月 /10 日 / 通过修改 Zabbix 官方 redis 模板监控微软云 Azure 上多台 MySQL 实例 /

下载方法见 http://www.linuxidc.com/Linux/2013-07/87684.htm

—————————————— 分割线 ——————————————

4>  测试脚本是否可以正常连接到微软云上 MySQL 并获取参数:

/etc/zabbix/script/mysql/zbx_mysql_status.py -u mysqluser -a mysqlpasswd test.mysqldb.chinacloudapi.cn list_db 

5> 添加 crontab,定期执行脚本发送数据给 zabbix,注意若密码中含有 % 需要用 \ 进行转义 (\%)。

若要监控多台 MySQL,则添加多个 crontab:

*/1 * * * * /etc/zabbix/script/mysql/zbx_mysql_status.py -u mysqluser -a mysqlpasswd test.mysqldb.chinacloudapi.cn

6> 创建 MySQL 监控模板,注意监控项类型应选择 ”zabbix 采集器 ”,若使用的脚本,键值为 ”azuremysql[xxxxxxx]”,否则请使用自己脚本定义的键值。

附件是我创建的一个模板,添加了一些监控项,并不完整,可以在此基础上再添加需要的监控项。

 zbx_Azure_MySQL_template.xml  (下载见上面的 Linux 公社资源站)

7> 使用 MySQL hostname 创建主机,链接模板,即可实现 zabbix 监控。

通过修改 Zabbix 官方 redis 模板监控微软云 Azure 上多台 MySQL 实例

更多 Zabbix 相关教程集合 

在 Ubuntu 16.04 服务器上安装 Zabbix 3.2  http://www.linuxidc.com/Linux/2017-07/145519.htm 

CentOS 7 LNMP 环境搭建 Zabbix3.0  http://www.linuxidc.com/Linux/2017-02/140134.htm 

Ubuntu 16.04 安装部署监控系统 Zabbix2.4  http://www.linuxidc.com/Linux/2017-03/141436.htm 

Zabbix 监控安装部署及警报配置  http://www.linuxidc.com/Linux/2017-03/141611.htm 

Zabbix 触发器表达式详解 http://www.linuxidc.com/Linux/2017-03/141921.htm 

Ubuntu 16.04 下安装部署 Zabbix3.0  http://www.linuxidc.com/Linux/2017-02/140395.htm 

CentOS 6.3 下 Zabbix 监控 apache server-status http://www.linuxidc.com/Linux/2013-05/84740.htm 

CentOS 7 下 Zabbix 3.0 安装详解 http://www.linuxidc.com/Linux/2017-03/141716.htm 

CentOS 7.4 安装 Zabbix 3.4  http://www.linuxidc.com/Linux/2017-09/147202.htm

64 位 CentOS 6.2 下安装 Zabbix 2.0.6   http://www.linuxidc.com/Linux/2014-11/109541.htm 

ZABBIX 的详细介绍:请点这里
ZABBIX 的下载地址:请点这里

本文永久更新链接地址:http://www.linuxidc.com/Linux/2017-10/147414.htm

正文完
星哥说事-微信公众号
post-qrcode
 
星锅
版权声明:本站原创文章,由 星锅 2022-01-21发表,共计6959字。
转载说明:除特殊说明外本站文章皆由CC-4.0协议发布,转载请注明出处。
【腾讯云】推广者专属福利,新客户无门槛领取总价值高达2860元代金券,每种代金券限量500张,先到先得。
阿里云-最新活动爆款每日限量供应
评论(没有评论)
验证码
【腾讯云】云服务器、云数据库、COS、CDN、短信等云产品特惠热卖中