airflow.providers.standard.sensors.weekday¶

類¶

DayOfWeekSensor

等待直到到達指定的第一個星期幾。

模組內容¶

class airflow.providers.standard.sensors.weekday.DayOfWeekSensor(*, week_day, use_task_logical_date=False, **kwargs)[source]¶

基類: airflow.sensors.base.BaseSensorOperator

等待直到到達指定的第一個星期幾。

例如，如果任務的執行日期是 '2018-12-22' (星期六)，並且您傳入 'FRIDAY'，任務將等待直到下一個星期五。

示例 (單天)

weekend_check = DayOfWeekSensor(
    task_id="weekend_check", week_day="Saturday", use_task_logical_date=True, dag=dag
)

示例 (使用集合包含多天)

weekend_check = DayOfWeekSensor(
    task_id="weekend_check", week_day={"Saturday", "Sunday"}, use_task_logical_date=True, dag=dag
)

示例 (使用 WeekDay 列舉)

# import WeekDay Enum
from airflow.providers.standard.utils.weekday import WeekDay

weekend_check = DayOfWeekSensor(
    task_id="weekend_check",
    week_day={WeekDay.SATURDAY, WeekDay.SUNDAY},
    use_task_logical_date=True,
    dag=dag,
)

引數:

week_day (str | collections.abc.Iterable[str] | airflow.providers.standard.utils.weekday.WeekDay | collections.abc.Iterable[airflow.providers.standard.utils.weekday.WeekDay]) –
要檢查的星期幾（全稱）。或者，也可以使用集合提供一組天。示例值：
- "MONDAY",
- {"Saturday", "Sunday"}
- {WeekDay.TUESDAY}
- {WeekDay.SATURDAY, WeekDay.SUNDAY}
要使用 WeekDay 列舉，請從 airflow.utils.weekday 匯入它
use_task_logical_date (bool) – 如果 True，則使用任務的邏輯日期與 `week_day` 進行比較。執行日期對於回填非常有用。如果 False，則使用系統的星期幾。當您不希望在系統的星期幾上執行任何內容時很有用。

另請參閱

有關如何使用此感測器的更多資訊，請檢視指南： DayOfWeekSensor

week_day[source]¶

use_task_logical_date = False[source]¶

poke(context)[source]¶

在派生此類時覆蓋此方法。