airflow.triggers.file

模組內容

類別

FileTrigger

在找到請求的檔案或資料夾後,精確觸發一次的觸發器。

class airflow.triggers.file.FileTrigger(filepath, recursive=False, poke_interval=5.0, **kwargs)[原始碼]

基於: airflow.triggers.base.BaseTrigger

在找到請求的檔案或資料夾後,精確觸發一次的觸發器。

參數
  • filepath (str) – 檔案或資料夾名稱(相對於連線中設定的基礎路徑),可以是 glob。

  • recursive (bool) – 當設定為 True 時,啟用 glob filepath 參數中 ** 的遞迴目錄匹配行為。預設為 False

  • poke_interval (float) – 作業在每次嘗試之間應等待的時間

serialize()[原始碼]

序列化 FileTrigger 參數和類別路徑。

async run()[原始碼]

迴圈直到找到相關檔案。

這個條目有幫助嗎?