要创建这样一个监控工具，你可以按照以下步骤进行： ### 步骤一：准备环境 确保你的环境中已经安装了Docker、MySQL以及Python（或其他你喜欢的脚本语言）。此外，你需要获取企业微信API的相关信息如corpid, corpsecret和agentid。 ### 步骤二：编写Shell或Python脚本来定期检查慢查询日志 这里我们用Python作为例子。首先连接到运行中的 MySQL 容器并配置好`slow_query_log_file`的位置和其他必要的参数。然后利用 Python 连接数据库读取 slow log 文件内容或者直接执行 SQL 查询从 `information_schema.SLOW_LOG` 表中提取数据。 ```python import pymysql from datetime import datetime import time import requests def get_slow_queries(): connection = None try: # Connect to the database inside Docker container. connection = pymysql.connect( host='localhost', user='your_user', password='your_password', db='mysql' ) with connection.cursor() as cursor: sql = "SELECT start_time, query_time, sql_text FROM information_schema.SLOW_LOG ORDER BY start_time DESC LIMIT 10;" cursor.execute(sql) results = cursor.fetchall() return [{"start_time": row, "query_time": row.total_seconds(), "sql_text": row} for row in results] finally: if connection is not None and connection.open: connection.close() # Function to send message via WeCom (Work WeChat) API def notify_wechat(msg): access_token_url = f"https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=YOUR_CORPID&corpsecret=YOUR_SECRET" resp = requests.get(access_token_url).json() token = resp['access_token'] msg_send_url = f'https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token={token}' data = { 'touser': '@all', 'msgtype': 'text', 'agentid': YOUR_AGENTID, 'text': {'content': msg}, 'safe': 0 } response = requests.post(url=msg_send_url, json=data) while True: queries = get_slow_queries() messages = ["警告：检测到以下几条慢查询记录"] for q in queries: messages.append(f"开始时间:{str(q['start_time'])} | 耗时: {round(q['query_time'], 2)}秒\nSQL语句:\n{q['sql_text']}") full_message = "\n".join(messages) print(full_message) # For testing purposes; remove or comment this line when deploying. if len(queries)>0: notify_wechat("\n".join(messages)) time.sleep(300) # Wait five minutes before next check. ``` 注意，在实际应用前还需要对以上代码做适当调整和完善错误处理机制；并且将所有敏感信息比如用户名密码替换为更安全的方式管理这些凭证例如通过环境变量传递而不是硬编码在源码里。 #### 关于上述方案的一些说明: - **安全性**: 不建议把数据库账号密码明文放在脚本文件内，请考虑使用密钥管理系统或者其他更加安全的方式来存储凭据。 - **优化空间**: 如果预期会有大量慢查询，则应限制发送给企业的消息长度，并增加更多过滤条件避免不必要的警报触发。