กำหนดตารางเวลา Dag ด้วย Python
ตอนนี้คุณได้เรียนรู้เรื่องการสร้าง Dag มาพอสมควรแล้ว ขั้นต่อไปคือการกำหนดตารางเวลาให้ Dag ทำงานในวันและเวลาที่ต้องการ นอกจากนี้ ยังต้องการให้โค้ดมีข้อมูลเหล่านี้ไว้ด้วย เผื่อเพื่อนร่วมทีมจำเป็นต้องติดตั้ง Dag ใหม่บนเซิร์ฟเวอร์อื่น
ออบเจ็กต์ dag ของ Airflow และเมธอด datetime ที่เกี่ยวข้องได้ถูก import ไว้ให้แล้ว
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
Apache Airflow เบื้องต้นด้วย Python
คำแนะนำการฝึกหัด
- ตั้งค่าวันเริ่มต้นของ Dag เป็นวันที่ 1 พฤศจิกายน 2025
- ใช้ cron syntax เพื่อกำหนดตารางเวลาให้ทำงานทุกวันพุธ เวลา 12:30 น.
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำ
ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์
@dag(
dag_id='update_dataflows',
# Set to November 1, 2025
start_date=datetime(____),
# Every Wednesday at 12:30pm
schedule='____'
)
def update_dataflows():
@task
def pull_source_data():
pass
update_dataflows()