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
esercizio interattivo pratico
Trasforma la teoria in pratica con uno dei nostri esercizi interattivi
Inizia esercizio