airflow.providers.standard.triggers.file¶

类¶

`FileTrigger`	一个触发器，在找到请求的文件或文件夹后恰好触发一次。
`FileDeleteTrigger`	一个触发器，在找到请求的文件后恰好触发一次并删除该文件。

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

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

参数:

filepath (str) – 文件或文件夹名称（相对于连接中设置的基础路径），可以是 glob 模式。
recursive (bool) – 当设置为 True 时，启用 glob 文件路径参数中 ** 的递归目录匹配行为。默认为 False。
poke_interval (float) – 任务每次尝试之间应等待的时间

serialize()[source]¶

序列化 FileTrigger 参数和 classpath。

async run()[source]¶

循环直到找到相关文件。

class airflow.providers.standard.triggers.file.FileDeleteTrigger(filepath, poke_interval=5.0, **kwargs)[source]¶

一个触发器，在找到请求的文件后恰好触发一次并删除该文件。

FileTrigger 和 FileDeleteTrigger 之间的区别在于 FileDeleteTrigger 只能查找特定的文件。

参数:

serialize()[source]¶

序列化 FileDeleteTrigger 参数和 classpath。

async run()[source]¶

循环直到找到相关文件。