Crearea unui pipeline partiționat
Un eveniment simplu de asset îi informează consumatorii din aval că „ceva s-a schimbat", fără să precizeze care segment de date. În practică, echipele de raportare și analiză trebuie de obicei să reproceseze doar partiția care s-a modificat efectiv – de exemplu, o singură zi – în loc să ruleze totul din nou. Asset Partitions transmit cheia de partiție în aval, astfel încât consumatorii pot reacționa exact la segmentul potrivit. În acest exercițiu, vei programa pipeline-ul de vânzări pe un timetable zilnic cu partiții și vei emite un eveniment daily_sales partiționat la fiecare rulare.
Acest exercițiu face parte din cursul
Construirea pipeline-urilor de date cu Airflow
Exercițiu interactiv practic
Transformă teoria în practică cu unul dintre exercițiile noastre interactive
Începe exercițiul