Створення розділеного на партиції конвеєра
Звичайна подія активу повідомляє споживачам нижче за потоком, що «щось змінилося», але не вказує, який саме фрагмент даних. На практиці командам звітності та аналітики зазвичай потрібно перезапускати лише ту партицію, яка справді змінилася, наприклад один день, а не все заново. Партиції активів передають ключ партиції далі за потоком, тож споживачі можуть реагувати саме на потрібний фрагмент. У цій вправі ви розкладете свій конвеєр продажів за щоденним розкладом партицій і на кожному запуску публікуватимете партиційовану подію daily_sales.
Ця вправа є частиною курсу
Створення конвеєрів даних з Airflow
Практична інтерактивна вправа
Перетворіть теорію на практику за допомогою однієї з наших інтерактивних вправ
Почати вправу