Hook for SSH connections.
SSHHook(ssh_conn_id: Optional[str] = None, remote_host: Optional[str] = None, username: Optional[str] = None, password: Optional[str] = None, key_file: Optional[str] = None, port: Optional[int] = None, timeout: int = 10, keepalive_interval: int = 30)¶
Hook for ssh remote execution using Paramiko. ref: https://github.com/paramiko/paramiko This hook also lets you create ssh tunnel and serve as basis for SFTP file transfer
ssh_conn_id (str) -- ssh connection id from airflow Connections from where all the required parameters can be fetched like username, password or key_file. Thought the priority is given to the param passed during init
remote_host (str) -- remote host to connect
username (str) -- username to connect to the remote_host
password (str) -- password of the username to connect to the remote_host
key_file (str) -- path to key file to use to connect to the remote_host
port (int) -- port of remote host to connect (Default is paramiko SSH_PORT)
timeout (int) -- timeout for the attempt to connect to the remote_host.
keepalive_interval (int) -- send a keepalive packet to remote host every keepalive_interval seconds
Returns custom field behaviour
Opens a ssh connection to the remote host.
- Return type
__exit__(self, exc_type, exc_val, exc_tb)¶
get_tunnel(self, remote_port: int, remote_host: str = 'localhost', local_port: Optional[int] = None)¶
Creates a tunnel between two hosts. Like ssh -L <LOCAL_PORT>:host:<REMOTE_PORT>.