Prometheus+altermanager對接企業(yè)微信機(jī)器人報錯內(nèi)容：
level=debug ts=2023-11-05T10:00:57.435Z caller=wechat.go:190 integration=wechat response="{\"errcode\":60020,\"errmsg\":\"not allow to access from your ip, hint: [1699178457562583222455115], from ip: 36.112.180.226, more info at https://open.work.weixin.qq.com/devtool/query?e=60020\"}" incident="{}:{alertname=\"kubernetes-etcd\"}"
解決方案：企業(yè)微信機(jī)器人添加企業(yè)可信IP 即可！
但是但是，第一次配置可信IP地址，需要先配置設(shè)置接收消息服務(wù)器URL，步驟如下：
打開一臺有公網(wǎng)IP的服務(wù)器，進(jìn)行下面操作：
wget https://github.com/sbzhu/weworkapi_python/archive/refs/heads/master.zip
unzip master.zip
mv weworkapi_python-master weworkapi_python
vim wechat.py
#-*- encoding:utf-8 -*-
from flask import abort, request
from flask import Flask
from xml.dom.minidom import parseString
import _thread
import time
import os
import sys
sys.path.append("weworkapi_python/callback") # 正確的模塊導(dǎo)入路徑
from WXBizMsgCrypt3 import WXBizMsgCrypt # https://github.com/sbzhu/weworkapi_python 項目地址
app = Flask(__name__)
# 對應(yīng)步驟4中接受消息回調(diào)模式中的URL，如域名是'www.example.com' 那么在步驟4中填入的url就為"http://www.example.com/hook_path"
@app.route('/hook_path', methods=['GET','POST'])
def douban():
if request.method == 'GET':
echo_str = signature(request, 0)
return(echo_str)
elif request.method == 'POST':
echo_str = signature2(request, 0)
return(echo_str)
qy_api = [
WXBizMsgCrypt("XXXXXXX", "XXXXXXX", "XXXXXXX"),
] #對應(yīng)接受消息回調(diào)模式中的token，EncodingAESKey 和 企業(yè)信息中的企業(yè)id
# 開啟消息接受模式時驗證接口連通性
def signature(request, i):
msg_signature = request.args.get('msg_signature', '')
timestamp = request.args.get('timestamp', '')
nonce = request.args.get('nonce', '')
echo_str = request.args.get('echostr', '')
ret,sEchoStr=qy_api[i].VerifyURL(msg_signature, timestamp,nonce,echo_str)
if (ret != 0):
print("ERR: VerifyURL ret: " + str(ret))
return("failed")
else:
return(sEchoStr)
# 實際接受消息
def signature2(request, i):
msg_signature = request.args.get('msg_signature', '')
timestamp = request.args.get('timestamp', '')
nonce = request.args.get('nonce', '')
data = request.data.decode('utf-8')
ret,sMsg=qy_api[i].DecryptMsg(data,msg_signature, timestamp,nonce)
if (ret != 0):
print("ERR: DecryptMsg ret: " + str(ret))
return("failed")
else:
with open ("/var/log/qywx.log", 'a+') as f: # 消息接收日志
doc = parseString(sMsg)
collection = doc.documentElement
name_xml = collection.getElementsByTagName("FromUserName")
msg_xml = collection.getElementsByTagName("Content")
type_xml = collection.getElementsByTagName("MsgType")
pic_xml = collection.getElementsByTagName("PicUrl")
msg = ""
name = ""
msg_type = type_xml[0].childNodes[0].data
if msg_type == "text": #文本消息
name = name_xml[0].childNodes[0].data #發(fā)送者id
msg = msg_xml[0].childNodes[0].data #發(fā)送的消息內(nèi)容
f.write(time.strftime('[%Y-%m-%d %H:%M:%S]') + "[ch%d] %s:%s\n" % (i, name, msg))
_thread.start_new_thread(os.system, ("python3 command.py '%s' '%s' '%d' '%d'" % (name, msg, i, 0), )) #此處將消息進(jìn)行外部業(yè)務(wù)處理
elif msg_type == "image": #圖片消息
name = name_xml[0].childNodes[0].data
pic_url = pic_xml[0].childNodes[0].data
f.write(time.strftime('[%Y-%m-%d %H:%M:%S]') + "[ch%d] %s:圖片消息\n" % (i, name))
_thread.start_new_thread(os.system, ("python3 command.py '%s' '%s' '%d' '%d'" % (name, pic_url, i, 1), )) #此處將消息進(jìn)行外部業(yè)務(wù)處理
f.close()
return("ok")
if __name__=='__main__':
app.run("0.0.0.0", 888) #本地監(jiān)聽端口,可自定義
共修改三處配置，如下
qy_api = [
WXBizMsgCrypt("XXXXXXX", "XXXXXXX", "XXXXXXX"),
] #對應(yīng)接受消息回調(diào)模式中的token，EncodingAESKey 和 企業(yè)信息中的企業(yè)id
執(zhí)行 wechat.py 腳本，如果缺py依賴就pip3 install 安裝一下，此處不在贅述??！
python3 wechat.py
如下圖表示啟動成功：
http://公網(wǎng)IP地址:888/hook_path
文章來源：http://www.zghlxwxcb.cn/news/detail-753161.html
OK，設(shè)置完成！，接下來可以添加企業(yè)可信IP了。
最后最后，告警也是成功發(fā)送到了企業(yè)微信，如下圖：
至此結(jié)束??！文章來源地址http://www.zghlxwxcb.cn/news/detail-753161.html
到了這里，關(guān)于對接企業(yè)微信機(jī)器人報錯：{\“errcode\“:60020,\“errmsg\“:\“not allow to access from your ip, hint: [169917845713115的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
