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
Exercițiu interactiv practic
Transformă teoria în practică cu unul dintre exercițiile noastre interactive
Începe exercițiul