Bir rapor oluştur ve e-postayla gönder
Airflow, neredeyse her tarz iş akışını otomatikleştirme olanağı sağlar. Görevler tamamlandığında, arayüzü veya günlük dosyalarını sürekli izlemeden Airflow'dan bir rapor almak istiyorsun. Bu mesajı sağlamak için Airflow içindeki e-posta işlevini kullanmaya karar verdin.
Tüm tipik Airflow bileşenleri senin için içe aktarıldı ve report_dag olarak tanımlanmış bir DAG zaten mevcut.
Bu egzersiz
Python ile Apache Airflow'a Giriş
kursunun bir parçasıdırEgzersiz talimatları
email_reportgörevi için doğru operatörü tanımla.- Operatör için eksik ayrıntıları doldur.
monthly_report.pdfadlı dosyayı kullan. email_reportgörevinigenerate_reportgörevinden sonra gerçekleşecek şekilde ayarla.
Uygulamalı interaktif egzersiz
Bu örnek kodu tamamlayarak bu egzersizi bitirin.
# Define the email task
email_report = ____(
task_id='email_report',
to='[email protected]',
subject='Airflow Monthly Report',
html_content="""Attached is your monthly workflow report - please refer to it for more detail""",
files=[____],
____=report_dag
)
# Set the email task to run after the report is generated
email_report ____ generate_report