我对气流很陌生,做了一些研究,但没有发现任何具体的区别,几乎发现
- 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