如何在Python中实现自动化数据流水线中的失败告警邮件？-Python教程-PHP中文网

smtplib.smtp_ssl直连465端口最稳定，需用应用密码、环境变量管理配置，异常时在except中发送带堆栈和影响范围的纯文本邮件，并加限流防骚扰。

如何在python中实现自动化数据流水线中的失败告警邮件？

用 `smtplib` 发送纯文本告警邮件最轻量

Python 自带的 smtplib 足够应付流水线失败时的简明告警，不需要额外装包。关键不是“发得花哨”，而是“发得稳、收得到”。注意：Gmail、Outlook 等主流邮箱已禁用明文密码登录，必须用应用专用密码（App Password）或 OAuth2；国内企业邮箱常需开启 SMTP 服务并配置端口（如 465 或 587）。

常见错误：smtplib.SMTPAuthenticationError 多半是密码不对或未开 SMTP；smtplib.SMTPServerDisconnected 常因网络超时或服务器主动断连，建议加 try/except 重试 1 次。

实操建议：

用 smtplib.SMTP_SSL(host, port) 直连 465 端口（更稳定），避免先 starttls()
发件人地址必须和登录账号一致，否则部分邮箱会拒收
邮件正文用 \n 换行，别用
```
<br>
```
—— 这是纯文本邮件

示例片段：

import smtplib
from email.mime.text import MIMEText

msg = MIMEText(f"流水线失败：{job_name}\n错误：{error_msg}")
msg["Subject"] = "⚠️ 数据流水线异常"
msg["From"] = "alert@company.com"
msg["To"] = "team@company.com"

with smtplib.SMTP_SSL("smtp.company.com", 465) as s:
    s.login("alert@company.com", "app_password_here")
    s.send_message(msg)

捕获异常后触发邮件，别在 `finally` 里发

告警只应在真正失败时发出，不是每次运行都通知。把发邮件逻辑放在 except 块里，而不是 finally，否则成功也发、失败也发，失去告警意义。

容易踩的坑：

Secure Python Code Sandbox

安全 Python 代码沙箱：在隔离的沙箱中执行任意 Python 代码，预装 requests、NumPy、pandas 库。返回 stdout、stderr。

下载

没捕获具体异常类型，导致 KeyboardInterrupt（Ctrl+C）也被当成流水线失败 —— 应只捕获 Exception 或自定义的 DataPipelineError
异常信息直接传给邮件正文，但 str(e) 可能为空或不完整；推荐用 traceback.format_exc() 获取完整堆栈
流水线分多阶段（ETL → 校验 → 推送），应在每个关键节点单独 try/catch，而非整个脚本包一层 —— 否则无法定位失败环节

用环境变量管理邮箱配置，禁止硬编码

SMTP_HOST、SMTP_USER、SMTP_PASSWORD 这类敏感信息绝不能写死在代码里。CI/CD 流水线中尤其要通过环境变量注入，本地调试可用 .env 文件（配合 python-dotenv），但生产环境必须走系统级环境变量。

为什么重要？

Git 历史里一旦出现密码，即使删了也难彻底清除
不同环境（dev/staging/prod）SMTP 配置不同，硬编码会导致部署失败
Docker 容器中，用 -e SMTP_PASSWORD=xxx 传递比挂载文件更可控
检查是否漏配：启动时加一句 assert all(k in os.environ for k in ["SMTP_HOST", "SMTP_USER", "SMTP_PASSWORD"])