ÎncepețiÎncepe gratuit

Adăugarea verificărilor de calitate la nivel de coloană

Un pipeline care încarcă date incorecte în mod regulat este mai rău decât unul care eșuează vizibil. Înainte ca echipele din aval să consume daily_summary, vei adăuga o poartă de calitate la nivel de coloană, care rulează imediat după încărcare și respinge execuția dacă veniturile scad sub zero sau dacă numărul de comenzi conține valori lipsă.

Task-ul de încărcare și fișierul SQL sunt precompletate din lecțiile anterioare.

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