广告行业包括网站建设吗,东道设计公司待遇如何,惠州网络公司网站建设,建站最好的Python实现企业微信告警
1. 创建企业微信群机器人
1-1. 什么是企业微信群机器人#xff1f;
企业微信群机器人是企业微信平台提供的一种功能#xff0c;可以通过Webhook方式将消息发送到指定的企业微信群中。它可以用于自动化发送通知、告警等信息#xff0c;实现监控和信…Python实现企业微信告警
1. 创建企业微信群机器人
1-1. 什么是企业微信群机器人
企业微信群机器人是企业微信平台提供的一种功能可以通过Webhook方式将消息发送到指定的企业微信群中。它可以用于自动化发送通知、告警等信息实现监控和信息共享。
1-2. 为什么使用企业微信群机器人进行告警通知
在企业中监控和告警是至关重要的。当系统出现异常、故障或重要事件发生时及时通知相关人员是保障业务稳定运行的关键。企业微信群机器人提供了一种方便、快速、可定制的告警通知方式帮助团队及时响应和处理问题。
1-3. 添加企业微信群机器人 在企业微信群聊里添加机器人 添加机器人 为机器人起名、自定义头像 获取Webhook机器人地址 这里的Webhook机器人地址后续用来接收消息复制保存下来。 地址url格式‘https://qyapi.weixin.qq.com/cgi-bin/webhook/send?keyc0cda19e-9523-4020-a476-xxxxxxxxxxxx’ 配置说明中可以查看机器人详细的使用介绍 查看推送消息示例机器人配置说明推送消息配置 2. 推送消息demo测试
利用curl发送消息至Webhook机器人地址机器人将消息发送至群里
参数介绍
参数必要参数说明msgtypetrue消息类型此时固定为textcontenttrue文本内容最长不超过2048个字节必须是utf8编码mentioned_listfalseuserid的列表提醒群中的指定成员(某个成员)all表示提醒所有人mentioned_mobile_listfalse手机号列表提醒手机号对应的群成员(某个成员)all表示提醒所有人
命令行demo 直接在服务器命令行执行如下代码
curl https://qyapi.weixin.qq.com/cgi-bin/webhook/send?keyc0cda19e-9523-4020-a476-xxxxxxxxxxxx \-H Content-Type: application/json \-d {msgtype: text,text: {content: 存储空间超过90%,请登录prd-etl01服务器进行处理}}{errcode:0,errmsg:ok
查看企业微信群 可以看到发送的json中 “content”: “存储空间超过90%,请登录prd-etl01服务器进行处理”已经发送至企业微信群中这是最简单的demo实现。 3.使用Python发送告警消息
3-1. 文本类型告警发送 原理是利用Python发送POST请求 通过Python的requests库可以轻松地发送POST请求到Webhook URL实现消息的发送。 [rootwangting monitor]# cat monitor_wechat.py
# -*- coding: utf-8 -*-
# Created on 2023年08月24日
# author: wangtingimport requests
import jsonurl https://qyapi.weixin.qq.com/cgi-bin/webhook/send?keyc0cda19e-9523-4020-a476-xxxxxxxxxxxx
headers {content-type: application/json}
data {msgtype: text,text: {content: 机房dolphin工作流check任务执行失败,mentioned_list: [王亭, all],}
}
data json.dumps(data)
print(requests.post(urlurl, headersheaders, datadata))运行Python脚本
[rootwangting monitor]# python3 monitor_wechat.py
Response [200]如果requests、json模块未安装可以使用pip install 进行安装 # 模块安装
[rootwangting monitor]# pip3 install simplejson
[rootwangting monitor]# pip3 install requests查看企业微信群效果 3-2. 图文类型告警发送 还可以通过企业微信机器人发送带有图片的消息以便更直观地展示问题。以下是一个示例演示如何发送带有图片的消息 [rootwangting monitor]# cat monitor_wechat_2.py
# -*- coding: utf-8 -*-
# Created on 2023年08月24日
# author: wangtingimport requests
import jsonurl https://qyapi.weixin.qq.com/cgi-bin/webhook/send?keyc0cda19e-9523-4020-xxxxxxxxxxxx
headers {content-type: application/json}data {msgtype: news,news: {articles : [{title : 危险|撤退,description : 有内鬼,终止交易,url : https://osswangting.oss-cn-shanghai.aliyuncs.com/monitor/warning.jpg,picurl : https://osswangting.oss-cn-shanghai.aliyuncs.com/monitor/warning.jpg}]}
}data json.dumps(data)
print(requests.post(urlurl, headersheaders, datadata))运行Python脚本
[rootwangting monitor]# python3 monitor_wechat_2.py
Response [200]查看企业微信群效果 “url” : “https://osswangting.oss-cn-shanghai.aliyuncs.com/monitor/warning.jpg”这里的url和值表示点击企业微信群告警信息中的图片后可以跳转的地址例如一般可以加监控grafana的监控项URL等等 参数说明
参数必要参数说明msgtypetrue消息类型此时固定为newsarticlestrue图文消息一个图文消息支持1到8条图文titletrue标题不超过128个字节超过会自动截断descriptionfalse描述不超过512个字节超过会自动截断urltrue点击图片后跳转的链接picurlfalse图文消息的图片链接支持JPG、PNG格式较好的效果为大图 1068455小图150150
3-3. 定时任务告警信息发送 可以设置定时任务定期发送监控摘要到企业微信群以便团队及时了解系统状态。以下是一个示例演示如何设置定时任务发送监控摘要 需要使用Python schedule模块
[rootwangting monitor]# pip3 install schedule
Collecting scheduleDownloading http://mirrors.cloud.aliyuncs.com/pypi/packages/eb/3b/040bd180eaef427dd160562ee66adc9f4f67088185c272edcdb899c609c7/schedule-1.1.0-py2.py3-none-any.whl
Installing collected packages: schedule
Successfully installed schedule-1.1.0脚本内容:
[rootwangting monitor]# cat monitor_wechat_3.py
# -*- coding: utf-8 -*-
# Created on 2023年08月24日
# author: wangtingimport requests
import scheduleurl https://qyapi.weixin.qq.com/cgi-bin/webhook/send?keyc0cda19e-9523-4020-xxxxxxxxxxxxdef schedule_monitor():data {msgtype: text,text: {content: 定时巡检:机房dolphin工作流check任务执行失败,mentioned_list: [王亭, all],}}res requests.post(url, jsondata)schedule.every().minutes.do(schedule_monitor)while True:schedule.run_pending()# schedule.clear() # 取消任务方法
# schedule.every().day.do(schedule_monitor).run() # 只运行当前一次运行Python脚本
[rootwangting monitor]# python3 monitor_wechat_3.py 查看企业微信群效果 schedule模块常用时间示例
# 秒
schedule.every().seconds # 每秒运行一次
schedule.every(2).seconds # 每2秒运行一次
schedule.every(1).to(5).seconds # 每1-5秒运行一次
# 分钟
schedule.every().minutes # 每分钟运行一次
# 小时
schedule.every().hour # 每小时运行一次
# 天
schedule.every().day # 每天运行一次如果后面没有at表示每天当前时间执行一次
schedule.every().day.at(00:00). # 每天凌晨运行一次
# 周
schedule.every().week # 每周凌晨运行一次
schedule.every().wednesday.at(00:00) # 每周三凌晨运行一次
# at 常用值
at(HH:MM:SS) # 准确时分秒
every().hour.at(:30) # 每小时的30分
every().minute.at(:30) # 每一分钟的30秒
# 每8周执行一次
schedule.every(8).weeks.do(job)3-4.获取数据库状态信息发送告警
测试表
CREATE TABLE monitor_table (id int(11) NOT NULL,monitor_info varchar(255) DEFAULT NULL,update timestamp NULL DEFAULT NULL,status varchar(255) DEFAULT NULL,PRIMARY KEY (id)
) ENGINEInnoDB DEFAULT CHARSETutf8mb4;样例数据
MariaDB [test] select * from monitor_table ;
------------------------------------------------
| id | monitor_info | update | status |
------------------------------------------------
| 1 | mysql_port | 2023-08-24 14:39:51 | success |
| 2 | mysql_port | 2023-08-24 14:43:14 | error |
------------------------------------------------需要使用Python pymysql模块
脚本内容:
# -*- coding: utf-8 -*-
# Created on 2023年08月24日
# author: wangtingimport pymysql.cursors
import requests
import json# 消息发送
def postmsg(url, post_data):post_data {msgtype: markdown, markdown: {content: %s}} % post_dataprint(post_data)if url :print(URL地址为空)else:r requests.post(url, datapost_data.encode())rstr r.json()if r.status_code 200 and error not in rstr:result 发送成功return resultelse:return Error# 数据库链接
def querySQL():conn pymysql.connect(hostwangting_host,userroot,password123456,databasetest)cursor conn.cursor()sql select monitor_info, status from monitor_table order by id desc limit 1;cursor.execute(sql)row cursor.fetchone()if row is None:print(没有数据)outmsg ## 状态信息: \n font colorinfo暂无新增数据/fontreturn outmsgelse:outmsg ## 告警信息\nwhile row:color info # 默认颜色为蓝色if row[1] success:color success # 绿色elif row[1] error:color warning # 红色实际中颜色可能有所不同outmsg outmsg f font color{color}-【{row[0]}】/font, {row[1]}\nrow cursor.fetchone()cursor.close()conn.close()return outmsgif __name__ __main__:url https://qyapi.weixin.qq.com/cgi-bin/webhook/send?keyc0cda19e-9523-4020-xxxxxxxxxxxxpost_data querySQL()result postmsg(url, post_data)运行脚本后查看效果 4. 总结
企业微信群机器人是一个强大的工具用于实现监控告警和信息通知。机器人发送不同类型的消息通知我们合理利用企业微信群机器人可以提升团队的响应速度和业务稳定性在实际工作中提升效率和效果。
