EmailOperator ve bağımlılıklar
Artık iş akışın için PythonOperator'ları başarıyla tanımladığına göre, yöneticin iş akışı tamamlandığında ayrıştırılmış JSON dosyasının bir kopyasını e-postayla almak istiyor. Önceki görevler hâlâ tanımlı ve process_sales_dag DAG'i yapılandırılmış durumda. Lütfen bu görevin eski DAG tanımlama yöntemini kullandığını ve senin için eklendiğini unutma.
Bu egzersiz
Python ile Apache Airflow'a Giriş
kursunun bir parçasıdırEgzersiz talimatları
- E-posta göndermek için sınıfı içe aktar.
- Operator'ü tanımla ve uygun argümanları ekle (
to,subject,files). - Görev sırasını ayarla; görevler ardışık çalışsın (Dosyayı çek, dosyayı ayrıştır, sonra yöneticine e-posta gönder).
Uygulamalı interaktif egzersiz
Bu örnek kodu tamamlayarak bu egzersizi bitirin.
# 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