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

Nhiều @tasks hơn

Để tiếp tục triển khai workflow, bạn cần thêm một bước nữa để phân tích và lưu các thay đổi của tệp đã tải xuống. Dag process_sales đã được định nghĩa và đã có sẵn task pull_file. Trong trường hợp này, hàm Python đã được định nghĩa sẵn cho bạn, parse_file(inputfile, outputfile).

Lưu ý rằng khi triển khai các task trong Airflow, bạn không phải lúc nào cũng hiểu rõ từng bước được giao. Chỉ cần bạn biết cách bao bọc các bước đó trong cấu trúc của Airflow, bạn sẽ có thể triển khai workflow mong muốn.

Hướng dẫn

100 XP
  • Tạo một task Airflow bằng phương thức parse_file.
  • Gọi task với các đối số cần thiết.