Bir DAG'ı Python ile zamanla
DAG oluşturma hakkında epey şey öğrendin, ama şimdi belirli bir DAG'ı haftanın belirli bir gününde, belirli bir saatte zamanlamak istiyorsun. Bir meslektaşının DAG'ı farklı bir sunucuya yeniden kurması gerekirse bu bilgiyi kodda bulundurmak istiyorsun.
Airflow DAG nesnesi ve uygun datetime yöntemleri senin için içe aktarıldı.
Bu egzersiz
Python ile Apache Airflow'a Giriş
kursunun bir parçasıdırEgzersiz talimatları
- DAG'ın başlangıç tarihini 1 Kasım 2023 olarak ayarla.
retry_delaydeğerini 20 dakikaya yapılandır.timedeltanesnesi hakkında 3. Bölümde daha fazla bilgi edineceksin. Şimdilik, bir tamsayı değer beklediğini bilmen yeterli.- Programlamayı her Çarşamba saat 12:30pm olacak şekilde cron söz dizimiyle yapılandır.
Uygulamalı interaktif egzersiz
Bu örnek kodu tamamlayarak bu egzersizi bitirin.
# Update the scheduling arguments as defined
default_args = {
'owner': 'Engineering',
'start_date': datetime(____, ____, ____),
'email': ['[email protected]'],
'email_on_failure': False,
'email_on_retry': False,
'retries': 3,
'retry_delay': timedelta(minutes=____)
}
dag = DAG('update_dataflows', default_args=default_args, schedule_interval='____')