EmailOperator e dipendenze
Ora che hai definito con successo i PythonOperator per il tuo workflow, il tuo manager desidera ricevere via email una copia del file JSON analizzato al completamento del workflow. I task precedenti sono ancora definiti e il DAG process_sales_dag è configurato. Nota che questo task usa il metodo più vecchio di definizione del DAG ed è stato aggiunto per te.
Questo esercizio fa parte del corso
Introduzione ad Apache Airflow in Python
Istruzioni dell'esercizio
- Importa la classe per inviare email.
- Definisci l'Operator e aggiungi gli argomenti appropriati (
to,subject,files). - Imposta l'ordine dei task in modo che vengano eseguiti in sequenza (scarica il file, analizza il file, poi invia l'email al tuo manager).
Esercizio pratico interattivo
Prova a risolvere questo esercizio completando il codice di esempio.
# 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