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_producer che sales_consumer e attivali usando l'interruttore.
Attiva sales_producer cliccando 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?

Templating, idempotenza e backfilling

Create Your Free Account