EmailOperator dan dependensi
Sekarang setelah Anda berhasil mendefinisikan PythonOperator untuk alur kerja Anda, manajer Anda ingin menerima salinan file JSON yang telah diurai melalui email saat alur kerja selesai. Task sebelumnya masih didefinisikan dan DAG process_sales_dag sudah dikonfigurasi. Perlu dicatat bahwa task ini menggunakan metode definisi DAG yang lebih lama dan telah ditambahkan untuk Anda.
Latihan ini adalah bagian dari kursus
Pengantar Apache Airflow dengan Python
Petunjuk latihan
- Impor kelas untuk mengirim email.
- Definisikan Operator dan tambahkan argumen yang sesuai (
to,subject,files). - Atur urutan task agar berjalan berurutan (Tarik file, uraikan file, lalu kirim email ke manajer Anda).
Latihan interaktif praktis
Cobalah latihan ini dengan menyelesaikan kode contoh berikut.
# Import the Operator
from ____ import ____
# Define the task
email_manager_task = ____(
task_id='email_manager',
____='[email protected]',
____='Latest sales JSON',
html_content='Attached is the latest sales JSON file as requested.',
____='parsedfile.json',
dag=process_sales_dag
)
# Set the order of tasks
pull_file_task ____ parse_file_task ____ email_manager_task