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

Truyền dữ liệu với XCom

Bạn đang cập nhật một quy trình ETL để dùng XCom nhằm theo dõi thông tin dễ dàng hơn. Vì vậy, bạn cần cập nhật các quan hệ phụ thuộc giữa các tác vụ trong Dag.

Bạn đã có sẵn bốn tác vụ có thể dùng như sau:

  • extract() - Trả về order_data
  • transform(order_data) - Trả về dữ liệu đã tổng hợp
  • load(summary_data) - Không trả về thông tin XCom
  • send_report() - Một tác vụ không dùng XCom, xử lý việc gửi thông báo

Hướng dẫn

100 XP
  • Chèn tác vụ transform vào giữa extract() và load() để hoàn thiện chuỗi.
  • Gán kết quả vào một biến tên là etl_result.
  • Thiết lập send_report chạy sau biến etl_result.