Meerdere endpoints verwerken met expand
Jouw team haalt data op uit meerdere API-endpoints die in de tijd veranderen. Voor elk endpoint een aparte taak hardcoden betekent dat je de Dag steeds moet aanpassen als er een endpoint bijkomt of verdwijnt. In deze oefening maak je van die starre pipeline een data-gedreven variant: met expand() leest Airflow de lijst met endpoints tijdens runtime en start het één taakinstantie per item, zodat de pipeline automatisch meebeweegt als het aantal endpoints verandert.
Deze oefening maakt deel uit van de cursus
Data-pijplijnen bouwen met Airflow
Interactieve oefening met praktijkervaring
Zet theorie om in actie met een van onze interactieve oefeningen
Begin oefening