Xử lý nhiều endpoint với expand

Nhóm của bạn lấy dữ liệu từ nhiều endpoint của API và các endpoint này thay đổi theo thời gian. Việc hardcode một tác vụ riêng cho từng endpoint buộc bạn phải chỉnh sửa Dag mỗi khi thêm hoặc bớt endpoint. Trong bài tập này, bạn sẽ biến pipeline cứng nhắc đó thành pipeline dẫn dắt bởi dữ liệu: với expand(), Airflow sẽ đọc danh sách endpoint khi chạy và tạo một instance tác vụ cho từng mục, vì thế pipeline sẽ tự động điều chỉnh theo số lượng endpoint.