检查 Airflow 项目中是否正确配置了 SMTP 邮件服务器设置。可以在 Airflow 的配置文件 airflow.cfg
中进行配置。
以下是 airflow.cfg
文件中 SMTP 邮件服务器相关的配置示例:
[email]
email_backend = airflow.utils.email.send_email_smtp
smtp_host =
smtp_starttls = True
smtp_ssl = False
smtp_user =
smtp_password =
smtp_port =
smtp_mail_from = <发件人>
请按照具体情况修改上述配置项。
可以使用 Python 的 smtplib
模块检查连接 SMTP 服务器的状态,以确定是否存在 SMTP 服务器设置上的问题。以下是一段 Python 代码示例:
import smtplib
smtp_server = ''
smtp_port =
smtp_user = ''
smtp_password = ''
smtp_from = '<发件人>'
smtp_to = ['<收件人1>', '<收件人2>']
msg_body = '测试邮件'
smtp = smtplib.SMTP(smtp_server, smtp_port)
smtp.starttls()
smtp.login(smtp_user, smtp_password)
smtp.sendmail(smtp_from, smtp_to, msg_body)
smtp.quit()
以上代码尝试连接 SMTP 服务器,并发送一封测试邮件。如测试成功,则说明 SMTP 服务器配置项是正确的。
SendEmailOperator
的参数设置在 Airflow 的 DAG 文件中,可以使用 SendEmailOperator
来发送邮件。请确保参数设置正确。以下是 SendEmailOperator
的一些常用参数说明:
to
: 收件人列表,一个字符串或一个包含多个字符串的列表。cc
: 抄送列表,一个字符串或一个包含多个字符串的列表。subject
: 邮件标题。html_content
: 邮件正
上一篇:AirflowSchedulingfirstofmonth
下一篇:AirflowSFTPHooktransport.pyAuthentication(password)failedusingPrivateKey