Bearbeta flera endpoints med expand
Ditt team hämtar data från flera API-endpoints som förändras över tid, och att hårdkoda en separat uppgift för var och en innebär att du måste redigera DAG:en varje gång en endpoint läggs till eller tas bort. I den här övningen omvandlar du den stela pipelinen till en datadrivet: med expand() läser Airflow listan över endpoints vid körningstillfället och skapar en uppgiftsinstans per post, så att pipelinen automatiskt anpassas när antalet endpoints förändras.
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