Repositório 

https://github.com/chaordic/data-airflow


criando uma dag utilizando a copia de uma existente

1- acesse o repositório data-airflow/dags/dl/dl_daily_job_v2.py /

copie o código


2- acesse  data-airflow/dags/data-shipping

crie novo arquivo (dagName.py)  cole o código copiado

           




3- Substitua o nome da dag criada e  observe grupo autoscaling


4 - Observar período de execução  e horário 


5- Encadeiamento da dag (sequencia de execução)


Deploy da Dag 

repositório  https://github.com/chaordic/data-airflow#readme

credenciais AWS  https://linxsa.awsapps.com/start#/



  • Sem rótulos