Hai Dag sales_pipeline_v3 (thượng nguồn) và sales_report (hạ nguồn) từ bài trước đã được triển khai và sẵn sàng chạy. Pipeline bán hàng chạy mỗi phút và phát ra một sự kiện daily_sales theo phân vùng ở mỗi lần chạy, trong khi báo cáo chỉ quan tâm đến ngày; đó chính là việc của StartOfDayMapper. Đến lúc xem chúng phối hợp với nhau.

Thực hiện tuần tự các bước sau:

Trong chế độ xem Dags, kích hoạt sales_report trước để nó sẵn sàng phản ứng khi sự kiện asset đến.
Sau đó kích hoạt sales_pipeline_v3; Dag này chạy mỗi phút và phát ra một sự kiện daily_sales đã phân vùng ở mỗi lần chạy.
Chờ khoảng một phút để sales_pipeline_v3 hoàn tất — khi đó sales_report sẽ tự động kích hoạt từ sự kiện asset.
Mở sales_report, vào thẻ Runs, mở lần chạy mới nhất và tìm Mapped Partition key ở đầu phần chi tiết lần chạy.

Định dạng ngày của Mapped Partition key là gì?

Lập lịch theo phân vùng với Asset Partitions

Create Your Free Account