airflow.hooks.filesystem

Module Contents

class airflow.hooks.filesystem.FSHook(conn_id='fs_default')[source]

Bases: airflow.hooks.base.BaseHook

Allows for interaction with an file server.

Connection should have a name and a path specified under extra:

example: Conn Id: fs_test Conn Type: File (path) Host, Schema, Login, Password, Port: empty Extra: {“path”: “/tmp”}

get_conn(self)[source]
get_path(self)[source]

Get the path to the filesystem location.

Returns

the path.

Was this entry helpful?