Parametrizace SQL a přesun dotazů do souborů
Inline SQL řetězce rychle přestanou být přehledné a datový tým je nemůže snadno revidovat. Tým proto přesunul agregaci do souboru include/sql/aggregate_sales.sql, kde je po boku zbytku projektu. Uprav dotaz tak, aby byl závislý na datu a každý běh zpracoval jediný den, a pak nasměruj pipeline na tento soubor. Jako cestu ke složce SQL použij /home/repl/workspace/include/sql.
Toto cvičení je součástí kurzu
Tvorba datových pipeline s Airflow
Interaktivní praktické cvičení
Proměňte teorii v praxi s jedním z našich interaktivních cvičení
Začít cvičení