PythonOperator'ı kullanma
Birkaç Airflow görevini BashOperator ile uyguladın ama bazı özel görevlerin Python ile daha iyi olacağını fark ettin. Airflow içinde bir dosyayı indirip sisteme kaydeden bir görev uygulayacaksın.
requests kütüphanesi senin için içe aktarıldı ve process_sales_dag DAG'ı zaten tanımlı.
Bu egzersiz
Python ile Apache Airflow'a Giriş
kursunun bir parçasıdırUygulamalı interaktif egzersiz
Bu örnek kodu tamamlayarak bu egzersizi bitirin.
# 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 {____}")