Создание простого 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
____()