Začněte nyníZačněte zdarma

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

Zobrazit kurz

Interaktivní praktické cvičení

Proměňte teorii v praxi s jedním z našich interaktivních cvičení

Začít cvičení