Створення простого Dag
Ви ознайомилися з компонентами Airflow і хочете випробувати власні робочі процеси. Спочатку ви вирішили визначити параметри за замовчуванням і створити об'єкт Dag для свого робочого процесу.
Об'єкт datetime вже імпортовано для вас.
Ця вправа є частиною курсу
Вступ до Apache Airflow на Python
Інструкції до вправи
- Імпортуйте об'єкт Dag з Airflow; зауважте, що враховується регістр.
- Визначте декоратор Dag і назвіть Dag
example_etl. - Запустіть функцію Dag наприкінці файлу коду.
Інтерактивна практична вправа
Спробуйте виконати цю вправу, доповнивши цей зразок коду.
# Import the dag object
from ____ import dag
# Define the Dag attributes
____(
____='example_etl',
start_date=datetime(2026, 3, 1),
)
def example_etl():
pass
# Run the Dag
____()