smtplib.SMTP_SSL直连465端口最稳定，需用应用密码、环境变量管理配置，异常时在except中发送带堆栈和影响范围的纯文本邮件，并加限流防骚扰。
用 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，否则成功也发、失败也发，失去告警意义。
立即学习“Python免费学习笔记（深入）”；
容易踩的坑：
安全 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"])
加简单限流，防流水线反复失败狂发邮件
如果某任务每分钟失败一次，又没做限制，1 小时可能发 60 封告警，团队立刻静音邮箱。这不是告警，是骚扰。
低成本限流方案：
- 用文件记录上次发送时间，每次发前检查间隔是否 >5 分钟（
os.path.getmtime+time.time()） - 更可靠的做法：在 Redis 存一个带过期时间的 key（如
alarm:etl_job_xxx，TTL=300），存在就不发 - 对同一错误码（如
"ConnectionRefusedError"）聚合计数，5 分钟内超 3 次才发，附上“近5次均失败”提示 - 避免在告警邮件里写“请立即处理”—— 收件人不负责你的流水线，写清“影响范围：昨日订单表未更新”更有效
真正难的不是发邮件，是让收件人一眼看懂哪里坏了、影响什么、是否需要干预。错误堆栈要截取关键行，别贴整页；时间戳统一用 UTC+8；如果流水线跑在 Kubernetes 上，顺手把 POD_NAME 和 NODE_NAME 也带上。
