Schemalägg en DAG via Python
Du har lärt dig en hel del om hur man skapar DAGs, och nu vill du schemalägga en specifik DAG på en viss veckodag vid en bestämd tidpunkt. Du vill att koden ska innehålla den här informationen ifall en kollega behöver installera om DAGen på en annan server.
Airflow-objektet dag och lämpliga datetime-metoder har redan importerats åt dig.
Den här övningen är en del av kursen
Introduktion till Apache Airflow i Python
Övningsinstruktioner
- Ange startdatumet för DAGen till den 1 november 2025.
- Använd cron-syntax för att konfigurera ett schema som kör varje onsdag kl. 12:30.
Interaktiv övning med praktiskt arbete
Testa den här övningen genom att slutföra den här exempelkoden.
@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()