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)[source]

基底類別: 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)[source]

選擇要運行的分支的抽象方法。

子類別應實作此方法，運行任何必要的邏輯來選擇分支，並傳回 task_id 或 task_ids 列表。

參數

context (airflow.utils.context.Context) – 傳遞給 execute() 的上下文字典

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

透過將較高和較低的目標時間與 base_date 結合，確保它們是日期時間。

此條目是否有幫助？