Uso di PythonOperator
Hai già implementato diverse attività di Airflow usando BashOperator, ma ti rendi conto che un paio di task specifici sarebbero meglio in Python. Implementerai un task che scarica e salva un file sul sistema all'interno di Airflow.
La libreria requests è già importata per te e il DAG process_sales_dag è già definito.
Questo esercizio fa parte del corso
Introduzione ad Apache Airflow in Python
Esercizio pratico interattivo
Prova a risolvere questo esercizio completando il codice di esempio.
# 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 {____}")