airflow.providers.standard.operators.datetime¶

类¶

BranchDateTimeOperator

根据当前日期时间将分支指向两个任务列表之一。

函数¶

target_times_as_dates(base_date, lower, upper)

通过将上下时间目标与基准日期组合，确保它们是 datetime 对象。

模块内容¶

class airflow.providers.standard.operators.datetime.BranchDateTimeOperator(*, follow_task_ids_if_true, follow_task_ids_if_false, target_lower, target_upper, use_task_logical_date=False, **kwargs)[source]¶

基类: airflow.providers.standard.operators.branch.BaseBranchOperator

根据当前日期时间将分支指向两个任务列表之一。

有关如何使用此算子的更多信息，请参阅指南：BranchDateTimeOperator。

当 datetime.datetime.now() 介于 target_lower 和 target_upper 之间时，返回 true 分支。

参数:

follow_task_ids_if_true (str | collections.abc.Iterable[str]) – 如果 datetime.datetime.now() 介于 target_lower 和 target_upper 之间，则要跟踪的任务 ID、任务组 ID 或任务 ID 和/或任务组 ID 列表。
follow_task_ids_if_false (str | collections.abc.Iterable[str]) – 如果 datetime.datetime.now() 小于 target_lower 或大于 target_upper，则要跟踪的任务 ID、任务组 ID 或任务 ID 和/或任务组 ID 列表。
target_lower (datetime.datetime | datetime.time | None) – 目标下限。
target_upper (datetime.datetime | datetime.time | None) – 目标上限。
use_task_logical_date (bool) – 如果为 True，则使用任务的逻辑日期与目标进行比较。逻辑日期对于回填很有用。如果为 False，则使用系统日期。

target_lower[source]¶

target_upper[source]¶

follow_task_ids_if_true[source]¶

follow_task_ids_if_false[source]¶

use_task_logical_date = False[source]¶

choose_branch(context)[source]¶

选择要运行哪个分支的抽象方法。

子类应实现此方法，运行选择分支所需的任何逻辑，并返回一个 task_id 或 task_ids 列表。

参数:: context (airflow.sdk.definitions.context.Context) – 传递给 execute() 的上下文字典。

airflow.providers.standard.operators.datetime.target_times_as_dates(base_date, lower, upper)[source]¶

通过将上下时间目标与基准日期组合，确保它们是 datetime 对象。