Backfill dữ liệu lịch sử
Dữ liệu đến muộn là chuyện thường gặp. Dag daily_sales_load của bạn vẫn chạy ổn, nhưng dữ liệu đơn hàng cho các ngày 20–22/04 chỉ mới đổ vào raw_orders hôm nay, để lại ba khoảng trống trong daily_summary. Cách khắc phục là chạy backfill. Dag hiện đang hoạt động, nên bạn sẽ thấy một lần chạy scheduled cho hôm nay bên cạnh các lần chạy backfill bạn tạo.
- Chạy
airflow backfill create --dag-id daily_sales_load --from-date 2026-04-20 --to-date 2026-04-22 --max-active-runs 1trong terminal. - Đợi khoảng 30 giây để các lần chạy backfill hoàn tất.
- Chạy
airflow dags list-runs daily_sales_loadđể xem tất cả các lần chạy.
Xem cột run_id trong đầu ra. Các lần chạy backfill bắt đầu với tiền tố nào?
Bài tập này là một phần của khóa học
Xây dựng Data Pipeline với Airflow
Bài tập tương tác thực hành
Biến lý thuyết thành hành động với một trong các bài tập tương tác của chúng tôi
Bắt đầu bài tập