python - Airflow 中的成功邮件

Question

完成执行每个 dags 后，如何在 Airflow 中获得成功邮件。

这是我尝试过的。
我正在尝试在完成 dags 后收到成功邮件
任何人都可以帮助我。
我已经导入了所有需要的文件。

i = datetime.now()

default_args = {
'owner': 'owner',
'depeneds_on_past': False,
'start_date': datetime(i.year, i.month, i.day-1),
'email': ['owner@gmail.com'],
'email_on_failure': True,
'email_on_retry': True,
'email_on_success': True,
'retries': 0,
'retry_delay': timedelta(minutes=10)
}

dag = DAG('update', default_args = default_args, 
schedule_interval="0 3 * * *")


t0 = PythonOperator(
task_id='clear',
python_callable=empty_tables,
email_on_failure=True,
email_on_success=True,
email=['owner@gmail.com'],
dag=dag
)

# Add tasks now 
t1 = BashOperator(
task_id='export',
bash_command=script,
dag=dag
)


t2 = PythonOperator(
task_id='load',
python_callable=load,
email_on_failure=True,
email_on_success=True,
email=['owner@gmail.com'],
dag=dag
)



t0 >> t1 >> t2

Answer 1

您需要配置 SMTP 服务器并将其添加到 airflow.cfg文件。

查询 https://stackoverflow.com/a/51837049/5691525了解如何使用 Gmail 为 Airflow 电子邮件警报设置 SMTP 服务器。