Mulai sekarangMulai gratis

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

Lihat Kursus

Latihan interaktif langsung

Ubah teori menjadi aksi dengan salah satu latihan interaktif kami

Mulai latihan