Заплануйте Dag за допомогою Python
Ви вже чимало дізналися про створення Dag'ів, але тепер хочете запланувати конкретний Dag на певний день тижня й на визначений час. Ви хочете, щоб цей розклад був у коді — на випадок, якщо колезі знадобиться перевстановити Dag на інший сервер.
Об'єкт Airflow dag і відповідні методи datetime уже імпортовано для вас.
Ця вправа є частиною курсу
Вступ до Apache Airflow на Python
Інструкції до вправи
- Встановіть дату початку Dag на 1 листопада 2025 року.
- Використайте синтаксис cron, щоб налаштувати розклад: щосереди о 12:30.
Інтерактивна практична вправа
Спробуйте виконати цю вправу, доповнивши цей зразок коду.
@dag(
dag_id='update_dataflows',
# Set to November 1, 2025
start_date=datetime(____),
# Every Wednesday at 12:30pm
schedule='____'
)
def update_dataflows():
@task
def pull_source_data():
pass
update_dataflows()