airflow.providers.standard.triggers.file

模块内容

FileTrigger

一个在找到请求的文件或文件夹后只触发一次的触发器。

class airflow.providers.standard.triggers.file.FileTrigger(filepath, recursive=False, poke_interval=5.0, **kwargs)[源代码]

基类: airflow.triggers.base.BaseTrigger

一个在找到请求的文件或文件夹后只触发一次的触发器。

参数
  • filepath (str) – 文件或文件夹名称(相对于连接中设置的基本路径),可以是 glob 模式。

  • recursive (bool) – 当设置为 True 时,启用 glob 文件路径参数中 ** 的递归目录匹配行为。默认为 False

  • poke_interval (float) – 作业在每次尝试之间应等待的时间

serialize()[源代码]

序列化 FileTrigger 参数和类路径。

async run()[源代码]

循环直到找到相关文件。

此条目是否有帮助?