Tạo một Dag đơn giản
Bạn đã dành thời gian xem lại các thành phần của Airflow và muốn thử nghiệm quy trình làm việc của riêng mình. Bắt đầu bằng cách bạn sẽ định nghĩa các tham số mặc định và tạo một đối tượng Dag cho quy trình làm việc.
Đối tượng datetime đã đượ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
- Import đối tượng Dag của Airflow; lưu ý là phân biệt chữ hoa chữ thường.
- Định nghĩa decorator Dag và đặt tên Dag là
example_etl. - Chạy hàm Dag ở cuối tệp mã.
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.
# 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
____()