定义一个电子邮件列表变量 email_list
,在变量中列出需要接收电子邮件提醒的各个ID。
在DAG定义中,设置default_args
,包括email
字段,设置为email_list
。
在使用 EmailOperator
的任务中,设置to
字段,将电子邮件列表传递给该任务。示例如下:
email_list = ['email1@example.com', 'email2@example.com']
default_args = {
'email' : email_list,
}
# 任务定义
send_email = EmailOperator(
task_id = 'send_email',
to = email_list,
subject = 'My Email Alert',
html_content = 'This is a message from Airflow!',
dag = dag
)