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

Connected

Bài tập

Thêm decorator cho một task

Bạn quyết định triển khai một task cụ thể của Airflow bằng Python. Task này cần tải xuống và lưu một tệp vào hệ thống trong Airflow, sử dụng hàm pull_file. Hàm này đã được định nghĩa sẵn cho bạn.

Thư viện requests và đối tượng dag của Airflow đã được import sẵn.

Hướng dẫn

100 XP
  • Import đối tượng cần thiết từ thư viện Airflow.
  • Cấu hình hàm pull_file để trở thành một task của Airflow.
  • Gọi đối tượng task.