airflow.providers.standard.sensors.filesystem

模組內容

類別

StartTriggerArgs

從觸發器啟動任務執行所需的引數。

FileSensor

等待檔案或資料夾落在檔案系統中。
class airflow.providers.standard.sensors.filesystem.StartTriggerArgs[原始碼]

從觸發器啟動任務執行所需的引數。

trigger_cls: str[原始碼]
next_method: str[原始碼]
trigger_kwargs: dict[str, Any] | None[原始碼]
next_kwargs: dict[str, Any] | None[原始碼]
timeout: datetime.timedelta | None[原始碼]
class airflow.providers.standard.sensors.filesystem.FileSensor(*, filepath, fs_conn_id='fs_default', recursive=False, deferrable=conf.getboolean('operators', 'default_deferrable', fallback=False), start_from_trigger=False, trigger_kwargs=None, **kwargs)[原始碼]

基於: airflow.sensors.base.BaseSensorOperator

等待檔案或資料夾落在檔案系統中。

如果給定的路徑是一個目錄，那麼只有當其中存在任何檔案（直接或在子目錄中）時，此感測器才會傳回 true

參數

  • fs_conn_id – 檔案（路徑）連線 ID 的參考

  • filepath – 檔案或資料夾名稱（相對於連線中設定的基礎路徑），可以是 glob。

  • recursive – 當設定為 True 時，啟用 glob filepath 參數中 ** 的遞迴目錄比對行為。預設為 False。

  • deferrable (bool) – 如果等待完成，是否延遲任務直到完成，預設為 False。

  • start_from_trigger (bool) – 直接從觸發器啟動任務，而無需進入 worker。

  • trigger_kwargs (dict[str, Any] | None) – 當 start_from_trigger 在動態任務映射中設定為 True 時，傳遞給觸發器的關鍵字引數。此引數在標準用法中未使用。

參見

有關如何使用此感測器的更多資訊，請參閱指南： FileSensor

template_fields: collections.abc.Sequence[str] = ('filepath',)[原始碼]
ui_color = '#91818a'[原始碼]
start_trigger_args[原始碼]
start_from_trigger = False[原始碼]
path()[原始碼]
poke(context)[原始碼]

當衍生此類別時覆寫。

execute(context)[原始碼]

在建立運算子時衍生。

Context 是與呈現 jinja 模板時使用的相同字典。

有關更多上下文，請參閱 get_template_context。

execute_complete(context, event=None)[原始碼]

此條目是否有幫助？