Apache 气流仅向列表中的第一人发送 sla 未命中电子邮件

问题描述

我使用 Apache Airflow，我希望它发送有关 sla 未命中的电子邮件通知.我将电子邮件地址存储为气流变量，并且我有一个 dag，其中一个任务使用 EmailOperator 发送电子邮件.

I use Apache Airflow and I would like it to send email notifications on sla miss. I store email adresses as airflow variable, and I have a dag which one of its tasks sends Email using EmailOperator.

问题来了，因为当我的发送邮件任务运行到所有收件人时，它会发送电子邮件，它只会将 sla 未命中通知发送到列表中的第一个地址，在我的示例中意味着 [email protected].

And here comes the issue because however It sends emails when my send-mail task is run to all the recipients, It do sends sla miss notifaction only to the first adress on the list which in my example means [email protected].

这是一些错误，还是为什么它不起作用?

Is this some bug, or why it's not working ?

这是我的 dag 和 airlfow 变量:

Here's my dag and airlfow variable:

from airflow import DAG
from datetime import datetime, timedelta
from airflow.operators.email_operator import EmailOperator
from airflow.models import Variable
from airflow.operators.slack_operator import SlackAPIPostOperator

email = Variable.get("test_recipients")

args = {
    'owner': 'airflow'
    , 'depends_on_past': False
    , 'start_date': datetime(2018, 8, 20, 0, 0)
    , 'retries': 0
    , 'email': email
    , 'email_on_failure': True
    , 'email_on_retry': True
    , 'sla': timedelta(seconds=1)
}

dag = DAG('sla-email-test'
          , default_args=args
          , max_active_runs=1
          , schedule_interval="@daily")

....

t2 = EmailOperator(
    dag=dag,
    task_id="send-email",
    to=email,
    subject="Testing",
    html_content="<h3>Welcome to Airflow</h3>"
)

推荐答案

是的，Airflow 目前在发送 SLA 电子邮件时存在一个错误 - 代码路径没有正确地按 拆分字符串， 就像任务失败电子邮件一样.

Yes, there is currently a bug in Airflow when it comes to sending the SLA emails - that code path doesn't correctly split a string by , like task failure emails do.

现在的简短工作是使您的变量成为一个列表(即具有 ["[email protected]","[email protected]"] 的值并像访问它一样访问它:

The short work around right now is to make your variable a list (i.e. with a value of ["[email protected]","[email protected]"] and access it like:

email = Variable.get("test_recipients", deserialize_json=True)

这应该适用于两种情况(SLA 和任务电子邮件)

That should work in both cases (SLA, and task emails)

这篇关于Apache 气流仅向列表中的第一人发送 sla 未命中电子邮件的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！