以wxpusher为第三方消息组件,可以实现实时的提醒与告警,献上封装好的代码。

微信接口 wxpusher api

import requests
from urllib import parse
from utils.common.date import timestamp
import json

RECEIVE_USER_ID  = ["test0",#手机关注后，获得接受方userid
               "test1",#hu
                    ]

def wxpostsend(msg="post 采集的数据为XXX"):
    url ="http://wxmsg.dingliqc.com/send"
    headers ={
            "Content-Type":"application/json"
    }
    data = {
    "userIds":RECEIVE_USER_ID,
    "template_id":"uesrid3",#手机关注后，获得发送方userid
    "data":{
        "first":{
            "value":"XXX",
            "color":"#ff0000"
            },
        "keyword1": {
            "value": "XXX",
            "color": "#000000"
        },
        "keyword2": {
            "value": f"{timestamp}",
            "color": "#000000"
        },
        "remark":{
            "value":msg,
            "color":"#000000"
            }
        }
    }
    # postdata = parse.urlencode(data)
    a = requests.post(url=url,json=data,headers=headers)
    if  a.json()['code'] ==200:
        print(f"[+]微信post方式消息提示，发送{repr(msg)}成功.")
    # print(a.text)


def wxgetsend(msg='get hello word'):
    data = {
    "title":"XXX",
    "userIds":RECEIVE_USER_ID,
    "msg":msg,
    }
    encodedata = parse.urlencode(data)
    url = f"http://wxmsg.dingliqc.com/send/?{encodedata}"
    a = requests.get(url)
    if a.status_code == 200:
        print("[+]微信get方式消息提示，发送成功.")

if __name__ == "__main__":
    wxgetsend()
    wxpostsend()