Inizia subitoInizia gratis

Elaborare più endpoint con expand

Il tuo team estrae dati da più endpoint API che cambiano nel tempo, e creare a mano un task separato per ciascuno significa dover modificare il Dag ogni volta che un endpoint viene aggiunto o rimosso. In questo esercizio trasformerai quella pipeline rigida in una pipeline guidata dai dati: con expand(), Airflow legge l'elenco degli endpoint a runtime e avvia un'istanza di task per ogni elemento, così la pipeline si adatta automaticamente quando il numero di endpoint cambia.

Questo esercizio fa parte del corso

Creare data pipeline con Airflow

Visualizza corso

esercizio interattivo pratico

Trasforma la teoria in pratica con uno dei nostri esercizi interattivi

Inizia esercizio