首先,您需要确保Airflow配置中正确配置了电子邮件服务器和用于发送电子邮件的凭据。例如:
[smtp] smtp_host = smtp.gmail.com smtp_starttls = True smtp_ssl = False smtp_user = airflow@example.com smtp_password = mypassword smtp_port = 587 smtp_mail_from = airflow@example.com
接下来,确保在您的DAG文件中正确设置并启用了电子邮件操作。例如:
from airflow.operators.email_operator import EmailOperator
def my_task(): # do something here pass
email = EmailOperator( task_id='send_email', to='recipient@example.com', subject='Airflow alert', html_content='My HTML formatted content goes here' dag=my_dag, )
my_task >> email
最后,请确保您的HTML内容符合规范。HTML标记应该正确嵌套,并确保使用正确的语法。例如:
html_content = """
Dear recipient,
This is my message.
"""email = EmailOperator( task_id='send_email', to='recipient@example.com', subject='Airflow alert', html_content=html_content, dag=my_dag, )
如果以上步骤均已完成,但仍然无法获得您预期的电子邮件格式,请查看Airflow日志并确保没有任何异常。
上一篇:Airflow用户访问管理