Apache Airflow + Server酱：DAG 任务失败时微信收到通知

效果：Airflow 的 DAG 或任务运行失败/成功时，微信自动收到推送通知。

前置条件

已有 Server酱 SendKey（30 秒获取教程）。schan:// 协议对接 Server酱Turbo，SendKey 需以 SCT 开头。
Airflow 环境可安装 pip 包。如需推送到企业微信/钉钉/飞书群等其他通道，参阅通道说明。

配置步骤

1. 安装 apprise provider

pip install apache-airflow-providers-apprise

2. 创建 Apprise 连接

在 Airflow Web UI 中进入 Admin → Connections，新建一个 Apprise 类型连接：

连接类型：Apprise
连接名称：serverchan（自定义，后续 DAG 中引用此值）
config：schan://你的SENDKEY

schan:// 是 Apprise 中 Server酱的专用协议，底层调用 https://sctapi.ftqq.com/你的SENDKEY.send。通用 Apprise 接法详见站内 Apprise 集成指南。

3. 命令行自测（可选）

安装 apprise CLI 后可直接验证连通性：

pip install apprise && apprise -t "测试" -b "正文" "schan://你的SENDKEY"

收到微信推送说明 SendKey 和通道均正常。

4. 在 DAG 中配置 AppriseNotifier 回调

将 AppriseNotifier 实例作为 on_failure_callback / on_success_callback 传入 DAG 或 Task 的 default_args：

from airflow.providers.apprise.notifications.apprise import AppriseNotifier

serverchan_notifier = AppriseNotifier(conn_id="serverchan")

default_args = {
    "on_failure_callback": serverchan_notifier,
    "on_success_callback": serverchan_notifier,
}

conn_id 值需与第 2 步中创建的连接名称一致。

完整示例

以下 DAG 包含一个会失败的任务，部署后任务失败时微信收到告警：

from datetime import datetime
from airflow import DAG
from airflow.operators.bash import BashOperator
from airflow.providers.apprise.notifications.apprise import AppriseNotifier

notifier = AppriseNotifier(conn_id="serverchan")

with DAG(
    dag_id="serverchan_failure_demo",
    start_date=datetime(2026, 1, 1),
    schedule="@daily",
    default_args={"on_failure_callback": notifier},
    catchup=False,
) as dag:
    BashOperator(
        task_id="will_fail",
        bash_command="exit 1",
    )

任务因 exit 1 失败后，Airflow 调用 AppriseNotifier，经 schan:// 协议向 Server酱发送请求，微信收到失败告警。

常见问题

免费额度是多少？

Server酱Turbo 免费额度为每天 5 条，每分钟上限 50 条。订阅会员目前特价最低 3 元/月，一天最多可发 1000 条（价格详情）。

任务失败了但没收到微信通知？

先检查 Airflow 任务日志中 AppriseNotifier 是否被调用、conn_id 是否与连接名称一致。再确认 schan:// 后的 SendKey 是否正确。仍无法解决可参考常见问题与排查。

sctp 开头的 SendKey 能用吗？

schan:// 协议当前对接 Server酱Turbo 端点 https://sctapi.ftqq.com，仅支持 SCT 开头的 SendKey。sctp 开头的 SendKey 不适用于 schan:// 协议。

大量任务同时失败会触发太多通知吗？

Server酱每分钟上限 50 条。如果 DAG 中有大量并发任务同时失败，建议在回调中做聚合或限制，避免短时间内发送过多请求。