Вищий за потоком sales_pipeline_v3 і нижчий за потоком sales_report з попередньої вправи розгорнуті та готові до запуску. Конвеєр продажів запускається щохвилини й під час кожного запуску генерує подію розділеного активу daily_sales, тоді як звіт цікавить лише дата; саме для цього потрібен StartOfDayMapper. Час подивитися, як вони працюють разом.

Виконайте ці кроки по черзі:

У поданні Dags спершу активуйте sales_report, щоб він був готовий відреагувати, коли надійде подія активу.
Потім активуйте sales_pipeline_v3; він працює щохвилини та під час кожного запуску надсилає подію розділеного активу daily_sales.
Зачекайте приблизно хвилину, доки sales_pipeline_v3 завершиться — після цього sales_report автоматично запуститься від події активу.
Відкрийте sales_report, перейдіть на вкладку Runs, відкрийте останній запуск і знайдіть Mapped Partition key у верхній частині деталей запуску.

У якому форматі дата в полі Mapped Partition key?

Вітаємо!

Create Your Free Account