【#文档大全网# 导语】以下是®文档大全网的小编为您整理的《微信机器人》,欢迎阅读!

sendMessageWechat.py(企业微信机器人): #!/usr/bin/env python # -*- coding: utf-8 -*-
import time import requests import json import datetime import logging
dt=datetime.datetime.now()
logging.basicConfig(level=logging.DEBUG,
format='%(asctime)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s', datefmt='%a, %d %b %Y %H:%M:%S',
filename='./log/'+dt.strftime('%Y%m%d')+'.log', filemode='a')
#################################################################################################
console = logging.StreamHandler() console.setLevel(logging.INFO)
formatter = logging.Formatter('%(name)-12s: %(levelname)-8s %(message)s') console.setFormatter(formatter)
logging.getLogger('').addHandler(console)
#################################################################################################
logging.debug('This is debug message') logging.info('This is info message')
logging.warning('This is warning message')
class WeChat:
def __init__(self):
self.CORPID = '**' #企业ID,在管理后台获取
self.CORPSECRET = '***'#自建应用的Secret,每个自建应用里都有单独的secret self.AGENTID = '***' #应用ID,在后台应用中获取
self.TOUSER = "@all" # 接收者用户名,多个用户用|分割
def _get_access_token(self):
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) return data["access_token"]
def get_access_token(self): try:
with open('./tmp/access_token.conf', 'r') as f: t, access_token = f.read().split() except:
with open('./tmp/access_token.conf', 'w') as f: access_token = self._get_access_token() cur_time = time.time()
f.write('\t'.join([str(cur_time), access_token])) return access_token else:
cur_time = time.time()
if 0 < cur_time - float(t) < 7260: return access_token else:
with open('./tmp/access_token.conf', 'w') as f: access_token = self._get_access_token()
f.write('\t'.join([str(cur_time), access_token])) return access_token
def send_data(self, message):
send_url = 'https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=' + self.get_access_token() send_values = {
"touser": self.TOUSER, "msgtype": "text",
"agentid": self.AGENTID, "text": {
"content": message }, "safe": "0" }
send_msges=(bytes(json.dumps(send_values), 'utf-8')) respone = requests.post(send_url, send_msges)
respone = respone.json() #当返回的数据是json串的时候直接用.json即可将respone转换成字典
logging.info(respone) return respone["errmsg"]
#if __name__ == '__main__': #wx = WeChat()
#wx.send_data("这是程序发送的第1条消息!\n Python程序调用企业微信API,从自建应用“告警测试应用”发送给管理员的消息!")
#wx.send_data("这是程序发送的第2条消息!")
本文来源:https://www.wddqxz.cn/ef61526b65ec102de2bd960590c69ec3d5bbdbca.html