Usar el PythonOperator
Has implementado varias tareas de Airflow usando el BashOperator, pero te das cuenta de que un par de tareas concretas sería mejor implementarlas con Python. Vas a implementar una tarea para descargar y guardar un archivo en el sistema dentro de Airflow.
La biblioteca requests ya está importada para ti y el DAG process_sales_dag ya está definido.
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
Ejercicio interactivo práctico
Prueba este ejercicio y completa el código de muestra.
# 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 {____}")