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

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


def robot(data):
    webhook="https://oapi.dingtalk.com/robot/send?access_token=7fa08ecc83219ad99657bdea9890df300fdcaa328ad6a10a2ba2d41b68d7a3c5"
    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 = "### us-mergex-flink集群告警\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 +"> ---------------------------------------\n"
    print(content)
    data = {
        "msgtype": "markdown",
        "markdown": {
            "title": "us-mergex-flink集群",
            "text": content
        }
    }
    res = robot(data)
    print(res)