1. Learn
    2. /
  2. Courses
    3. /
  3. Giới thiệu về Apache Airflow với Python
Connected

Exercise

Sử dụng PythonOperator

Bạn đã triển khai một số tác vụ Airflow bằng BashOperator nhưng nhận ra rằng một vài tác vụ cụ thể sẽ phù hợp hơn nếu dùng Python. Bạn sẽ triển khai một tác vụ để tải xuống và lưu một tệp vào hệ thống ngay trong Airflow.

Thư viện requests đã được nhập sẵn cho bạn, và DAG process_sales_dag cũng đã được định nghĩa.

Instructions 1/3

undefined XP
    1
    2
    3
  • Định nghĩa một hàm tên pull_file với hai tham số, URL và savepath.
  • Dùng hàm print() và f-string của Python để ghi một thông báo vào logs.