Değişkenler tam tutmuyor
Patronun, bir satış raporunun oluşturulmadığı bir konuyu incelemeni istiyor. Kısa süre önce, çeşitli satış verilerini işleyip patronunun istediği raporu yazdıran Dags’lerinden birinde (process_sales) değişkenleri uyguladın. Günlüklere bakarken, çıktının hedeflenen konuma değil, varsayılan bir konuma yazıldığını fark ediyorsun.
Raporu işleyen görev şunu yapıyor:
@task()
def parse_file():
output_path = Variable.get("Output_Path", default="/home")
output_fn = Variable.get("Output_Filename", default="sales_report.pdf")
save_file("{output_path}/{output_fn}")
Dosya /data/sales/sales_report.pdf olarak kaydedilmelidir.
Günlük çıktısını görmek için airflow dags test process_sales komutunu çalıştırmayı dene.
Aşağıdakilerden hangisi hatanın nedeni ve bunu nasıl düzeltirsin?
Bu egzersiz, kursun bir parçasıdır
Python ile Apache Airflow’a Giriş
Uygulamalı etkileşimli egzersiz
Teoriyi etkileşime dönüştürün, interaktif egzersizlerimizden biriyle
Egzersize başla