如何配置CDH的企业微信-群机器人告警

# 创建目录
mkdir -p opt/cloudera/ud_alert;

vi /opt/cloudera/ud_alert/ew_alert.py

#!/usr/bin/env python
#coding: utf8

import sys
import json
import requests
import time
reload(sys)
sys.setdefaultencoding('utf-8')


def ew_robot(data):
    webhook = "http://xxxxx/cgi-bin/webhook/send?key=xxxxx"
    headers = {'content-type': 'application/json'}
    r = requests.post(webhook, headers=headers, data=json.dumps(data))
    r.encoding = 'utf-8'
    return (r.text)


if __name__ == "__main__":
    myfile = sys.stdin
    alert_data = json.load(myfile)
    content = "### Eights-CDH测试环境集群告警\n"
    for i in range(0, len(alert_data)):
       alert=alert_data[i]["body"]["alert"]
       timestamp= time.localtime(alert["timestamp"]["epochMs"]/1000)
       content = content +"> 时间：**"+time.strftime("%Y-%m-%d %H:%M:%S",timestamp)+"**\n"
       content = content +"> 内容："+alert["content"] +"\n"
       content = content +"> 详情："+alert["source"]+"\n"
       content = conteng +"> ---------------------------------------\n"
    print content
    data={"msgtype": "markdown","markdown": {"content": content}}
    res = ew_robot(data)
    print(res)

#!/usr/bin/env bash
# 抓告警信息
cat $1 >> /opt/cloudera/ud_alert/alert.log
# 告警信息发送
ALERT_INFO=`cat $1 | python /opt/cloudera/ud_alert/ew_alert.py`
echo ${ALERT_INFO}

# 修改权限和组
chown -R cloudera-scm:cloudera-scm /opt/cloudera/ud_alert;
chmod 755 -R /opt/cloudera/ud_alert;