Vedere in azione la pianificazione basata su asset
Sia i Dag sales_producer che sales_consumer degli esercizi precedenti sono stati caricati nella UI di Airflow. Il producer scrive i dati di vendita e aggiorna l'asset s3://data-lake/sales/daily.csv. Il consumer è pianificato su quell'asset.
Segui questi passaggi:
- Nella vista Dags, trova sia
sales_producerchesales_consumere attivali usando l'interruttore. - Attiva
sales_producercliccando l'icona play, selezionando Single Run, poi Trigger. - Attendi che l'esecuzione del producer sia completata (tutti i task in verde).
- Verifica se
sales_consumerè stato attivato automaticamente senza che tu abbia cliccato nulla.
Dopo che l'esecuzione di sales_producer è completata, cosa succede a sales_consumer?
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