帮忙写一个完善的监控工具，用来监控docker部署的mysql服务的慢查询，检测到慢查询的时候结果通知在企业微信；结果通知包含：慢查询开始时间，慢查询sql，慢查询耗时等。

要构建这样一个监控 Docker 部署 MySQL 服务中慢查询并能将检测到的信息发送至企业微信的工具，你可以按照以下步骤操作： ### 一、配置MySQL捕获慢查询首先确保你的 MySQL 已经正确配置了慢查询日志功能。 1. **编辑my.cnf** (或对应的ini文件) - 找到或创建 `mysqld` 段落下添加/修改这些设置以开启慢查询记录（根据实际需求调整时间和阈值）： ```conf slow_query_log = ON long_query_time = 2 # 单位秒, 设置多少秒以上的SQL被认为是“慢”的，默认是10s. log_output=FILE # 或TABLE 如果希望数据存储在数据库表内而非外部文件 ``` 2. **重启 MySQL** - 更改以上参数后保存并重新启动 MySQL 实例使更改生效。 3. **验证是否启用成功** - 登录 MySQL 客户端执行命令查看当前状态： ```sql SHOW VARIABLES LIKE 'slow_query%'; ``` ### 二、编写Python脚本抓取和分析慢查询信息接下来我们将利用 Python 编程语言结合官方提供的 mysqldb 库来读取 MySQL 内部生成的日志条目，并从中筛选出我们关心的数据字段如开始时间、SQL语句本身以及执行所需的时间等信息。此外还需要安装 requests 包用于后续向企业微信推送消息的功能实现。（如果你使用的是 Python 3.x 版本，请注意库名可能是 pymysql） - 使用 pip 安装必要的依赖包： ```bash pip install pymysql requests ``` - 下面是一个简单的 python 示例代码片段展示如何连接到 Mysql 获取慢查询列表并且格式化输出成字符串形式准备传递给聊天机器人 API: ```python import pymysql from datetime import timedelta import json import time import os # 连接到本地运行中的MYSQL实例 conn = pymysql.connect(host='localhost', port=3306,user='root',password='your_password') cursor = conn.cursor() try: cursor.execute("select * from INFORMATION_SCHEMA.SLOW_LOG where start_time >= NOW() - INTERVAL %s HOUR;"%(int(os.getenv('HOURS_LOOKBACK','1')))) results = cursor.fetchall() finally: cursor.close() conn.close() if not results: print('No Slow Queries Found.') else: for row in results: msg="【告警】发现一条慢查询:\n" \ f"- 查询发起时刻:{row.strftime('%Y-%m-%d %H:%M:%S')}\n"\ f"- SQL内容为：{str(row)[:80]+'...' if len(str(row))>80 else str(row) }\n"\ "- 查询持续时长(s)：" + "{:.4}".format(float(row)) send_to_wechat(msg) def send_to_wechat(message): webhook_url=os.environ.get('WECHAT_WEBHOOK_URL') headers={'Content-Type': 'application/json'} payload={ "msgtype": "text", "text": { "content": message, "mentioned_mobile_list":["@all"] } } response=requests.post(webhook_url,json=payload,headers=headers) return response.status_code == 200 and response.json().get('errmsg')=='ok' ``` 此段程序会从 INFORMAITON_SCHEMA 中拉取过去一段时间内的所有慢查询请求并将每一条组装成为易于阅读的消息文本最终调用辅助方法send_to_wechat 方法推送给指定的企业微信群聊当中去。 ### 三、定时任务调度为了保证系统能够周期性的检查是否有新的慢查询产生，建议采用 Linux 系统自带 crontab 功能或者是更复杂的分布式任务调度框架比如 Celery 来安排上述 Python 脚本定期触发运行。假设您想每天凌晨两点整自动地执行一次这个监控动作，在 shell 终端里输入如下指令设定计划任务即可： ```shell crontab -e ``` 追加一行规则表示“每日清晨两小时零分”执行该 py 文件： ```cronjob 0 2 * * * /usr/bin/python3 /path/to/your/script.py > /dev/null 2>&1 ``` 这行规则意味着不管哪一天都会在当地标准时间为上午两点钟的时候让操作系统负责唤醒我们的脚本进程来进行一轮全面扫描工作。

创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考

下一篇 C# websocket winform连接服务器