1. 학습
    2. /
  2. 강의
    3. /
  3. Giới thiệu về Apache Airflow với Python
Connected

연습 문제

Thêm PythonOperator

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

Lưu ý: khi triển khai các task trong Airflow, đôi khi bạn sẽ không hiểu tường tận từng bước được giao. Chỉ cần bạn nắm cách “đóng gói” các bước vào cấu trúc của Airflow, bạn sẽ có thể triển khai được workflow mong muốn.

지침

100 XP
  • Định nghĩa task Python vào biến parse_file_task với id parse_file.
  • Thêm parse_file(inputfile, outputfile) vào Operator.
  • Xác định các đối số sẽ truyền vào callable.