Parameterizing SQL and extracting it into files
Inline SQL strings get unwieldy fast and can't be reviewed by your data team. Your team has extracted the aggregation into include/sql/aggregate_sales.sql so it lives next to the rest of the project. Make the query date-aware so each run processes a single day, then point the pipeline at the file. Use /home/repl/workspace/include/sql as the SQL folder path.
Diese Übung ist Teil des Kurses
<Kurs>Building Data Pipelines with Airflow</Kurs>Interaktive praktische Übung
Verwandle Theorie mit einer unserer interaktiven Übungen in die Praxis
Übung starten