`airflow.providers.standard.hooks.filesystem`¶

模块内容¶

类¶

允许与文件服务器进行交互。

class airflow.providers.standard.hooks.filesystem.FSHook(fs_conn_id=default_conn_name, **kwargs)[源代码]¶

基类: airflow.hooks.base.BaseHook

允许与文件服务器进行交互。

连接应具有一个名称，并且在 extra 下指定一个路径

示例：连接 ID: fs_test 连接类型: 文件 (路径) 主机、模式、登录名、密码、端口: 空 extra: {“path”: “/tmp”}

conn_name_attr = 'fs_conn_id'[源代码]¶

default_conn_name = 'fs_default'[源代码]¶

conn_type = 'fs'[源代码]¶

hook_name = '文件 (路径)'[源代码]¶

classmethod get_connection_form_widgets()[源代码]¶

返回要添加到连接表单的连接小部件。

classmethod get_ui_field_behaviour()[源代码]¶

返回自定义字段行为。

get_conn()[源代码]¶

返回 hook 的连接。

get_path()[源代码]¶

获取文件系统位置的路径。

返回: 路径。
返回类型: str

test_connection()[源代码]¶: 测试文件连接。

此条目是否有帮助？