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

Exercise

Định nghĩa một tác vụ BashOperator

BashOperator cho phép bạn chỉ định bất kỳ lệnh hoặc script Shell nào và thêm nó vào một workflow của Airflow. Đây có thể là bước khởi đầu tuyệt vời để triển khai Airflow trong môi trường của bạn.

Hiện tại, bạn đang chạy thủ công một số script để làm sạch dữ liệu (dùng script tên cleanup.sh) trước khi bàn giao cho đồng nghiệp trong nhóm Data Analytics. Khi ngày càng có nhiều tác vụ như vậy, bạn nhận ra thật khó để chạy mọi thứ thủ công, chưa kể xử lý lỗi hay thử lại. Bạn muốn triển khai script đơn giản này dưới dạng một operator trong Airflow.

DAG Airflow analytics_dag đã được định nghĩa sẵn cho bạn và có đầy đủ cấu hình cần thiết.

Instructions

100 XP
  • Import đối tượng BashOperator.
  • Định nghĩa một BashOperator tên cleanup với task_id là cleanup_task.
  • Dùng lệnh cleanup.sh.