Lên lịch một Dag bằng Python
Bạn đã học khá nhiều về cách tạo Dag, nhưng giờ bạn muốn lên lịch cho một Dag cụ thể vào một ngày cố định trong tuần vào một thời điểm nhất định. Bạn muốn phần mã bao gồm thông tin này phòng khi đồng nghiệp cần cài đặt lại Dag lên một máy chủ khác.
Đối tượng dag của Airflow và các phương thức datetime phù hợp đã được nhập sẵn cho bạn.
Bài tập này là một phần của khóa học
Giới thiệu về Apache Airflow bằng Python
Hướng dẫn bài tập
- Đặt ngày bắt đầu của Dag là 1 tháng 11, 2025.
- Dùng cú pháp cron để cấu hình lịch chạy vào mỗi thứ Tư lúc 12:30pm.
Bài tập tương tác thực hành trực tiếp
Hãy thử làm bài tập này bằng cách hoàn thành đoạn mã mẫu này.
@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()