การสร้าง Dag อย่างง่าย
หลังจากที่ได้ศึกษาองค์ประกอบต่าง ๆ ของ Airflow แล้ว ก็ถึงเวลาทดลองสร้าง workflow ของตัวเอง เริ่มต้นด้วยการกำหนดพารามิเตอร์เริ่มต้นและสร้าง Dag object สำหรับ workflow
ได้นำเข้า datetime object ให้เรียบร้อยแล้ว
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
Apache Airflow เบื้องต้นด้วย Python
คำแนะนำการฝึกหัด
- นำเข้า Airflow Dag object โดยระวังเรื่องตัวพิมพ์เล็ก-ใหญ่ด้วย
- กำหนด Dag decorator และตั้งชื่อ Dag ว่า
example_etl - เรียกใช้ฟังก์ชัน Dag ที่ท้ายไฟล์โค้ด
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำ
ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์
# Import the dag object
from ____ import dag
# Define the Dag attributes
____(
____='example_etl',
start_date=datetime(2026, 3, 1),
)
def example_etl():
pass
# Run the Dag
____()