email_on_failure 和失败回调之间的区别

Question

我是 Airflow 的新手，做了一些研究，但没有发现任何具体差异。，几乎发现

完成的工作

• email_on_failure 通过设置为 true 即：email_on_failure :True 和
• on_failure_callback=some_methods- 几乎一样。 -有人可以提一下这两者的功能差异 b/w 吗？

Answer 1

email_on_failure 是一个布尔 DAG 参数，用于设置在 任务 失败时是否发送电子邮件。

示例：当任务失败时，Airflow 将触发发送电子邮件至 airflow@example.com。

default_args = {
    ...
    'email': ['airflow@example.com'],
    'email_on_failure': True,
}

on_failure_callback 是将在 DagRun 失败时执行的函数。

示例：当 DagRun 失败时，Airflow 将 运行 运行 print_hello。

function print_hello():
  print('hello')

default_args = {
    ...
    'on_failure_callback': print_hello
}

有关分配给 DAG 的参数的更详细说明，请参阅：https://airflow.apache.org/docs/apache-airflow/stable/_api/airflow/models/dag/index.html