Python实现钉钉发送报警消息的方法
作者:steanxy 发布时间:2022-11-18 06:06:44
钉钉开放平台传送门:https://open.dingtalk.com
我司使用钉钉作为内部通讯工具,基本上大家在电脑和手机上都开着,消息可以第一时间查看,报警消息的即时性要求比较高,所以适合用钉钉通知。
下面介绍如何用Python实现钉钉发送报警消息。
获取access token
要使用钉钉发送消息,首先需要获取access token,代码如下:
def get_access_token():
url = 'https://oapi.dingtalk.com/gettoken?corpid=%s&corpsecret=%s' % (corp_id, corp_secret)
request = urllib2.Request(url)
response = urllib2.urlopen(request)
response_str = response.read()
response_dict = json.loads(response_str)
error_code_key = "errcode"
access_token_key = "access_token"
if response_dict.has_key(error_code_key) and response_dict[error_code_key] == 0 and response_dict.has_key(access_token_key):
return response_dict[access_token_key]
else:
return ''
access token在2小时内有效,有效期内重复获取返回相同结果,有效期会自动延长。corp_id和corp_secret是企业的id和secret,在钉钉的管理后台可以找到。另外,上面用到了urllib2和json,需要import:
import urllib2
import json
消息类型
钉钉的消息类型分为:text,image,voice,file,link和OA,具体消息格式参见:https://open-doc.dingtalk.com/docs/doc.htm?treeId=172&articleId=104972&docType=1 。
下面以发送文本,链接和文件消息为例进行说明。
给用户发送消息
发送文本
def send_text_to_users(access_token, users, text):
msg_type, msg = _gen_text_msg(text)
return _send_msg_to_users(access_token, users, msg_type, msg)
def _gen_text_msg(text):
msg_type = 'text'
msg = { "content": text }
return msg_type, msg
def _send_msg_to_users(access_token, users, msg_type, msg):
to_users = '|'.join(users)
body_dict = {
"touser": to_users,
"agentid": agent_id,
"msgtype": msg_type
}
body_dict[msg_type] = msg
body = json.dumps(body_dict)
return _send_msg("https://oapi.dingtalk.com/message/send?access_token=", access_token, body)
其中agent_id是一个钉钉应用的id,以钉钉应用的名义给用户发送消息。users是用户id列表,每个用户id是一个字符串。
发送链接
def send_link_to_users(access_token, users, url, title, text):
msg_type, msg = _gen_link_msg(url, title, text)
return _send_msg_to_users(access_token, users, msg_type, msg)
def _gen_link_msg(url, title, text):
msg_type = 'link'
msg = {
"messageUrl": url,
"picUrl": "https://gw.alicdn.com/tps/TB1FN16LFXXXXXJXpXXXXXXXXXX-256-130.png",
"title": title,
"text": text
}
return msg_type, msg
其中_send_msg_to_users方法参见前面的代码,picUrl字段设置的是钉钉官方的图片,这里用于测试。
发送文件
def send_file_to_users(access_token, users, file_name):
media_id = upload_file(access_token, file_name)
if media_id == '':
return
msg_type, msg = _gen_file_msg(media_id)
return _send_msg_to_users(access_token, users, msg_type, msg)
def upload_file(access_token, file_name):
register_openers()
datagen, headers = multipart_encode({'media': open(file_name, 'rb')})
requst_url = 'https://oapi.dingtalk.com/media/upload?access_token=' + access_token + '&type=file'
request = urllib2.Request(requst_url, datagen, headers)
response = urllib2.urlopen(request)
response_str = response.read()
response_dict = json.loads(response_str)
media_id_key = 'media_id'
error_code_key = 'errcode'
if response_dict.has_key(error_code_key) and response_dict[error_code_key] == 0 and response_dict.has_key(media_id_key):
return response_dict[media_id_key]
else:
return ''
需要先上传文件获得media_id,然后使用media_id将文件发送给用户。另外,这里用到了poster,可使用pip安装:
pip install poster
之后引入multipart_encode和register_openers函数:
from poster.encode import multipart_encode
from poster.streaminghttp import register_openers
给群会话发送消息
与给用户发送信息类似,区别是需要群会话id,而不是用户列表,以发送文本消息为例,代码如下:
def send_text_to_chat(access_token, chat_id, text):
msg_type, msg = _gen_text_msg(text)
return _send_msg_to_chat(access_token, chat_id, msg_type, msg)
def _send_msg_to_chat(access_token, chat_id, msg_type, msg):
body_dict = {
"chatid": chat_id,
"msgtype": msg_type
}
body_dict[msg_type] = msg
body = json.dumps(body_dict)
return _send_msg("https://oapi.dingtalk.com/chat/send?access_token=", access_token, body)
其中_gen_text_msg方法参见前面的代码。
群会话可以自行创建,参见https://open-doc.dingtalk.com/docs/doc.htm?treeId=172&articleId=104977&docType=1 。
来源:https://blog.csdn.net/anxiaoyuthss/article/details/71908522
猜你喜欢
- 阅读上一篇:FrontPage XP设计教程4——Css样式表的应用表单在网站的制作过程中是比较常见的,举个简单的例子,我们在申请免费电子信
- 一 简介python-mysql-replication 是基于python实现的 MySQL复制协议工具,我们可以用它来解析binlog
- php获取文件创建时间、修改时间常用代码filemtime ( string filename )返回文件上次被修改的时间,出错时返回 FA
- 如下所示:import socketimport threadingimport timedef testconn( host , port
- 本文主要给大家介绍了关于python实现循环购物车功能的相关内容,分享出来供大家参考学习,下面来一起看看详细的介绍:示例代码# -*- co
- 第一种情况是返回的游标是某个具体的表或视图的数据,如:SQL-Code:CREATE OR REPLACE P
- Tuple 叫做 tuple,用小括号、或者无括号来表述,是一连串有顺序的数字。a_tuple = (12, 3, 5, 15 , 6)an
- 有时候我们可能需要import另一个路径下的python文件,例如下面这个目录结构,我们想要在_train.py里import在networ
- OCR of Hand-written Data using kNNOCR of Hand-written Digits我们的目标是构建一个
- 为了防止网络上日益猖獗的垃圾广告和灌水评论,大多数网站在信息发布的时候要求输入验证码。图片、文字、字母甚至还有计算题。验证码图片里的信息东颠
- 本文实例讲述了python函数局部变量用法。分享给大家供大家参考。具体分析如下:当你在函数定义内声明变量的时候,它们与函数外具有相同名称的其
- 在numpy中的ndarry是一个数组,因此index就是位置下标,注意下标是从0开始增加:在插入时使用np.insert(),在末尾添加时
- Numba是Python的即时编译器,在使用NumPy数组和函数以及循环的代码上效果最佳。使用Numba的最常见方法是通过其装饰器集合,这些
- 概述编程的内核是数学,而测试的本质是计算,专业名词叫容量预估,而测试的大体就是用程序模拟程序,检测程序的正确性,有两个点需要注意,QPS最佳
- 一、初步认识socket被翻译成套接字,尽管有些人诟病,但我觉得还挺贴切的。其功能是提供低级别的网络服务,最常用的就是根据IP来传输数据。所
- python模拟登陆网页主要使用到urllib、urllib2、cookielib及BeautifulSoup等基本模块,当然进阶阶段我们还
- 前言老早就看到新闻员工通过人脸识别监控老板来摸鱼。有时候摸鱼太入迷了,经常在上班时间玩其他的东西被老板看到。自从在咸鱼上淘了一个树莓派3b,
- 核心导出作业的 代码 和 作业备份是相似的 代码如下:alter PROC DumpJob (@job VARCHAR(100)
- 1、残差连接是目前常用的组件,解决了大规模深度学习模型梯度消失和瓶颈问题。通常,在10层以上的模型中追加残差连接可能有帮助。from ker
- 列表的逆序遍历a = [1,3,6,8,9]print("通过下标逆序遍历1:")for i in a[::-1]: &