Menggunakan PythonOperator
Anda telah mengimplementasikan beberapa task Airflow menggunakan BashOperator, tetapi menyadari bahwa beberapa task tertentu akan lebih baik jika diimplementasikan dengan Python. Anda akan membuat sebuah task untuk mengunduh dan menyimpan file ke sistem di dalam Airflow.
Library requests sudah diimpor untuk Anda, dan DAG process_sales_dag sudah didefinisikan.
Latihan ini adalah bagian dari kursus
Pengantar Apache Airflow dengan Python
Latihan interaktif praktis
Cobalah latihan ini dengan menyelesaikan kode contoh berikut.
# 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 {____}")