Vytvoření particionovaného pipeline
Obyčejná asset událost říká downstream konzumentům, že „něco se změnilo", ale neurčuje, která část dat. V praxi týmy reportingu a analytiky obvykle potřebují znovu zpracovat jen tu partici, která se skutečně změnila – třeba jeden konkrétní den – místo toho, aby spouštěly celý pipeline znovu. Asset partitions nesou klíč partice dále po proudu, takže konzumenti mohou reagovat přesně na tu správnou část dat. V tomto cvičení naplánuješ svůj sales pipeline na denní particový timetable a při každém spuštění vyšleš particionovanou událost daily_sales.
Toto cvičení je součástí kurzu
Tvorba datových pipeline s Airflow
Interaktivní praktické cvičení
Proměňte teorii v praxi s jedním z našich interaktivních cvičení
Začít cvičení