Usando o PythonOperator
Você implementou várias tarefas do Airflow usando o BashOperator, mas percebeu que algumas tarefas específicas seriam melhor implementadas em Python. Você vai implementar uma tarefa para baixar e salvar um arquivo no sistema dentro do Airflow.
A biblioteca requests já foi importada para você, e o DAG process_sales_dag já está definido.
Este exercício faz parte do curso
Introdução ao Apache Airflow em Python
Exercício interativo prático
Experimente este exercício completando este código de exemplo.
# Define the method
def ____(____, ____):
r = requests.get(URL)
with open(savepath, 'wb') as f:
f.write(r.content)
# Use the print method for logging
print(f"File pulled from {____} and saved to {____}")