Vendo o agendamento baseado em asset na prática
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_produceresales_consumere ative-os usando a chave de alternância. - Dispare o
sales_producerclicando 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_consumerfoi acionado automaticamente sem você clicar em nada.
Depois que a execução de sales_producer terminar, o que acontece com sales_consumer?
Este exercicio faz parte do curso
Criando Pipelines de Dados com Airflow
exercicio interativo prático
Transforme teoria em prática com um dos nossos exercicio interativos
Iniciar exercicio