Inizia subitoInizia gratis

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:

  1. Nella vista Dags, trova sia sales_producer che sales_consumer e attivali usando l'interruttore.
  2. Attiva sales_producer cliccando l'icona play, selezionando Single Run, poi Trigger.
  3. Attendi che l'esecuzione del producer sia completata (tutti i task in verde).
  4. 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

Visualizza corso

esercizio interattivo pratico

Trasforma la teoria in pratica con uno dei nostri esercizi interattivi

Inizia esercizio