Báo hiệu dữ liệu sẵn sàng với Asset outlet

Nhóm của bạn có một pipeline ghi dữ liệu bán hàng hằng ngày vào s3://data-lake/sales/daily.csv, và một số pipeline phía sau phụ thuộc vào nó. Thay vì để chúng thăm dò theo lịch hoặc đoán khi nào tệp sẵn sàng, bạn sẽ gắn một Asset outlet để tác vụ này phát tín hiệu rằng dữ liệu đã được cập nhật ngay khi nó hoàn tất. Tín hiệu đó cho phép các Dag khác tự lập lịch dựa trên chính dữ liệu.

Sau khi hoàn thành mã, hãy chạy tệp, rồi xác minh asset đã được đăng ký và cập nhật bằng Airflow CLI.