Variabel kurang tepat
Atasan Anda meminta Anda menelusuri masalah di mana laporan penjualan tidak dihasilkan. Anda baru saja menerapkan variabel dalam salah satu Dag Anda (process_sales) yang memproses beragam data penjualan dan menulis laporan yang diminta atasan Anda. Saat meninjau log, Anda menyadari bahwa file tidak ditulis ke lokasi yang diinginkan, melainkan ke lokasi default.
Tugas yang memproses laporan melakukan hal berikut:
@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}")
File seharusnya disimpan sebagai /data/sales/sales_report.pdf.
Coba jalankan perintah airflow dags test process_sales untuk melihat keluaran log.
Manakah dari berikut ini alasan kesalahannya, dan bagaimana Anda akan memperbaikinya?
Latihan ini merupakan bagian dari kursus
Pengantar Apache Airflow dengan Python
Latihan interaktif langsung
Ubah teori menjadi aksi dengan salah satu latihan interaktif kami
Mulai latihan