Airflow 中的trigger_rule

本文主要是介绍Airflow 中的trigger_rule，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

最近正在使用airflow，用到了这个，记录下

在 Apache Airflow 中，trigger_rule 是用于控制任务何时被触发的规则。TriggerRule 是一个枚举类型，它包含了多种不同的触发规则。以下是这些规则及其用途的详细说明：

1. ALL_SUCCESS（默认就是它）
    描述: 只有当所有上游任务都成功时，当前任务才会被触发。
    用途: 用于确保当前任务只在所有前置条件都满足的情况下执行。
2. ALL_FAILED 
   描述: 只有当所有上游任务都失败时，当前任务才会被触发。
   用途: 用于在所有上游任务失败后执行某些补救操作或通知。
3. ALL_DONE
   描述: 当所有上游任务都完成时，无论它们是成功、失败还是被跳过，当前任务都会被触发。
   用途: 用于在所有上游任务失败后执行某些补救操作或通知。
4. ONE_SUCCESS
   描述: 只要有一个上游任务成功，当前任务就会被触发。
   用途: 用于只要有一个前置条件满足就执行当前任务的情况。
5. ONE_FAILED
   描述: 只要有一个上游任务失败，当前任务就会被触发。
   用途: 用于只要有一个前置条件不满足就执行某些补救操作或通知。
6. NONE_FAILED
   描述: 只有当所有上游任务都没有失败时，当前任务才会被触发（即上游任务要么成功要么被跳过）。
   用途: 用于确保当前任务在没有失败任务的情况下执行。
7. NONE_FAILED_MIN_ONE_SUCCESS
   描述: 只有当所有上游任务都没有失败且至少有一个上游任务成功时，当前任务才会被触发。
   用途: 用于确保当前任务在没有失败任务且至少有一个成功任务的情况下执行。
8. DUMMY
   描述: 当前任务会被立即触发，不考虑上游任务的状态。
   用途: 用于测试和调试目的，或用于在开发过程中快速验证 DAG 的部分流程。

具体就是在定义Operator用到，例子如下：

update_transaction_for_error_task = PythonOperator(task_id='update_transaction_for_error',provide_context=True,python_callable=update_transaction_for_error,trigger_rule=TriggerRule.ONE_SUCCESS,dag=dag,
)    

注意！！！！！

trigger_rule的优先级非常高，就算dag顺序里面定义的路径应该走它但是trigger_rule没有满足，依然不会走，顺序里面不该走它，trigger_rule满足了他就会触发，我已经遇到几次这种错误导致我焦头烂额了

 

 

 

 

这篇关于Airflow 中的trigger_rule的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---