要实现对Docker中MySQL服务的慢查询监控并发送企业微信通知，您可以按照以下步骤操作： ### 步骤一：配置 MySQL 监控 确保 Docker 中运行的 MySQL 实例已经正确启用了 `slow_query_log` 功能，并设置好日志文件路径。 ```sql # 登录 MySQL 容器中的数据库 mysql -u root -p # 设置慢查询参数 (假设最小时间为2秒) SET GLOBAL slow_query_log = 'ON'; SET GLOBAL long_query_time = 2; SET GLOBAL slow_query_log_file = '/var/log/mysql/slow-query.log'; SHOW VARIABLES LIKE 'slow_query%'; # 查看当前慢查询记录状态是否开启成功 ``` 注意，在容器环境中可能需要调整默认的日志存储位置为宿主机上的挂载卷内以便后续读取。 ### 步骤二：编写 Python 脚本监测和解析 接下来我们将创建一个简单的Python脚本来定期检查这些日志条目并将相关信息推送到企业的微信机器人API端点上。这里我们使用了第三方库如 `requests` 来处理HTTP请求以及正则表达式来进行模式匹配提取必要的字段信息。 首先安装依赖项： ```bash pip install requests pymysql ``` 然后创建名为 `monitor_mysql_slow_queries.py` 文件包含以下代码： ```python import os, re, time, json from datetime import datetime import requests def send_wechat_message(webhook_url: str, content: dict): """Send message via WeCom WebHook""" headers = {'Content-Type': 'application/json'} payload = {"msgtype": "text", "text": { "content": f"【告警】发现新的慢SQL\n" f"\n开始时间:{content['start']}\n" f"执行语句:\n{content['query'].strip()}" f"\n耗时(s): {round(float(content['time']), 3)}" } } try: resp = requests.post(url=webhook_url, data=json.dumps(payload), headers=headers).json() if not resp.get('errcode') == 0: print(f"[ERROR] Failed to post the alert to WeCom. Error code:", resp.get('errmsg')) except Exception as e: print("[EXCEPTION]", e) if __name__ == '__main__': SLOW_QUERY_LOG_PATH = "/path/to/your/docker/mounted/logs/slow-query.log" # 替换为您的实际路径 last_position = 0 webhook_url = '<Your-WeCom-Robot-API>' # 填入您自己的WebHook URL 地址 while True: with open(SLOW_QUERY_LOG_PATH) as log_file: log_file.seek(last_position) for line in log_file: match = re.search(r'# Time: (\d+-\d+ \d+:)+(\d+)\.\d+\s*' r'(.*?);',line,re.DOTALL|re.IGNORECASE) if match: groups = list(match.groups()) start_timestamp = groups.pop(0)[:19] query_content = ''.join(groups[:-1]).replace('\n',' ') duration_str = '' for piece in reversed(line.split()): if '#' in piece or ';' in piece : break else:duration_str+=piece parsed_duration=float(duration_str.strip())//60 send_wechat_message( webhook_url, {'start':datetime.strptime(start_timestamp,'%Y-%m-%d %H:%M:%S'), 'query':query_content,'time':parsed_duration} ) last_position=log_file.tell() time.sleep(5 * 60) ``` 此段程序会持续监听指定日志文件的变化情况，并根据定义好的规则分析每一行新添加的数据；一旦发现了符合“慢查询”条件的内容就会立即触发向特定群聊或个人用户推送消息的通知行为。 **请注意:** 在生产环境下建议将此类任务封装成定时任务计划(cron job)，而不是直接在主进程中循环等待变化事件的发生以免占用过多资源造成不必要的性能损耗。 #### 注意事项： - 将上述示例中的 `/path/to/your/docker/mounted/logs/slow-query.log` 和 `<Your-WeCom-Robot-API>` 分别替换为您真实的日志存放目录及企业微信号机器人的 API 接口地址； - 根据实际情况修改 `long_query_time` 参数值来适应不同场景下的需求； - 对于较为复杂的企业级应用环境，请考虑采用更加专业的APM工具代替自定义解决方案以获得更全面准确的服务质量跟踪能力。