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 文件路径参数中 ** 的递归目录匹配行为。默认为 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)[源代码]

此条目是否有帮助？