在Airflow中,可以通过自定义DAG的Operator来发送成功邮件。下面是一个示例代码:
from airflow.operators.email_operator import EmailOperator
from airflow.models import DAG
from datetime import datetime
default_args = {
'owner': 'airflow',
'start_date': datetime(2021, 1, 1),
'email': ['your_email@example.com'],
'email_on_success': True,
}
dag = DAG(
'send_success_email',
default_args=default_args,
schedule_interval='@once'
)
send_email = EmailOperator(
task_id='send_email',
to=['recipient@example.com'],
subject='Airflow DAG Execution Successful',
html_content='The DAG execution was successful.',
dag=dag
)
在上面的示例中,我们创建了一个名为"send_success_email"的DAG,并设置了默认参数,包括owner、start_date、email和email_on_success。然后,我们定义了一个EmailOperator任务,将在DAG执行成功时发送电子邮件。在任务中,我们指定了收件人的邮箱地址、邮件主题和正文内容。
要使用此代码示例,你需要将"your_email@example.com"替换为你的邮箱地址,并将"recipient@example.com"替换为收件人的邮箱地址。
请注意,要发送电子邮件,你需要在Airflow配置文件中配置SMTP服务器。有关更多信息,请参阅Airflow文档中的SMTP配置部分。