1. Learn
  2. /
  3. Courses
  4. /
  5. Python 中的 Apache Airflow 入门

Connected

Exercise

实现 SmtpNotifier

既然您已经成功创建了失败回调,团队负责人现在要求:每次 Dag 成功运行后,都要向团队别名发送电子邮件。您查阅了 Airflow 文档后,决定使用 Airflow 内置的通知器框架是最佳方案。

dag 和 task 对象已经导入,alert_on_failure 回调函数以及 get_sales_data 和 process_sales_data 任务也都已为您定义好。

Instructions

100 XP
  • 导入 SMTP 通知器对象。
  • 在 Dag 上添加成功回调属性。
  • 将通知发送给 [email protected]。
  • 包含一个主题。