Lập lịch trên các asset đã phân vùng

Giờ đây khi upstream phát ra các sự kiện daily_sales đã được phân vùng, Dag báo cáo có thể tự động phản ứng với chúng, chỉ chạy cho đúng phân vùng vừa được làm mới thay vì xử lý lại mọi ngày. Upstream phát ra timestamp đầy đủ, nhưng báo cáo chỉ quan tâm đến ngày trên lịch; chuẩn hóa khóa đó chính là mục đích của StartOfDayMapper. Trong bài tập này, bạn sẽ lập lịch cho báo cáo downstream dựa trên asset đã phân vùng và ánh xạ từng sự kiện về đúng ngày của nó.

Phần upstream đã được điền sẵn trong tệp để bạn tham khảo ngữ cảnh, và bạn sẽ thấy cả hai Dag phối hợp với nhau trong bài tập tiếp theo.