Verwendung des PythonOperator
Du hast mehrere Airflow-Tasks mit dem BashOperator implementiert, merkst aber, dass sich ein paar spezielle Aufgaben besser in Python umsetzen lassen. Du implementierst einen Task, der innerhalb von Airflow eine Datei herunterlädt und im System speichert.
Die Bibliothek requests ist bereits importiert, und der DAG process_sales_dag ist schon definiert.
Diese Übung ist Teil des Kurses
Einführung in Apache Airflow mit Python
Interaktive Übung
Vervollständige den Beispielcode, um diese Übung erfolgreich abzuschließen.
# 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 {____}")