Aan de slagBegin gratis

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

Bekijk cursus

Interactieve oefening met praktijkervaring

Zet theorie om in actie met een van onze interactieve oefeningen

Begin oefening