airflow.hooks.filesystem

模块内容

FSHook

允许与文件服务器交互。

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

基类: airflow.hooks.base.BaseHook

允许与文件服务器交互。

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

示例:连接 ID:fs_test 连接类型:文件 (path) 主机、模式、登录名、密码、端口:空 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()[源代码]

返回钩子的连接。

get_path()[源代码]

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

返回

路径。

返回类型

str

test_connection()[源代码]

测试文件连接。

此条目是否有帮助?