Utilizar el Operador Python
Has implementado varias tareas de Airflow utilizando el BashOperator, pero te das cuenta de que un par de tareas específicas se implementarían mejor utilizando Python. Implementarás una tarea para descargar y guardar un archivo en el sistema dentro de Airflow.
La biblioteca requests se importa por ti, y la DAG process_sales_dag ya está definida.
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
Ejercicio interactivo práctico
Pruebe este ejercicio completando este 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 {____}")