zabbix使用微信告警

213123

在生产环境中，往往使用邮件和短信来进行告警，由于邮件经常被忽略或当垃圾邮件清理掉，起不到告警的作用，而短信告警价格费用又比较高，而我们又经常使用及时通信软件像微信等等，利用微信告警可以大幅度的降低运维成本。具体的使用微信告警步骤，如下：

（一）申请微信企业号。

（1）微信的第三方接口要求我们申请一个企业号来进行传送据，网站为：https://qy.weixin.qq.com/
。具体安装一步步来进行注册。
（2）在通讯录中添加组和成员：
   a,添加子部门，如图一
   b,添加成员，如图二
  

图一

图二

注意：1，我们要把成员信息添加到组织部门，必须填写手机号+微信号+邮箱，这样别人扫码二维码才能正常的关注。
    2，记住子部门的ID和成员的账号

（3）在应用中心创建应用（单价+号-->消息性应用-->添加应用的名称,功能，应用范围）。创建应用，是因为通过应用发送消息给部门成员，一定要记住应用的ID。如下图：


（4)给部门设置管理员:
设置--->功能设置---->权限管理---->新建管理组 管理员必须事先已经关注了企业号，并且已经设置好邮箱地址
注意：本次我们需要记住上次标红的部分，CorpID和Secret，这两个参数的值，在我们调用参数的时候要用到。

综上所述，我们需要提取如下信息:成员账号.组织部门的ID.应用ID.CorpID.Secret


（二）如何调用微信接口：调用微信接口需要一个调用接口的凭证：access_toke 通过 ：CropID 、Secret  才能获取到access_token，但是获取到的token有效期为7200s.微信企业号接口调试工具传送门：http://qydev.weixin.qq.com/debug




（三）写shell脚本

       使用： curl -s -G  url           获取 AccessToken

           curl --data  url          传送凭证调用企业号接口

   zabbix会传递三个参数给脚本，$1是消息接收账号，$2报警标题，$3报警内容

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

#!/bin/bash ###send message from weixin for zabbix monitor #author:lqb #date:V1-2016-4-12 CropID='xxxxxx' Secret='xxxxxx' GURL="https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=$CropID&corpsecret=$Secret" Gtoken=$(/usr/bin/curl -s -G $GURL | awk -F\" '{print $4}') PURL="https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=$Gtoken" function body() {         local int AppID=1                      #企业号中的应用id         local UserID=$1                       #部门成员id，zabbix中定义的微信接收者           local PartyID=2                        #部门id，定义了范围，组内成员都可接收到消息         local Msg=$(echo "$@" | cut -d" " -f3-)  #过滤出zabbix传递的第三个参数         printf '{\n'         printf '\t"touser": "'"$UserID"\"",\n"         printf '\t"toparty": "'"$PartyID"\"",\n"         printf '\t"msgtype": "text",\n'         printf '\t"agentid": "'" $AppID "\"",\n"         printf '\t"text": {\n'         printf '\t\t"content": "'"$Msg"\""\n"         printf '\t},\n'         printf '\t"safe":"0"\n'         printf '}\n' } /usr/bin/curl --data-ascii "$(body $1 $2 $3)" $PURL

由于微信企业号开放的端口有固定的格式现在：
企业号支持的格式：http://qydev.weixin.qq.com/wiki/index.php?title=消息类型及数据格式

（四）将脚本放到zabbix默认的执行路径下，并赋予可执行权限。

1 2 3

[iyunv@zabbix alertscripts]# mv weixin.sh /usr/local/zabbix/alertscripts/ [iyunv@zabbix alertscripts]# chown zabbix.zabbix weixin.sh    [iyunv@zabbix alertscripts]# chmod +x weixin.sh

（五）在zabbix服务器端进行如下设置。
  （1）创建媒介。管理-->示警媒体类型-->创建示警媒体类型-->类型选脚本.
  (2)创建用户
（3）创建触发器动作发送的内容：

（4）创建发送的方式。


(六）收到的告警信息；

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

python脚本为： #!/usr/bin/env python #coding: utf-8 import time import urllib,urllib2 import json import sys ''' 1 空 2 空 3 内容 ''' """ touser否成员ID列表（消息接收者，多个接收者用‘|’分隔，最多支持1000个）。特殊情况：指定为@all，则向关注该企业应用的全部成员发送 toparty否部门ID列表，多个接收者用‘|’分隔，最多支持100个。当touser为@all时忽略本参数 totag否标签ID列表，多个接收者用‘|’分隔。当touser为@all时忽略本参数 msgtype是消息类型，此时固定为：text agentid是企业应用的id，整型。可在应用的设置页面查看 content是消息内容 safe否表示是否是保密消息，0表示否，1表示是，默认0 """ # baseurl = 'https://qyapi.weixin.qq.com/cgi-bin/gettoken' # securl = 'https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=%s' % access_token class WeChatMSG(object):     def __init__(self,content):         self.gettoken_url = 'https://qyapi.weixin.qq.com/cgi-bin/gettoken'              self.gettoken_content = {                             'corpid' : 'wxdc26c4d41cb90b70',                             'corpsecret' : 'D8Q-0d_6PKLhfJAST0BroOn2pgzb2BIVd0RUUNcu5HigsIXYppmApte1DiqQ1PFS' ,                                      }         self.main_content = {                             "toparty":"1",                             "agentid":"3",                             "msgtype": "text",                             "text":{                             "content":content,                                     }                             }     def get_access_token(self,string):         token_result = json.loads(string.read())         access_token=  token_result['access_token']         return access_token.encode('utf-8')     def geturl(self,url,data):         data = self.encodeurl(data)         response = urllib2.urlopen('%s?%s' % (url,data))         return response.read().decode('utf-8')     def posturl(self,url,data,isjson = True):         if isjson:             data = json.dumps(data)         response = urllib2.urlopen(url,data)         return response.read().decode('utf-8')     def encodeurl(self,dict):         data = ''         for k,v in dict.items():             data += '%s=%s%s' % (k,v,'&')         return data if __name__ == '__main__':     if len(sys.argv) == 4:         touser,notuse,content = sys.argv[1:]             else:         print 'error segments, now exit'         sys.exit()     msgsender = WeChatMSG(content)     access_token_response = msgsender.geturl(msgsender.gettoken_url, msgsender.gettoken_content)     access_token =  json.loads(access_token_response)['access_token']     sendmsg_url = 'https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=%s' % access_token       print msgsender.posturl(sendmsg_url,msgsender.main_content)