MysqlAlarm

mysql 报警

使用方法

import json

from alarm import Alarmer
from alarm import all_funcs
from handler import dingding_handler, mail_handler, fake_handler
from logger import Logger

if __name__ == '__main__':
    my_logger = Logger(stream=True, file=True).get_logger()
    with open("config.json", "r", encoding="utf-8") as f:
        configs = json.load(f)['databases']
    for config in configs:
        user = config.get("user")
        passwd = config.get("passwd")
        host = config.get("host")
        port = config.get("port")
        slaves = config.get("slaves")
        tags = config.get("tags")
        my_functions = ["disk", "thread_connect", "innodb_buffer_hint_precent"]
        my_func_dic = {name: all_funcs.get(name) for name in my_functions}
        try:
            with Alarmer(user=user, passwd=passwd, host=host, port=port, slaves=slaves,
                         alarm_handler=[fake_handler], tags=tags, logger=my_logger,
                         funcs=my_func_dic
                         ) as client:
                client.run()
        except Exception as e:
            my_logger.error(f"Addr:{host}:{host},User:{user},Password:{passwd},{e}")

my_functions可以根据名称选择需要的监控参数
多线程使用参见threading_demo.py

Logger选择

可选择stream和file两种handler file handler 默认文件名为当前日期.log
默认选择的default_logger选择的是stream handler
如选择file handler

from logger.logger import Logger
file_logger = Logger(stream=False,file=True).get_logger()

并将file_logger传入DBUtil中

扩展

通知

在handler中可以编写自己的通知函数，接收参数有(host, parameter, current, threshold, th_type,tags) 扩展参照dingding

添加监控参数

可以在get_params.py中添加自己需要的参数，示例如下：

def get_mysql_disk(db):
    # 占用空间
    db.dict_cursor.execute(
        "select TABLE_SCHEMA, concat(truncate(sum(data_length)/1024/1024,2)) as data_size,concat(truncate(sum("
        "index_length)/1024/1024,2)) as index_size from information_schema.tables group by TABLE_SCHEMA,"
        "data_length,index_length order by data_length desc;")
    res = db.dict_cursor.fetchall()
    data_size = sum([float(x["data_size"]) for x in res if x["data_size"] is not None])
    index_size = sum([float(x["index_size"]) for x in res if x["index_size"] is not None])
    db.params.update({"Size": round((data_size + index_size), 2)})


get_mysql_disk.name = "disk"

函数会自动进行调用

配置说明

数据库配置

在根目录创建config.json
主要保存数据库连接信息和从节点信息，建议单独创建用户，权限根据所需查询参数配置

{
  "databases": [
    {
      "user": "user1",
      "passwd": "pwd",
      "host": "127.0.0.1",
      "port": 3306,
      "slaves": [
        "xx.xx.xx.xx",
        "xx.xx.xx.xx"
      ],
      "tags": "tag"
    },{
      "user": "user",
      "passwd": "pwd",
      "host": "xx.xx.xx.xx",
      "port": 3306,
      "tags": "tag1"
    }
  ]}

handler中的配置

dingding:
conf.json其中的配置详细见钉钉机器人文档，如果不需要代理则直接删除proxies即可

{
  "secret": "secret",
  "url": "",
  "proxies": {
    "http": "",
    "https": ""
  }
}

mail:

{
  "username": "username",
  "password": "password",
  "host": "mailhost",
  "receiver": ["xxx@xxx.com","xxx@xx.com"]
}