Bir SLA tanımlama
Birkaç Airflow iş akışını başarıyla canlıya aldın, ancak şu anda bir iş akışının çalışmasının fazla uzun sürüp sürmediğini belirlemenin bir yolu yok. Yöneticin ve ekibinle görüştükten sonra, bir test iş akışında DAG düzeyinde bir SLA uygulamaya karar verdin.
Gerekli tüm Airflow kütüphaneleri senin için içe aktarıldı.
Bu egzersiz
Python ile Apache Airflow'a Giriş
kursunun bir parçasıdırEgzersiz talimatları
timedeltanesnesini içe aktar.- 30 dakikalık bir
slatanımla. - SLA'yı DAG'e ekle.
Uygulamalı interaktif egzersiz
Bu örnek kodu tamamlayarak bu egzersizi bitirin.
# Import the timedelta object
____
# Create the dictionary entry
default_args = {
'start_date': datetime(2024, 1, 20),
'____': ____
}
# Add to the DAG
test_dag = DAG('test_workflow', default_args=____, schedule_interval=None)