#!/usr/bin/env python
#coding:utf8
 
# 导入 smtplib 和 MIMEText 
import sys,getpass 
import smtplib 
from email.mime.text import MIMEText 

# 发送邮件函数 
def send_mail(to_list, sub,context): 
        me = mail_user + "<"+mail_user+"@"+mail_postfix+">" 
        msg = MIMEText(context,'plain','utf-8') 
        msg['Subject'] = sub 
        msg['From'] = me 
        msg['To'] = "".join(to_list) 
        try: 
                send_smtp = smtplib.SMTP() 
                send_smtp.connect(mail_host) 
                send_smtp.login(mail_user, mail_pass) 
                send_smtp.sendmail(me, to_list, msg.as_string()) 
                send_smtp.close() 
                return True 
        except Exception, e: 
                print str(e) 
                return False 

# 设置服务器名称、用户名、密码以及邮件后缀 
mail_host = "smtp.exmail.qq.com" 
mail_user = "reportsender@domain.com" 
mail_pass = "xxxxxxxxx" 
mail_postfix="exmail.qq.com" 

mailto_list = sys.argv[1] 
sub= sys.argv[2] 
context=sys.argv[3] 

if send_mail(mailto_list,sub,context): 
        print "Send mail succed!" 
else: 
        print "Send mail failed!"

import sys, json
from aliyunsdkdysmsapi.request.v20170525 import SendSmsRequest
from aliyunsdkcore.client import AcsClient
import uuid
from aliyunsdkcore.profile import region_provider

"""
pip install --upgrade setuptools
pip install aliyun-python-sdk-core
pip install aliyun-python-sdk-dysmsapi
"""
try:
    reload(sys)
    sys.setdefaultencoding('utf8')
except NameError:
    pass
except Exception as err:
    raise err

# 注意：不要更改
REGION = "cn-hangzhou"
PRODUCT_NAME = "Dysmsapi"
DOMAIN = "dysmsapi.aliyuncs.com"
ACCESS_KEY_ID = "xxxxxx"
ACCESS_KEY_SECRET = "xxxxxxxxx"

acs_client = AcsClient(ACCESS_KEY_ID, ACCESS_KEY_SECRET, REGION)
region_provider.add_endpoint(PRODUCT_NAME, REGION, DOMAIN)


def send_sms(business_id, phone_numbers, sign_name, template_code, template_param=None):
    sms_request = SendSmsRequest.SendSmsRequest()
    # 申请的短信模板编码,必填
    sms_request.set_TemplateCode(template_code)

    # 短信模板变量参数
    if template_param is not None:
        sms_request.set_TemplateParam(template_param)

    # 设置业务请求流水号，必填。
    sms_request.set_OutId(business_id)

    # 短信签名
    sms_request.set_SignName(sign_name)

    # 短信发送的号码列表，必填。
    sms_request.set_PhoneNumbers(phone_numbers)

    # 调用短信发送接口，返回json
    sms_response = acs_client.do_action_with_exception(sms_request)

    ##业务处理
    return sms_response


if __name__ == '__main__':
    __business_id = uuid.uuid1()
    sendto = str(sys.argv[1])  # zabbix传过来的第一个参数
    message = str(sys.argv[2])  # zabbix传过来的第二个参数
    params = {"msg": message}  # 对应短信模板里设置的参数
    params = json.dumps(params)
    print(send_sms(__business_id, sendto, "阿里大鱼查看", "阿里大鱼查看", params))

import tornado.web

class ZabbixSendAlertHandler(BaseHandler):

    def post(self, *args, **kwargs):
        data = json.loads(self.request.body.decode("utf-8"))
        print(data)
        return self.write(dict(data=data))


#这里自己封装了，不用关心
zabbix_urls = [
    (r"/v1/zabbix/send_alert/", ZabbixSendAlertHandler),
]

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time    : 2019/7/15 10:09
# @Author  : Fred Yangxiaofei
# @File    : send_alert.py
# @Role    : Zabbix webhooks 发送告警信息


import sys
import requests
import json

def send_alert(webhook_url, messages):
    params = {
        "auth_key": "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.这个Key是我平台自己申请的"
    }
    # payload = "{\"data\": \"test\"}"
    payload = {"data": messages}
    headers = {'content-type': "application/json", 'cache-control': "no-cache"}
    response = requests.post(url=webhook_url, data=json.dumps(payload), headers=headers, params=params)
    print(response.text)



if __name__ == '__main__':
    webhook_url = sys.argv[1]
    messages = sys.argv[2]
    send_alert(webhook_url, messages)

"""
如何使用：

pip install json
pip install requests

如何测试：

保证脚本没问题，你先手动执行下看看
python send_alert_to_codo.py http://172.16.0.101:8040/v1/zabbix/send_alert/ alert_message_test