ตัวแปรที่ยังไม่ถูกต้อง
หัวหน้าของคุณให้ไปตรวจสอบปัญหาที่รายงานยอดขายไม่ถูกสร้างขึ้น คุณเพิ่งนำตัวแปรมาใช้ใน 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
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำจริง
เปลี่ยนทฤษฎีให้เป็นการลงมือทำด้วยแบบฝึกหัดเชิงโต้ตอบหนึ่งในของเรา
เริ่มแบบฝึกหัด