简介 #
SmartPip 支持在 DAG 任务中发送邮件或企业微信消息通知，支持固定内容和动态数据两种方式。适用于任务执行完成后的结果通知。
消息发送方式对比 #
| 方式 | 驱动 | 适用场景 |
|---|---|---|
| 邮件 | #send_mail |
正式报告、详细数据 |
| 企微 | #diy + 数据集 |
实时告警、简短通知 |
使用说明 #
固定内容发送 #
msg = ['报表刷新成功', '<h1>刷新成功!!</h1>']
maillist = 'xxx@smartchart.cn'
#send_mail reportmail msg maillist
动态获取数据发送 #
maillist = 'xxx@smartchart.cn,abc@xxx.cn'
def fun_msg():
result = get_dataset(123)['data']
msg = f'<h3>尊敬的领导:</h3><p style="text-indent:20px">当前销售额:{result[1][0]}</p>'
title = '销售额监控'
return title, msg
#send_mail reportmail fun_msg maillist
发送企微消息 #
-
在smartchart中新建一个企微数据源
-
新建一个数据集并使用qiweiMsg这个数据源, 按照企微消息发送文档填写, 记下数据集ID如 12
{
"touser" : "1359xxxxx",
-- "totag" : "4",
"msgtype" : "text",
"agentid" : xxxxxxx,
"text" : {
"content" : "$msg"
},
"safe":0}
- 在DAG中可以使用通过自定义任务来进行企微发送
def notice_content():
return get_dataset(12, param={'msg':'hello world'})
#diy qiwei_notice notice_content