airflow.operators.datetime

模块内容

类

BranchDateTimeOperator

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

函数

target_times_as_dates(base_date, lower, upper)

通过将上限和下限时间目标与 base_date 组合，确保它们是日期时间。
class airflow.operators.datetime.BranchDateTimeOperator(*, follow_task_ids_if_true, follow_task_ids_if_false, target_lower, target_upper, use_task_logical_date=False, use_task_execution_date=False, **kwargs)[源代码]

基类： airflow.operators.branch.BaseBranchOperator

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

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

当 datetime.datetime.now() 落在 target_upper 之下和 target_lower 之上时，将返回 True 分支。

参数

  • follow_task_ids_if_true (str | 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 | 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.operators.datetime.target_times_as_dates(base_date, lower, upper)[源代码]

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

此条目是否有帮助？