1. 学习
  2. /
  3. 课程
  4. /
  5. Python 中的 Apache Airflow 入门

Connected

练习

使用 Jinja 编写

随着您更多地使用 Airflow,您添加了各种通知回调,但发现每次收件箱里都是相同的消息。主题始终一样,导致很难定位具体哪一封。阅读了 Airflow 对 Jinja 的支持后,您意识到可以加入一些标识信息,确保您的 Dags 为每天的运行各自发送报告。您决定先从更新 sales_update Dag 开始:当成功完成时,给您发送一封带有模板化主题的电子邮件。

所有必需的 Airflow 导入都已可用,任务 pull_sales_data 和 generate_sales_report 也都已经定义。

说明

100 XP
  • 配置 Dag 在无错误完成时向您发送电子邮件。

  • 为通知邮件设置 subject 属性。

  • 使用 Jinja 模板在主题行中包含运行日期:

    Sales update successfully processed for YYYY-MM-DD