Python'da bir variable okuma
DAG'lerinde Variables kullanmanın, geliştirme ve test Airflow sunucuların da dahil olduğu çeşitli ortamlardaki yapılandırma üzerinde biraz kontrol sağlayacağını fark ettin. Her biri için DAG kodunu güncelleme ihtiyacını ortadan kaldırmak için, sunucunda çeşitli dosyaların tutulduğu konumu saklamak üzere Output_Path adında bir variable uygulamaya karar verdin.
dag ve task nesneleri ile datetime senin için içe aktarıldı.
Bu egzersiz, kursun bir parçasıdır
Python ile Apache Airflow’a Giriş
Egzersiz talimatları
- Variables ile çalışmak için gerekli kütüphaneyi içe aktar.
- Airflow'dan
Output_Pathvariable'ını oku. Output_Pathtanımlı değilse/homeiçin bir geri dönüş değeri ver.
Uygulamalı etkileşimli egzersiz
Bu egzersizi bu örnek kodu tamamlayarak deneyin.
# Import the proper library to read Variables
from airflow.____ import ____
@dag(dag_id='process_sales', start_date=datetime(2026, 4, 15))
def process_sales():
@task()
def parse_file():
# Get the output file location, otherwise default to "/home"
output_path = ____.____("Output_Path", ____="/home")
# Logging only currently - processing to be added later
print(f"File parsed and saved to {output_path}/sales_report.pdf")
parse_file()
process_sales()