1. Học hỏi
    2. /
  2. Khoa Học
    3. /
  3. Giới thiệu về Apache Airflow bằng Python
Connected

Bài tập

Tạo một FileSensor

Sau khi đọc về FileSensor, bạn quyết định thử triển khai một phiên bản cơ bản để làm quen với một số tham số thường dùng. FileSensor này sẽ được dùng để đảm bảo một tệp dữ liệu cụ thể có mặt trước khi tiếp tục.

FileSensor sẽ thăm dò (poll) tệp theo chu kỳ đều đặn và dừng chờ khi đã vượt quá timeout giây. Với mode='reschedule', slot của worker sẽ được giải phóng giữa các lần thăm dò.

Hướng dẫn

100 XP
  • Import thư viện phù hợp để sử dụng FileSensor.
  • Gán precheck tham chiếu tới đối tượng FileSensor.
  • Cấu hình FileSensor tìm tệp "salesdata_ready.csv".
  • Đặt timeout là 5 phút.