airflow.sensors.filesystem

模組內容

類別

FileSensor

等待檔案或資料夾落地到檔案系統中。
class airflow.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: 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)[原始碼]

此條目是否有幫助？