airflow.hooks.filesystem

Module Contents

Classes

FSHook

Allows for interaction with an file server.

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: Connection Id: fs_test Connection Type: File (path) Host, Schema, Login, Password, Port: empty Extra: {“path”: “/tmp”}

get_conn(self)[source]

Returns connection for the hook.

get_path(self) str[source]

Get the path to the filesystem location.

Returns

the path.

Was this entry helpful?