摘要：發(fā)送到企業(yè)微信，微信實(shí)現(xiàn)即時告警的系統(tǒng)十分好用，使用，之類的可以快捷地實(shí)現(xiàn)保存日志到文件，發(fā)送錯誤日志給管理員的功能。發(fā)送的到企業(yè)微信配置的系統(tǒng)接下來我們需要配置一下的系統(tǒng)，來發(fā)送級別的到企業(yè)微信。微信接口實(shí)現(xiàn)運(yùn)維報(bào)警

Django的logging系統(tǒng)十分好用，使用file，mail_admins之類的handlers可以快捷地實(shí)現(xiàn)保存日志到文件，發(fā)送錯誤日志給管理員的功能。但是，如果能直接將應(yīng)用的錯誤日志發(fā)送到手機(jī)上，實(shí)現(xiàn)即時告警，豈不是更好？

首先需要注冊一個企業(yè)微信賬號，地址是：
https://work.weixin.qq.com/we...

**注意**：

注冊過程如果是為企業(yè)使用要選擇企業(yè)，然后上傳企業(yè)的資質(zhì)證明，如果是個人注冊，選擇團(tuán)隊(duì)，然后輸入自己的身份證號即可完成注冊.

然后進(jìn)入企業(yè)應(yīng)用頁面，添加一個應(yīng)用，添加完成后，進(jìn)入應(yīng)用頁面：

這里的agentid和secret需要留意， 后續(xù)的發(fā)送信息api需要它們。

另外我們還需要corpid，在我的企業(yè)-企業(yè)信息中可以找到。

測試使用企業(yè)微信API發(fā)送消息：
企業(yè)微信API：發(fā)送消息

例子：

#! /usr/bin/env python
# -*- coding: utf-8 -*-

import requests
import json


def get_token():

   url = "https://qyapi.weixin.qq.com/cgi-bin/gettoken"
   values = {
       "corpid": "",
       "corpsecret": "",
      }
   req = requests.post(url, params=values)
   data = json.loads(req.text)
   return data["access_token"]


def send_msg():
   url = ("https://qyapi.weixin.qq.com/cgi-bin/message/send"
          "?access_token={}").format(get_token())
   values = {
       # "touser": "@all",
       "toparty": "2",
       "msgtype": "text",
       "agentid": "",
       "text": {
           "content": u"報(bào)警測試，toparty: 2"
       },
       }

   req = requests.post(url, json.dumps(values))
   print(values, req)


if __name__ == "__main__":
   send_msg()

其中toparty：2，意為向id為2的部門的所有成員發(fā)送消息。
使用touser：@all, 可以向所有人發(fā)送信息。

配置Django的logging系統(tǒng)
接下來我們需要配置一下django的logging系統(tǒng)，來發(fā)送ERROR級別的log到企業(yè)微信。

我的思路是可以參照django自帶的AdminEmailHandler寫一個WechatAlarmHandler。
代碼如下：

import logging
import requests
import json
from copy import copy


from django.core.cache import cache
from django.views.debug import ExceptionReporter


class WechatAlarmHandler(logging.Handler):
    """An exception log handler that sends log entries to wechat alarm bot.
    """

    def __init__(self):
        logging.Handler.__init__(self)

    def emit(self, record):
        try:
            request = record.request
            subject = "%s (%s IP): %s" % (
                record.levelname,
                ("internal" if request.META.get("REMOTE_ADDR") in settings.INTERNAL_IPS # NOQA
                 else "EXTERNAL"),
                record.getMessage()
            )
        except Exception:
            subject = "%s: %s" % (
                record.levelname,
                record.getMessage()
            )
            request = None
        subject = self.format_subject(subject)
        message = self.format(record)
        self.send_msg(subject, message)
        
    def send_msg(self, subject, message=None, *args, **kwargs):
        WechatAlarm().send_msg("{}

{}".format(subject, message))


    def format_subject(self, subject):
        """
        Escape CR and LF characters.
        """
        return subject.replace("
", "
").replace("
", "
")


class WechatAlarm:
    def __init__(self, corpid="",
                 corpsecret="",
                 agentid="", partyid=""):
        self.corpid = corpid
        self.partyid = partyid
        self.key = "wechat_send_alarm_key"
        self.corpsecret = corpsecret
        self.agentid = agentid

    def get_token(self):
        token = cache.get(self.key)
        if token:
            return token
        else:
            url = "https://qyapi.weixin.qq.com/cgi-bin/gettoken"
            values = {
                "corpid": self.corpid,
                "corpsecret": self.corpsecret,
               }
            req = requests.post(url, params=values)
            data = json.loads(req.text)
            cache.set(self.key, data["access_token"], 7200)
            return data["access_token"]

    def send_msg(self, content=None):
        url = ("https://qyapi.weixin.qq.com/cgi-bin/message/send"
               "?access_token={}").format(self.get_token())
        values = {
            # "touser": "@all",
            "toparty": self.partyid,
            "msgtype": "text",
            "agentid": self.agentid,
            "text": {
                "content": content,
            },
            }

        return requests.post(url, json.dumps(values))

再配置一下django的settings里的LOGGING：

GGING = {
    "version": 1,
    "disable_existing_loggers": False,
    "formatters": {
        "verbose": {
            "format": "[%(asctime)s](%(levelname)s)<%(name)s.%(funcName)s>{%(process)d/%(thread)d} : %(message)s"
        },
        "simple": {
            "format": "%(levelname)s %(message)s"
        },
    },
    "filters": {
        "require_debug_false": {
            "()": "django.utils.log.RequireDebugFalse"
        }
    },
    "handlers": {
        "null": {
            "level": "DEBUG",
            "class": "django.utils.log.NullHandler",
        },
        "console": {
            "level": "DEBUG",
            "class": "logging.StreamHandler",
            "formatter": "simple"
        },
        "mail_admins": {
            "level": "ERROR",
            "class": "django.utils.log.AdminEmailHandler",
            "filters": ["require_debug_false"],
        },
        "send_wechat": {
            "level": "ERROR",
            "class": "utils.log.WechatAlarmHandler",   # your handler path
        },
        "file": {
            "level": "INFO",
            "class": "logging.handlers.TimedRotatingFileHandler",
            "formatter": "verbose",
            "filename": webservice_logfile,
            "when": "D"
        },
    },
    "loggers": {
        "": {
            "handlers": ["file", "mail_admins", "send_wechat"],
            "propagate": True,
            "level": "ERROR",
        },
        "django": {
            "handlers": ["file", "mail_admins"],
            "propagate": True,
            "level": "ERROR",
        },
        "django.request": {
            "handlers": ["file", "mail_admins", ],
            "level": "ERROR",
            "propagate": True,
        },
    }
}

即，在handler里增加了一個send_wechat, 在loggers里的handers里增加了send_wechat。

這樣django的error log就會通過企業(yè)微信發(fā)送到手機(jī)了。

Python+微信接口實(shí)現(xiàn)運(yùn)維報(bào)警 ?