用企業微信實現預警(shell + python)
阿新 • • 發佈:2018-12-27
目錄
一 註冊企業微信
本文所有內容是基於2018年12月26日時的企業微信版本所做的教程。後面可能由於企業微信介面規則更改導致部分流程不一致。(大家看文章時請注意這一點)
註冊企業微信必備條件
- 微訊號(實名認證了)
- 手機號
之前我有個誤區,就是以為註冊企業微信就一定要有營業執照之類的證件才可以註冊,實際是不需要也可以的,因為我們直接註冊後,即使不繫結企業,我們也是可以正常使用的,未繫結實際企業的,有200人的數的上限(難道你們技術部有200人?不存在的,哈哈!)
註冊
註冊連結:企業微信
企業名稱可以隨便填,建議填真實的啊,其他的你就按照實際情況填了。
二 建立訊息
建立部門
首先我們需要建立一個部門,然後將成員新增到一個部門裡面
邀請成員加入
我們可以在首頁點選進行邀請。
也可以在選中要新增的部門後再選右邊的新增成員或者微信邀請。
建立應用
建立的時候指定下可以接收的訊息的部門
關注微工作平臺
在我的企業 ---》 微工作平臺 ---》邀請關注
三 實現預警
在完成的上面的所有準備工作後,我們還需要獲取三個東西 :
1 企業ID
2 獲取應用ID和Secret
獲取企業ID
獲取應用ID和Secret
通過shell 指令碼實現監控預警
該shell 指令碼實現的功能: 檢測埠是否在監聽狀態,不在則進行微信預警。
#!/bin/bash ############### #$Auth= djx #$Function= monitoring service #Date= 2018-12-26 ############### # 日誌儲存檔案 log_file='/var/log/ljf_status.log' # 主機名 hostname=`hostname` # 監聽的埠陣列 check_port=("3306" "3329" "4567") # 陣列長度 num=${#check_port[*]} # 報警訊息 msg="" echo "--------------------------$(date +%F_%T)-----------------" >>$log_file for i in `seq 0 $num` do netstat -tnlp|grep "${check_port[${i}]}" >>/dev/null if [ $? -ne 0 ] then msg="\\n${hostname}:The Port ${check_port[${i}]} is down \\n"${msg} echo "$(date +%F_%T) ${hostname}:The Port ${check_port[${i}]} is down">>$log_file fi done if [ "${msg}" != "" ] then CropID="" #填入企業ID值 Secret="" #填入認證密碼 GURL="https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=$CropID&corpsecret=$Secret" # 獲取token Gtoken=$(/usr/bin/curl -s -G $GURL | awk -F\" '{print $10}') PURL="https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=$Gtoken" body='{ "touser": "@all", "msgtype": "text", "agentid": "1000002", #要更改為我們的應用ID "text":{ "content":" 故障:'$msg' " }, "safe":0 }' /usr/bin/curl --data-ascii "$body" $PURL >>$log_file 2>&1 fi
通過python 指令碼實現監控預警
由於centos7和centos6 預設安裝的都是python2版本,所以下面的指令碼是基於python2寫的,這樣我們就可以直接拿到我們的伺服器上使用了。
# -*- coding: utf-8 -*-
# @Time : 2018/12/27 0021 11:58
# @Author : djx
# @Email : [email protected]
# @File : 微信預警指令碼.py
# @Software: PyCharm
import os
import time
import urllib2
import json
# 企業號ID
wxid = ""
# 應用ID
depid = ""
# 認證密碼
secret = ""
# 獲取主機的名稱
hostname = os.popen("hostname").read()
# 日誌儲存檔案
log_file = '/var/log/ljf_status.log'
# 監聽的埠列表
check_port = (
"8500",
"3306")
# 傳送的訊息
msg = ""
# 獲取當前的時間
date_time = time.strftime("%Y-%m-%d %X")
# 檢查埠是否在監聽
for i in check_port:
shell = "netstat -nutlp |grep \"" + i + "\""
recv = os.popen(shell).read()
if recv == "":
msg = msg + hostname + ": The Port " + i + "is down \n"
# 預警判斷
if msg != "":
url = "https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=" + \
wxid + "&corpsecret=" + secret
request = urllib2.Request(url)
response = urllib2.urlopen(request)
recv_info = response.read()
recv_info = eval(recv_info)
wx_token = recv_info['access_token']
msg_url = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=" + wx_token
send_msg = {
"touser": "@all",
"msgtype": "text",
"agentid": depid,
"text": {"content": msg},
"safe": 0
}
send_msg_json = json.dumps(send_msg)
request_post = urllib2.urlopen(msg_url,send_msg_json)
recv_msg = request_post.read()
with open(log_file,mode='a') as f:
f.write(date_time)
f.write("\n")
f.write(msg)
f.write(recv_msg)
f.write("\n")
上面的指令碼也可以應用在zabbix或者是Open-falcon。
最後送上一句覺得不錯的話 : 立志要如山,行道要如水,如山能堅定,如水能曲達。