Os Dags sales_producer e sales_consumer dos exercícios anteriores foram carregados na interface do Airflow. O produtor grava os dados de vendas e atualiza o asset s3://data-lake/sales/daily.csv. O consumidor é agendado com base nesse asset.

Siga estes passos:

Na visualização de Dags, encontre sales_producer e sales_consumer e ative-os usando a chave de alternância.
Dispare o sales_producer clicando no ícone de play, selecionando Single Run e depois Trigger.
Aguarde a conclusão da execução do produtor (todas as tarefas em verde).
Verifique se o sales_consumer foi acionado automaticamente sem você clicar em nada.

Depois que a execução de sales_producer terminar, o que acontece com sales_consumer?

Fluxos de trabalho com intervenção humana

Create Your Free Account