AI 助理
备案控制台
开发者社区 大数据 文章 正文

Nagios调用Python程序控制微信公众平台发布报警信息

2017-11-27 1340
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
日志服务 SLS，月写入数据量 50GB 1个月
简介：

公司已经搭建号nagios，通过nagiosql界面管理，下面通过微信企业公众号实现微信告警！

首先注册个微信公共平台账号

申请企业公众号地址：https://qy.weixin.qq.com/

帐号类型选择企业号，注册步骤略过，申请好后登陆公众号后台创建应用。

通讯录-创建组织架构、标签

添加通讯录人员信息，可以手动一个个添加，也可以批量导入。

我们要提前把成员信息添加进组织部门，必填项+手机号或者微信号，这样别人扫描二维码的时候才能成功关注企业号。

  注意：这里有两个我们要用到信息，一个组织部门的ID，一个部门成员的账号（账号是自己手动指定的，不同于微信号，最好是字母加数字）


wKioL1fkydTwHNznAAJDTU1nq1Y775.png

wKiom1fkydaRFSj7AAIuJAVyRWI148.png



应用中心-新建应用-消息型应用-设置头像、名称、应用范围等

wKiom1fkyEnwelcVAALrOXtOIIg527.png

wKiom1fkyuby-NtKAAJupkQc2rg820.png

wKiom1fkyuiT6KooAAKvznqnTvI013.png

点击应用中心-告警测试应用

可以查看该应用的应用ID（这个ID后面会用到）

wKiom1fky8iTowX1AAMN91ANZtw261.png

wKiom1fky8qieUjDAAObGSYUKEU767.png


设置-权限管理-新建-配置管理组

wKioL1fkz5rzW268AAJ4SVjPzZU138.png

wKiom1fkz5vykTL7AAIn7Ak5pfs361.png

wKioL1fkz5zADR5pAAI8kJNwERc519.png

wKiom1fkz56wTOkxAALGNw81yoA797.png


这里的CorpID、Secret后面会用到。接受告警信息的用户关注该企业号，完成身份认证。


通过脚本发送微信告警信息

第一步 获取access_token

正常情况下AccessToken有效期为7200秒，之后需要重新获取，参考文档http://qydev.weixin.qq.com/wiki/index.php?title=%E4%B8%BB%E5%8A%A8%E8%B0%83%E7%94%A8

  • Https请求方式: 

    https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=id&corpsecret=secrect

id、Secret对应上面应用中的信息。替换上续信息后直接浏览器里打开或者linux cur http://...就可以获取access_token信息，

wKiom1fk1zGgt-unAABRUhj4Mx0175.png

  • 微信企业号接口调试工具方式：

地址：http://qydev.weixin.qq.com/debug

wKiom1fk3vSQbleBAACf3N2Mi7s130.png

第二步 发送消息

  • 通过微信企业号接口调试工具来发送消息

wKiom1fk4u6x8TmLAABgVdzR9Ps196.png

wKiom1fk4ySgq68dAACMCGgUBLs298.png

查看公众号里信息：

wKiom1fk5KvBrHFpAAAnFOLmj_Q851.png


其中的body部分可以这样定义

{

   "toparty": "2",    //2 通讯录中对应的部门ID，

   "msgtype": "text",  //text 消息类型

   "agentid": "6",   //6 企业应用的id，这里对应的是上面创建的测试应用ID

   "text": {

       "content": "Hello Justin!"   //消息内容

   },

   "safe":"0"   //表示是否是保密消息，0表示否，1表示是，默认0

}

具体参数可以参考官方文档：

http://qydev.weixin.qq.com/wiki/index.php?title=消息类型及数据格式#text.E6.B6.88.E6.81.AF


  • 通过curl方式

1
2
3
4
5
6
7
8
9
10
[root@localhost sh] # curl https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=DJZi3l051NuXz7rmWZOrugc9D6GlKewiqW3VewnCkAgvBFNQngImvYfPtdfHcQWncJ -d  "{ \
>    \"toparty\": \"2\", \
>    \"msgtype\": \"text\", \
>    \"agentid\": 6, \
>    \"text\": { \
>        \"content\": \"Hello Justin_peng! \" \
>    }, \
>    \"safe\":\"0\" \
> }"
{ "errcode" :0, "errmsg" : "ok" }[root@localhost sh] #

wKioL1fk5zORLdfiAAA1uu4SWvU067.png

wKioL1fk5zPzEZt1AAAxQnMRrFA733.png


部门ID可以在通讯录中选择修改部门查看对应ID

wKiom1fk5GPRBMBmAAF8H2nr13E723.png

wKioL1fk5GTycbGkAAHc37SB2Cw593.png


至此微信端配置完成，下面在nagios上配置

安装Python-3.4

安装openssl与openssl-devel包，否则使用python发送微信连接时会报urllib2.URLError: <urlopen error unknown url type: https>这个错误，是因为python没有SSL模块，需重新编译安装python

1
2
3
4
5
6
7
8
9
10
11
12
13
14
[root@localhost libexec] # yum -y install openssl openssl-devel
[root@localhost libexec] # wget 
[root@localhost libexec] # tar zxvf Python-3.4.3.tgz  
[root@localhost libexec] # cd Python-3.4.3/Modules/
[root@localhost Modules] # vim Setup.dist 
# Socket module helper for SSL support; you must comment out the other
# socket line above, and possibly edit the SSL variable:
SSL= /usr/local/ssl
_ssl _ssl.c \
         -DUSE_SSL -I$(SSL) /include  -I$(SSL) /include/openssl  \
         -L$(SSL) /lib  -lssl -lcrypto
 
# The crypt module is now disabled by default because it breaks builds
[root@localhost Modules] #

修改Setup.dist，去掉以上几行的注释，使其支持发送https请求。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
[root@localhost Modules] # cd .. 
[root@localhost Python-3.4.3] # ./configure --prefix=/usr/local/python-3.4
[root@localhost Python-3.4.3] # make && make install
[root@localhost Python-3.4.3] # vim /etc/profile
export  PATH= "/usr/local/python-3.4/bin:$PATH"    #文末添加
[root@localhost Python-3.4.3] # source /etc/profile 
[root@localhost Python-3.4.3] # cd /usr/local/nagios/python/
[root@localhost python] # vim Notify-host-by-weixin-party.py 
import  urllib.request
import  json
import  sys
#以上是导入模块
#创建获取AccessToken的方法
def gettoken(corp_id,corp_secret):
     gettoken_url =  'https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid='  + corp_id +  '&corpsecret='  + corp_secret
     try:
         token_file = urllib.request.urlopen(gettoken_url)
     except urllib.error.HTTPError as e:
         print(e.code)
         print(e. read ().decode( "utf8" ))
     token_data = token_file. read ().decode( 'utf-8' )
     token_json = json.loads(token_data)
     token_json.keys()
     token = token_json[ 'access_token' ]
     return  token
#这里是发送消息的方法
def senddata(access_token,notify_str):
     send_url =  'https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token='  + access_token
#我传入的参数是一段字符串每个信息用separator连起来，只要再用字符串的split("separator")方法分开信息就可以了。
     notifydata = notify_str. split ( "separator" )
     party = notifydata[0]
     cationtype = notifydata[1]
     name = notifydata[2]
     state = notifydata[3]
     address = notifydata[4]
     output = notifydata[5]
     datatime = notifydata[6]
#    content = '[擦汗]Host Notification[擦汗]\n\n类型: ' + cationtype + '\n主机名: ' + name + '\n状态: ' + state + '\nIP地址: ' + address + '\n摘要: ' + output + '\n时间: ' + datatime + '\n'
     if  cationtype ==  "RECOVERY" :
        content =  '[嘘]'  + address +  ' is '  + state +  '[嘘]\n\nIP地址: '  + address +  '\n主要用途: '  + name +  '\n当前状态: '  + state +  '\n\n日志摘要: '  + output +  '\n检测时间: '  + datatime +  '\n'
     else :
        content =  '[擦汗]'  + address +  ' is '  + state +  '[擦汗]\n\nIP地址: '  + address +  '\n主要用途: '  + name +  '\n当前状态: '  + state +  '\n\n日志摘要: '  + output +  '\n检测时间: '  + datatime +  '\n'
     send_values = {
         "toparty" :party,
         "totag" : "2" ,
         "msgtype" : "text" ,
         "agentid" : "15" ,
         "text" :{
             "content" :content
             },
         "safe" : "0"
         }
     send_data = json.dumps(send_values, ensure_ascii=False).encode(encoding= 'UTF8' )
#设置为非ascii解析，使其支持中文
     send_request = urllib.request.Request(send_url, send_data)
     response = urllib.request.urlopen(send_request)
#这个是返回微信公共平台的信息，调试时比较有用
     msg = response. read ()
     return  msg
default_encoding =  'utf-8'
if  sys.getdefaultencoding() != default_encoding:
     reload(sys)
     sys.setdefaultencoding(default_encoding)
#我编辑的脚本是要获取nagios传入的一段参数的（字符串），下面这条代码是获取执行脚本后获取的第一个参数（经测试nagios只能传入一个参进python，所以把所有包括用户名跟报警主机报警信息放进一个字符串里）
notifystr = str(sys.argv[1])
corpid =  'wxb6162862801114c9da602'   
corpsecret =  '2nCsNcHxepBCV4U9Lcf-23By1RGzU1Zs422tdJpKTQzqjQ1b26IFxP76ydG2rKkchGN6E'
accesstoken = gettoken(corpid,corpsecret)
msg = senddata(accesstoken,notifystr)
print(msg)
[root@localhost python] # vim Notify-service-by-weixin-party.py 
import  urllib.request
import  json
import  sys
 
def gettoken(corp_id,corp_secret):
     gettoken_url =  'https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid='  + corp_id +  '&corpsecret='  + corp_secret
     try:
         token_file = urllib.request.urlopen(gettoken_url)
     except urllib.error.HTTPError as e:
         print(e.code)
         print(e. read ().decode( "utf8" ))
     token_data = token_file. read ().decode( 'utf-8' )
     token_json = json.loads(token_data)
     token_json.keys()
     token = token_json[ 'access_token' ]
     return  token
 
def senddata(access_token,notify_str):
     send_url =  'https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token='  + access_token
     notifydata = notify_str. split ( "separator" )
     party = notifydata[0]
     cationtype = notifydata[1]
     desc = notifydata[2]
     alias  = notifydata[3]
     address = notifydata[4]
     state = notifydata[5]
     datatime = notifydata[6]
     output = notifydata[7]
#    content ='[擦汗]Service Notification [擦汗]\n\n类型: ' + cationtype + '\n\n服务名: ' + desc + '\n主机名: ' + alias + '\nIP址: ' + address + '\n状态: ' + state + '\n时间: ' + datatime + '\n摘要:\n' + output + '\n'
     if  cationtype ==  "RECOVERY" :
        content = '[鼓掌]'  + desc +  ' is '  + state +  '[鼓掌]\n\nIP地址: '  + address +  '\n主要用途: '  +  alias  +  '\n服务状态: '  + desc +  ' is '  + state +  '\n检测时间: '  + datatime +  '\n日志摘要: \n'  + output +  '\n'
     else :
        content = '[擦汗]'  + desc +  ' is '  + state +  '[擦汗]\n\nIP地址: '  + address +  '\n主要用途: '  +  alias  +  '\n服务状态: '  + desc +  ' is '  + state +  '\n检测时间: '  + datatime +  '\n日志摘要: \n'  + output +  '\n'
     send_values = {
         "toparty" :party,
         "totag" : "2" ,
         "msgtype" : "text" ,
         "agentid" : "15" ,
         "text" :{
             "content" :content
             },
         "safe" : "0"
         }
     send_data = json.dumps(send_values, ensure_ascii=False).encode(encoding= 'UTF8' )
     send_request = urllib.request.Request(send_url, send_data)
     response = urllib.request.urlopen(send_request)
     msg = response. read ()
     return  msg
 
 
default_encoding =  'utf-8'
if  sys.getdefaultencoding() != default_encoding:
     reload(sys)
     sys.setdefaultencoding(default_encoding)
notifystr = str(sys.argv[1])
corpid =  'wxb616286d28ds01114c9da602'
corpsecret =  '2nCsNcHxepBCdtgV4U9Lcf-23By1RGzUgh1Zs422tdJpKTQzqjQ1b26IFxP76ydG2rKkchGN6E'
accesstoken = gettoken(corpid,corpsecret)
msg = senddata(accesstoken,notifystr)
print(msg)
[root@localhost python] # chmod +x Notify-host-by-weixin-party.py
[root@localhost python] # chmod +x Notify-service-by-weixin-party.py 
[root@localhost python] # ll Notify-host-by-weixin-party.py Notify-service-by-weixin-party.py 
-rwxr-xr-x. 1 root root 3040 Aug 22 14:32 Notify-host-by-weixin-party.py
-rwxr-xr-x. 1 root root 2498 Aug 19 14:55 Notify-service-by-weixin-party.py
[root@localhost python] #

上面脚本需要修改以下几处成自己的信息：

 send_values = {

        "toparty":party,

        "totag":"2",

        "msgtype":"text",

        "agentid":"15",

        "text":{

            "content":content

            },

        "safe":"0"

        }

corpid = 'wxb6162862sf80113e14c9da602'

corpsecret = '2nCsNcHxepBCV4U9Lcf-23By1RGzU1Zs422tdJdpKTQzqjQ1gjyb26IFxP76ydG2rKkchGN6E'


通过命令行测试脚本

[root@localhost python]# /usr/local/python-3.4/bin/python3.4 /usr/local/nagios/python/Notify-host-by-weixin-party.py "微信通讯录组id号separator时间标题separator主机名separator主机状态separator主机地址separator主机输出信息separator时间"

成功后会有 b'{"errcode":0,"errmsg":"ok"}' 的提示。

1
2
3
[root@localhost python] # /usr/local/python-3.4/bin/python3.4 /usr/local/nagios/python/notify-host-by-weixin-test.py "2separator20160923separatortest_serverseparatorupseparator10.10.2.132separatortestseparator17:30"
b '{"errcode":0,"errmsg":"ok"}'
[root@localhost python] #

wKioL1fk-yXCJToCAAA0O07sCCY012.png

wKiom1fk-ybSzubNAAAxEQaroA8467.png

上面第一条命令报错，提示权限问题，检测脚本里CorpID、Secret对应的管理组是否给了权限：设置-权限管理-对应的管理组-应用权限。我这里是没把告警测试应用加到脚本里CorpID、Secret对应的管理组的应用权限里。


接下来需要对接nagios报警了

定义发送微信的命令，修改commands.cfg文件，定义主机报警命令notify-host-by-weixin，及服务报警命令notify-service-by-weixin。然后修改templates.cfg文件，添加微信报警。我这里通过nagiosql管理nagios的。

在命令栏里定义报警命令：

notify-host-by-weixin-Party-Address4

/usr/local/python-3.4/bin/python3.4 /usr/local/nagios/python/Notify-host-by-weixin-party.py "$CONTACTADDRESS4$separator$NOTIFICATIONTYPE$separator$HOSTALIAS$separator$HOSTSTATE$separator$HOSTADDRESS$separator$HOSTOUTPUT$separator$LONGDATETIME$"

notify-service-by-weixin-Party-Address4

/usr/local/python-3.4/bin/python3.4 /usr/local/nagios/python/Notify-service-by-weixin-party.py "$CONTACTADDRESS4$separator$NOTIFICATIONTYPE$separator$SERVICEDESC$separator$HOSTALIAS$separator$HOSTADDRESS$separator$SERVICESTATE$separator$LONGDATETIME$separator$SERVICEOUTPUT$"

wKiom1fouuDhCYx9AAByBtyQUx0753.png

我这里是发送消息到组，

告警栏里添加微信告警人信息，上面命令中$CONTACTADDRESS4$调取的是附加地址4，我们把组ID写到该栏，然后选择主机命令、服务命令

wKioL1fou3fjOhXjAAGmOQBlx2Y916.png至此，nagios通过微信告警完成！

wKiom1fou8_Sg_bgAABqN7j76ok608.png




本文转自 justin_peng 51CTO博客，原文链接：http://blog.51cto.com/ityunwei2017/1775702，如需转载请自行联系原作者

文章标签：
日志服务
Python
网络安全
机器学习/深度学习
数据格式
关键词：
Python程序
Python信息
微信信息
Python程序信息
Python微信
相关实践学习
日志服务之使用Nginx模式采集日志
本文介绍如何通过日志服务控制台创建Nginx模式的Logtail配置快速采集Nginx日志并进行多维度分析。
技术小阿哥
目录
相关文章
bruce_xiaowei
|
3月前
|
Python
自动化微信朋友圈：Python脚本实现自动发布动态
本文介绍如何使用Python脚本自动化发布微信朋友圈动态，节省手动输入的时间。主要依赖`pyautogui`、`time`、`pyperclip`等库，通过模拟鼠标和键盘操作实现自动发布。代码涵盖打开微信、定位朋友圈、准备输入框、模拟打字等功能。虽然该方法能提高效率，但需注意可能违反微信使用条款，存在风险。定期更新脚本以适应微信界面变化也很重要。
bruce_xiaowei
265 61
左诗右码
|
3月前
|
Android开发 开发者 Python
通过标签清理微信好友：Python自动化脚本解析
微信已成为日常生活中的重要社交工具，但随着使用时间增长，好友列表可能变得臃肿。本文介绍了一个基于 Python 的自动化脚本，利用 `uiautomator2` 库，通过模拟用户操作实现根据标签批量清理微信好友的功能。脚本包括环境准备、类定义、方法实现等部分，详细解析了如何通过标签筛选并删除好友，适合需要批量管理微信好友的用户。
左诗右码
141 7
Codelinghu
|
5月前
|
小程序 JavaScript
微信小程序之input组件及其获取用户输入信息
微信小程序之input组件及其获取用户输入信息
Codelinghu
107 1
小周sir
|
6月前
|
小程序 API 开发工具
使用python 实现微信签到提醒功能
【9月更文挑战第4天】使用python 实现微信签到提醒功能
小周sir
131 2
游客jjw5lou74ja6k
|
7月前
|
缓存 JavaScript 前端开发
微信 JS-SDK Demo “分享信息设置” API 及数字签名生成方法（NodeJS版本）
微信 JS-SDK Demo “分享信息设置” API 及数字签名生成方法（NodeJS版本）更新时间（2020-10-29）
游客jjw5lou74ja6k
94 0
爱你三千遍斯塔克
|
8月前
|
算法 安全 数据安全/隐私保护
支付系统---微信支付09------数字签名，现在Bob想要给Pink写一封信，信件的内容不需要加密，怎样能够保证信息的完整性，使用信息完整性的主要手段是摘要算法，散列函数，哈希函数，H称为数据指纹
支付系统---微信支付09------数字签名，现在Bob想要给Pink写一封信，信件的内容不需要加密，怎样能够保证信息的完整性，使用信息完整性的主要手段是摘要算法，散列函数，哈希函数，H称为数据指纹
爱你三千遍斯塔克
83 0
朝阳39
|
8月前
|
小程序 定位技术
微信小程序实战——获取用户地理位置信息
微信小程序实战——获取用户地理位置信息
朝阳39
123 0
温轻舟
|
9月前
|
安全 UED 黑灰产治理
微信留言自动回复(Python实现）
本项目旨在使用Python与Windows GUI自动化工具来自动化微信的操作，作用为读取未读消息、根据关键词回复消息
温轻舟
341 0
八音盒coding
|
9月前
|
JavaScript Java 测试技术
基于SpringBoot+Vue+uniapp的速达物流信息查询微信小程序的详细设计和实现(源码+lw+部署文档+讲解等)
基于SpringBoot+Vue+uniapp的速达物流信息查询微信小程序的详细设计和实现(源码+lw+部署文档+讲解等)
八音盒coding
80 0
编程千纸鹤
|
9月前
|
小程序 前端开发 JavaScript
微信小程序｜高校毕业生就业信息的设计与实现
微信小程序｜高校毕业生就业信息的设计与实现
编程千纸鹤
86 0

热门文章

最新文章

  • 1
    Python爬虫实战：股票分时数据抓取与存储
  • 2
    通义灵码AI程序员实战：从零构建Python记账本应用的开发全解析
  • 3
    Python 编程基础与实战：从入门到精通
  • 4
    【01】整体试验思路，如何在有UID的情况下获得用户手机号信息，python开发之理论研究试验，如何通过抖音视频下方的用户的UID获得抖音用户的手机号-本系列文章仅供学习研究-禁止用于任何商业用途-仅供学习交流-优雅草卓伊凡
  • 5
    如何在Python中高效实现CSV到JSON的数据转换
  • 6
    通义灵码 2.0 体验报告：Deepseek 加持下的 Python 开发之旅
  • 7
    体验通义灵码的AI程序员：用Python+Tkinter实现表单向config.ini写入与读取
  • 8
    深入剖析 Python 爬虫：淘宝商品详情数据抓取
  • 9
    通义灵码 2.0 智能编码功能评测：Deepseek 加持下的 Python 开发体验
  • 10
    基于Python深度学习的【蘑菇识别】系统~卷积神经网络+TensorFlow+图像识别+人工智能
  • 1
    【03】微信支付商户申请下户到配置完整流程-微信开放平台创建APP应用-填写上传基础资料-生成安卓证书-获取Apk签名-申请+配置完整流程-优雅草卓伊凡
    55
  • 2
    技术小白如何利用DeepSeek半小时开发微信小程序？
    73
  • 3
    【产品小贴士】: 企业微信集成
    32
  • 4
    【02】微信支付商户申请下户到配置完整流程-微信开放平台申请APP应用-微信商户支付绑定appid-公众号和小程序分别申请appid-申请+配置完整流程-优雅草卓伊凡
    31
  • 5
    【01】微信支付商户申请下户到配置完整流程-微信商户申请-资料准备以及提交-微信商户密钥申请-申请+配置完整流程-优雅草卓伊凡
    25
  • 6
    D1net阅闻 | 13亿月活的微信接入DeepSeek
    21
  • 7
    微信正式接入DeepSeek
    33
  • 8
    微信小程序数据绑定与事件处理：打造动态交互体验
    20
  • 9
    微信小程序页面导航与路由：实现多页面跳转与数据传递
    24
  • 10
    微信小程序网络请求与API调用：实现数据交互
    25

    • 相关课程

    更多
  • 高校精品课-华东师范大学 - Python数据科学基础与实践
  • 【科技少年】Python基础语法
  • 【科技少年】Python绘画编程第一课
  • 面向运维的 python 脚本速成-1024程序员节创造营公益课
  • Python 脚本入门
  • Python 脚本进阶

    • 相关电子书

    更多
  • 给运维工程师的Python实战课
  • Python 脚本速查手册
  • ACE 区域技术发展峰会：Flink Python Table API入门及实践

    • 相关实验场景

    更多
  • Python新手入门
  • Python入门
  • Python选择及循环结构
  • Python新手入门（Anolis OS）
  • 使用云助手公共命令快速安装Java环境
  • Python网络通信程序典型应用

    • 推荐镜像

    更多
  • python-release
    • 下一篇
    阿里云负载均衡SLB版本CLB、ALB和NLB有什么区别如何选择？