airflow.contrib.hooks.fs_hook

Module Contents

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

Bases: airflow.hooks.base_hook.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]

Was this entry helpful?