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

Airflow DAGs

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

การแทน data pipeline ด้วย DAG นั้นสมเหตุสมผลมาก เพราะบางงานต้องเสร็จก่อนงานอื่นจึงจะเริ่มได้ ลองนึกภาพสายการผลิตในโรงงานรถยนต์ — แต่ละขั้นตอนต่อยอดจากขั้นก่อนหน้า ตัวอย่าง DAG สมมติอาจมีหน้าตาแบบนี้:

Example DAG

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

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

Data Engineering เบื้องต้น

ดูคอร์ส

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

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

# Create the DAG object
dag = DAG(dag_id="car_factory_simulation",
          default_args={"owner": "airflow","start_date": airflow.utils.dates.days_ago(2)},
          schedule_interval="____")
แก้ไขและรันโค้ด