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

Airflow DAGs

ใน Airflow ไปป์ไลน์จะถูกแสดงเป็น Directed Acyclic Graph หรือ DAG โหนดของกราฟแสดงถึงงาน (task) ที่ถูกดำเนินการ ส่วนเส้นเชื่อมแบบมีทิศทางระหว่างโหนดแสดงถึงความสัมพันธ์แบบพึ่งพากันระหว่างงานเหล่านั้น

การแสดงไปป์ไลน์ข้อมูลในรูปแบบ DAG นั้นสมเหตุสมผลมาก เพราะบางงานจำเป็นต้องเสร็จสิ้นก่อนที่งานอื่นจะเริ่มได้ ลองเปรียบเทียบกับสายการประกอบในโรงงานผลิตรถยนต์ งานต่างๆ จะต่อยอดกันไปเรื่อยๆ และแต่ละงานอาจขึ้นอยู่กับว่างานก่อนหน้าเสร็จสิ้นแล้วหรือยัง ตัวอย่าง DAG สมมติอาจมีลักษณะดังนี้

Example DAG

การประกอบโครงรถจะเกิดขึ้นก่อน ตามด้วยตัวถังและยาง และสุดท้ายคือการพ่นสี มาลองสร้างตัวอย่างข้างต้นด้วยโค้ดกัน

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

Data Engineering เบื้องต้น

ดูคอร์ส

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

ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์

# Create the DAG
@dag(dag_id="car_factory_simulation",
     start_date=datetime(2024, 1, 1),
     schedule="____")
def car_factory_simulation():
    pass

# Run the DAG
car_factory_simulation()
แก้ไขและรันโค้ด