เริ่มต้นใช้งานเริ่มต้นใช้งานได้ฟรี

ตัวแปรที่ยังไม่ถูกต้อง

หัวหน้าของคุณให้ไปตรวจสอบปัญหาที่รายงานยอดขายไม่ถูกสร้างขึ้น คุณเพิ่งนำตัวแปรมาใช้ใน DAG ชื่อ process_sales ซึ่งประมวลผลข้อมูลยอดขายและเขียนรายงานที่หัวหน้าต้องการ เมื่อดูที่ log พบว่าไฟล์ถูกบันทึกไปยัง path เริ่มต้น ไม่ใช่ตำแหน่งที่ตั้งใจไว้

งานที่ประมวลผลรายงานทำงานดังนี้:

@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}")

ไฟล์ควรถูกบันทึกที่ /data/sales/sales_report.pdf

ลองรันคำสั่ง airflow dags test process_sales เพื่อดูผลลัพธ์ของ log

ข้อใดต่อไปนี้คือสาเหตุของข้อผิดพลาด และควรแก้ไขอย่างไร?

แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร

Apache Airflow เบื้องต้นด้วย Python

ดูคอร์ส

แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำจริง

เปลี่ยนทฤษฎีให้เป็นการลงมือทำด้วยแบบฝึกหัดเชิงโต้ตอบหนึ่งในของเรา

เริ่มแบบฝึกหัด