公司已經(jīng)搭建號nagios，通過nagiosql界面管理，下面通過微信企業(yè)公眾號實現(xiàn)微信告警！
首先注冊個微信公共平臺賬號
申請企業(yè)公眾號地址：https://qy.weixin.qq.com/
帳號類型選擇企業(yè)號，注冊步驟略過，申請好后登陸公眾號后臺創(chuàng)建應(yīng)用。
通訊錄-創(chuàng)建組織架構(gòu)、標簽
添加通訊錄人員信息，可以手動一個個添加，也可以批量導(dǎo)入。
我們要提前把成員信息添加進組織部門，必填項+手機號或者微信號，這樣別人掃描二維碼的時候才能成功關(guān)注企業(yè)號。
注意：這里有兩個我們要用到信息，一個組織部門的ID，一個部門成員的賬號（賬號是自己手動指定的，不同于微信號，最好是字母加數(shù)字）
應(yīng)用中心-新建應(yīng)用-消息型應(yīng)用-設(shè)置頭像、名稱、應(yīng)用范圍等
點擊應(yīng)用中心-告警測試應(yīng)用
可以查看該應(yīng)用的應(yīng)用ID（這個ID后面會用到）
設(shè)置-權(quán)限管理-新建-配置管理組
這里的CorpID、Secret后面會用到。接受告警信息的用戶關(guān)注該企業(yè)號，完成身份認證。
通過腳本發(fā)送微信告警信息
第一步 獲取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對應(yīng)上面應(yīng)用中的信息。替換上續(xù)信息后直接瀏覽器里打開或者linux cur http://...就可以獲取access_token信息，
微信企業(yè)號接口調(diào)試工具方式：
地址：http://qydev.weixin.qq.com/debug
第二步 發(fā)送消息
通過微信企業(yè)號接口調(diào)試工具來發(fā)送消息
查看公眾號里信息：
其中的body部分可以這樣定義
{
"toparty": "2", //2 通訊錄中對應(yīng)的部門ID，
"msgtype": "text", //text 消息類型
"agentid": "6", //6 企業(yè)應(yīng)用的id，這里對應(yīng)的是上面創(chuàng)建的測試應(yīng)用ID
"text": {
"content": "Hello Justin!" //消息內(nèi)容
},
"safe":"0" //表示是否是保密消息，0表示否，1表示是，默認0
}
具體參數(shù)可以參考官方文檔：
http://qydev.weixin.qq.com/wiki/index.php?title=消息類型及數(shù)據(jù)格式#text.E6.B6.88.E6.81.AF
通過curl方式
重慶分公司
重慶分公司
[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]#
部門ID可以在通訊錄中選擇修改部門查看對應(yīng)ID
至此微信端配置完成，下面在nagios上配置
安裝Python-3.4
安裝openssl與openssl-devel包，否則使用python發(fā)送微信連接時會報urllib2.URLError:
[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，去掉以上幾行的注釋，使其支持發(fā)送https請求。
[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
#以上是導(dǎo)入模塊
#創(chuàng)建獲取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
#這里是發(fā)送消息的方法
def senddata(access_token,notify_str):
send_url = 'https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=' + access_token
#我傳入的參數(shù)是一段字符串每個信息用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狀態(tài): ' + state + '\nIP地址: ' + address + '\n摘要: ' + output + '\n時間: ' + datatime + '\n'
if cationtype == "RECOVERY":
content = '[噓]' + address + ' is ' + state + '[噓]\n\nIP地址: ' + address + '\n主要用途: ' + name + '\n當前狀態(tài): ' + state + '\n\n日志摘要: ' + output + '\n檢測時間: ' + datatime + '\n'
else:
content = '[擦汗]' + address + ' is ' + state + '[擦汗]\n\nIP地址: ' + address + '\n主要用途: ' + name + '\n當前狀態(tài): ' + 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')
#設(shè)置為非ascii解析，使其支持中文
send_request = urllib.request.Request(send_url, send_data)
response = urllib.request.urlopen(send_request)
#這個是返回微信公共平臺的信息，調(diào)試時比較有用
msg = response.read()
return msg
default_encoding = 'utf-8'
if sys.getdefaultencoding() != default_encoding:
reload(sys)
sys.setdefaultencoding(default_encoding)
#我編輯的腳本是要獲取nagios傳入的一段參數(shù)的（字符串），下面這條代碼是獲取執(zhí)行腳本后獲取的第一個參數(shù)（經(jīng)測試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服務(wù)名: ' + desc + '\n主機名: ' + alias + '\nIP址: ' + address + '\n狀態(tài): ' + state + '\n時間: ' + datatime + '\n摘要:\n' + output + '\n'
if cationtype == "RECOVERY":
content ='[鼓掌]' + desc + ' is ' + state + '[鼓掌]\n\nIP地址: ' + address + '\n主要用途: ' + alias + '\n服務(wù)狀態(tài): ' + desc + ' is ' + state + '\n檢測時間: ' + datatime + '\n日志摘要: \n' + output + '\n'
else:
content ='[擦汗]' + desc + ' is ' + state + '[擦汗]\n\nIP地址: ' + address + '\n主要用途: ' + alias + '\n服務(wù)狀態(tài): ' + 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-23By1RGzUgh2Zs422tdJpKTQzqjQ1b26IFxP76ydG2rKkchGN6E'
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主機狀態(tài)separator主機地址separator主機輸出信息separator時間"
成功后會有 b'{"errcode":0,"errmsg":"ok"}' 的提示。
[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]#
上面第一條命令報錯，提示權(quán)限問題，檢測腳本里CorpID、Secret對應(yīng)的管理組是否給了權(quán)限：設(shè)置-權(quán)限管理-對應(yīng)的管理組-應(yīng)用權(quán)限。我這里是沒把告警測試應(yīng)用加到腳本里CorpID、Secret對應(yīng)的管理組的應(yīng)用權(quán)限里。
接下來需要對接nagios報警了
定義發(fā)送微信的命令，修改commands.cfg文件，定義主機報警命令notify-host-by-weixin，及服務(wù)報警命令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$"
我這里是發(fā)送消息到組，
告警欄里添加微信告警人信息，上面命令中$CONTACTADDRESS4$調(diào)取的是附加地址4，我們把組ID寫到該欄，然后選擇主機命令、服務(wù)命令
至此，nagios通過微信告警完成！
另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機、免備案服務(wù)器”等云主機租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。
