email_on_failure和on failure回调的差异

  • 本文关键字:failure on email 回调 airflow
  • 更新时间 :
  • 英文 :


我对气流很陌生,做了一些研究,但没有发现任何具体的区别,几乎发现

  • email_on_failure设置为true ie:email_on_failure :True
  • on_failure_callback=some_methods-基本相同。-谁能说说这两者的功能差异?

email_on_failure是布尔DAG参数,用于设置当任务时是否发送电子邮件。失败了。

示例:当任务失败时,气流将触发给airflow@example.com发送电子邮件。

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

on_failure_callback是一个函数,如果DagRun失败了。

示例:当DagRun失败时,气流将运行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

相关内容

  • 没有找到相关文章

最新更新