Bir Dag'i Python ile zamanla
Dags oluşturma konusunda epey şey öğrendin, ama şimdi belirli bir Dag'i haftanın belirli bir gününde belirli bir saatte zamanlamak istiyorsun. Bir iş arkadaşının Dag'i farklı bir sunucuya yeniden kurması gerekirse bu bilgilerin kodda yer almasını istiyorsun.
Airflow dag nesnesi ve uygun datetime metodları senin için içe aktarıldı.
Bu egzersiz, kursun bir parçasıdır
Python ile Apache Airflow’a Giriş
Egzersiz talimatları
- Dag'in başlangıç tarihini 1 Kasım 2025 olarak ayarla.
- Her Çarşamba saat 12:30 için cron söz dizimini kullanarak bir zamanlama yapılandır.
Uygulamalı etkileşimli egzersiz
Bu egzersizi bu örnek kodu tamamlayarak deneyin.
@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()