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

вправа

Реалізація SmtpNotifier

Тепер, коли ви успішно створили зворотний виклик на помилку, ліду вашої команди потрібно, щоб усі успішні запуски Dag надсилалися електронною поштою на командний аліас. Ознайомившись із документацією Airflow, ви вирішили, що найкращий варіант — скористатися вбудованим фреймворком сповіщень Airflow.

Об'єкти dag і task уже імпортовано, функцію зворотного виклику alert_on_failure і завдання get_sales_data та process_sales_data уже визначено для вас.

Інструкції

100 XP
  • Імпортуйте об'єкт сповіщення SMTP.
  • Додайте атрибут зворотного виклику успіху до Dag.
  • Надішліть сповіщення на [email protected].
  • Додайте тему листа.