邮件配置

You can configure the email that is being sent in your airflow.cfg by setting a subject_template and/or a html_content_template in the [email] section.

[email]
email_backend = airflow.utils.email.send_email_smtp
subject_template = /path/to/my_subject_template_file
html_content_template = /path/to/my_html_content_template_file

等效的环境变量如下所示:

AIRFLOW__EMAIL__EMAIL_BACKEND=airflow.utils.email.send_email_smtp
AIRFLOW__EMAIL__SUBJECT_TEMPLATE=/path/to/my_subject_template_file
AIRFLOW__EMAIL__HTML_CONTENT_TEMPLATE=/path/to/my_html_content_template_file

您可以通过在[email]部分设置from_email来配置发件人的电子邮件地址,例如:

[email]
from_email = "John Doe <johndoe@example.com>"

等效的环境变量如下所示:

AIRFLOW__EMAIL__FROM_EMAIL="John Doe <johndoe@example.com>"

要配置SMTP设置,请查看标准配置中的SMTP部分。 如果您不想将SMTP凭据存储在配置文件或环境变量中,可以创建一个名为smtp_defaultEmail类型连接,或者选择自定义连接名称并在配置中设置email_conn_id为其名称,并将SMTP用户名和密码存储在其中。其他SMTP设置(如主机、端口等)始终仅从配置中获取。该连接可以是任何类型(例如"HTTP连接")。

如果想查看当前设置的邮件后端,可以使用airflow config get-value email email_backend命令,如下例所示。

$ airflow config get-value email email_backend
airflow.utils.email.send_email_smtp

要访问任务的信息,您可以在模板文件中使用Jinja Templating

For example a html_content_template file could look like this:

Try {{try_number}} out of {{max_tries + 1}}<br>
Exception:<br>{{exception_html}}<br>
Log: <a href="{{ti.log_url}}">Link</a><br>
Host: {{ti.hostname}}<br>
Mark success: <a href="{{ti.mark_success_url}}">Link</a><br>

注意

有关配置设置的更多信息,请参阅设置配置选项

使用SendGrid发送邮件

使用默认SMTP

你可以使用默认的airflow SMTP后端通过SendGrid发送邮件

[smtp]
smtp_host=smtp.sendgrid.net
smtp_starttls=False
smtp_ssl=False
smtp_user=apikey
smtp_password=<generated-api-key>
smtp_port=587
smtp_mail_from=<your-from-email>

等效的环境变量如下所示

AIRFLOW__SMTP__SMTP_HOST=smtp.sendgrid.net
AIRFLOW__SMTP__SMTP_STARTTLS=False
AIRFLOW__SMTP__SMTP_SSL=False
AIRFLOW__SMTP__SMTP_USER=apikey
AIRFLOW__SMTP__SMTP_PASSWORD=<generated-api-key>
AIRFLOW__SMTP__SMTP_PORT=587
AIRFLOW__SMTP__SMTP_MAIL_FROM=<your-from-email>

使用SendGrid提供商

Airflow 可以配置为使用 SendGrid 发送电子邮件。

按照以下步骤启用它:

  1. 设置您的SendGrid账户,获取SMTP信息并复制用户名和API密钥。

  2. sendgrid提供程序作为Airflow安装的一部分包含在内,例如:

pip install 'apache-airflow[sendgrid]' --constraint ...
or
pip install 'apache-airflow-providers-sendgrid' --constraint ...
  1. 更新airflow.cfg文件中[email]部分的email_backend属性,例如:

    [email]
    email_backend = airflow.providers.sendgrid.utils.emailer.send_email
    email_conn_id = sendgrid_default
    from_email = "hello@eg.com"
    

    对应的环境变量如下:

    AIRFLOW__EMAIL__EMAIL_BACKEND=airflow.providers.sendgrid.utils.emailer.send_email
    AIRFLOW__EMAIL__EMAIL_CONN_ID=sendgrid_default
    SENDGRID_MAIL_FROM=hello@thelearning.dev
    
  2. 创建一个名为sendgrid_default的连接,或者选择一个自定义连接名称并在'Email'类型的email_conn_id中设置它。该连接仅使用登录名和密码。

create email connection

注意

成功、失败和重试的回调将使用相同的配置来发送电子邮件

使用AWS SES发送电子邮件

Airflow可以配置为使用AWS SES发送电子邮件。

按照以下步骤启用它:

  1. amazon子包作为Airflow安装的一部分包含进来:

pip install 'apache-airflow[amazon]'
  1. 更新 email_backend 属性在 [email] 部分的 airflow.cfg 文件中:

    [email]
    email_backend = airflow.providers.amazon.aws.utils.emailer.send_email
    email_conn_id = aws_default
    from_email = From email 
    

请注意,对于SES,您必须将from_email配置为能够通过SES发送消息的有效电子邮件。

  1. 创建一个名为aws_default的连接,或者选择一个自定义连接名称并在email_conn_id中设置它。连接类型应为Amazon Web Services

这篇内容对您有帮助吗?