Реалізація SmtpNotifier
Тепер, коли ви успішно створили зворотний виклик на помилку, ліду вашої команди потрібно, щоб усі успішні запуски Dag надсилалися електронною поштою на командний аліас. Ознайомившись із документацією Airflow, ви вирішили, що найкращий варіант — скористатися вбудованим фреймворком сповіщень Airflow.
Об'єкти dag і task уже імпортовано, функцію зворотного виклику alert_on_failure і завдання get_sales_data та process_sales_data уже визначено для вас.
Ця вправа є частиною курсу
Вступ до Apache Airflow на Python
Інструкції до вправи
- Імпортуйте об'єкт сповіщення SMTP.
- Додайте атрибут зворотного виклику успіху до Dag.
- Надішліть сповіщення на [email protected].
- Додайте тему листа.
Інтерактивна практична вправа
Спробуйте виконати цю вправу, доповнивши цей зразок коду.
# Import the notifier
from airflow.providers.smtp.notifications.smtp import ____
# Add a success callback notifier
@dag(dag_id='sales_etl_dag',
on_failure_callback=alert_on_failure,
____=SmtpNotifier(
to="____",
from_email="[email protected]",
____="sales_etl_dag run succeeded!"
))
def sales_etl_dag():
get_sales_data() >> process_sales_data()
sales_etl_dag()