Kom igångKom igång gratis

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

Visa kurs

Interaktiv övning med praktiskt arbete

Gör teori till handling med en av våra interaktiva övningar

Starta övningen