ÎncepețiÎncepe gratuit

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

Vezi cursul

Exercițiu interactiv practic

Transformă teoria în practică cu unul dintre exercițiile noastre interactive

Începe exercițiul