การเชื่อมต่อ Classic Operator เข้ากับ TaskFlow Task
ไปป์ไลน์ของคุณมี BashOperator ที่ดึงวันที่ปัจจุบัน และเพื่อนร่วมงานได้เขียนฟังก์ชัน @task สำหรับบันทึก timestamp นั้น แต่ยังไม่ได้เชื่อมต่อกัน
ต้องใช้ attribute ที่ถูกต้องบน classic operator เพื่อส่งผลลัพธ์ไปยังฟังก์ชัน TaskFlow
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
การสร้าง Data Pipeline ด้วย Airflow
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำจริง
เปลี่ยนทฤษฎีให้เป็นการลงมือทำด้วยแบบฝึกหัดเชิงโต้ตอบหนึ่งในของเรา
เริ่มแบบฝึกหัด