1. Learn
    2. /
  2. Курси
    3. /
  3. Вступ до Apache Airflow на Python
Connected

вправа

Пишемо з Jinja

Працюючи з Airflow, ви додали різні зворотні виклики для сповіщень, але помітили, що у скриньку щоразу приходять однакові повідомлення. Складно знайти потрібне, коли тема листа завжди одна й та сама. Прочитавши про підтримку Jinja в Airflow, ви зрозуміли, що можна додати ідентифікаційну інформацію, щоб ваші Dags надсилали звіт для кожного денного запуску. Ви вирішили почати з оновлення Dag sales_update, щоб після успішного завершення він надсилав вам електронний лист із шаблонною темою.

Усі необхідні імпорти Airflow уже доступні, а задачі pull_sales_data і generate_sales_report уже визначені.

Інструкції

100 XP

  • Налаштуйте Dag так, щоб він надсилав вам електронний лист після завершення без помилок.

  • Задайте атрибут subject для листа-сповіщення.

  • Використайте шаблон Jinja, щоб додати дату запуску в рядок теми:

    Sales update successfully processed for YYYY-MM-DD