Comece agoraComece grátis

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:

  1. Na visualização de Dags, encontre sales_producer e sales_consumer e ative-os usando a chave de alternância.
  2. Dispare o sales_producer clicando no ícone de play, selecionando Single Run e depois Trigger.
  3. Aguarde a conclusão da execução do produtor (todas as tarefas em verde).
  4. 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?

Este exercicio faz parte do curso

Criando Pipelines de Dados com Airflow

Ver curso

exercicio interativo prático

Transforme teoria em prática com um dos nossos exercicio interativos

Iniciar exercicio