Parametrisera SQL och bryt ut det till filer
Inline-SQL-strängar blir snabbt svårhanterliga och går inte att granska med ditt datateam. Teamet har extraherat aggregeringen till include/sql/aggregate_sales.sql så att den ligger tillsammans med resten av projektet. Gör frågan datummedveten så att varje körning bearbetar en enda dag, och peka sedan om pipelinen mot filen. Använd /home/repl/workspace/include/sql som sökväg till SQL-mappen.
Den här övningen är en del av kursen
Bygg datapipelines med Airflow
Interaktiv övning med praktiskt arbete
Gör teori till handling med en av våra interaktiva övningar
Starta övningen