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

Bài tập

Định nghĩa thứ tự cho các BashOperator

Giờ bạn đã biết về các toán tử bitshift, hãy sửa workflow để thêm bước pull và thiết lập thứ tự các task. Bạn hiện có ba thành phần đã được định nghĩa: cleanup, consolidate và push_data.

DAG analytics_dag có sẵn như trước và BashOperator đã được import.

Hướng dẫn

100 XP
  • Tạo một BashOperator tên pull_sales với lệnh bash wget https://salestracking/latestinfo?json.
  • Đặt pull_sales chạy trước task cleanup.
  • Cấu hình consolidate chạy kế tiếp, sử dụng toán tử downstream.
  • Đặt push_data chạy cuối cùng bằng cách dùng một trong hai toán tử bitshift.