`airflow.providers.standard.operators.datetime`¶

模块内容¶

类¶

BranchDateTimeOperator

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

函数¶

target_times_as_dates(base_date, lower, upper)

通过将上限和下限时间目标与 base_date 组合，确保它们是日期时间。

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)[源代码]¶

基类: airflow.operators.branch.BaseBranchOperator

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

有关如何使用此操作符的更多信息，请查看指南：BranchDateTimeOperator。

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

参数

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

choose_branch(context)[源代码]¶

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

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

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

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

通过将上限和下限时间目标与 base_date 组合，确保它们是日期时间。

airflow.providers.standard.operators.datetime¶

模块内容¶

类¶

函数¶

`airflow.providers.standard.operators.datetime`¶