Establish SSH forwarding tunnel in background

ssh_tunnel.py

import subprocess

logger = logging.getLogger(__name__)

def ssh_tunnel(jumphost, remote_server, local_port, remote_port,
               control_socket='/tmp/ssh_socket'):
    """
    Establish SSH tunnel

    :param jumphost: jump host
    :param remote_server: remote server
    :param local_port: local port
    :param remote_port: remote port
    :param control_socket: control socket for SSH tunnel
    :return:
    """
    if os.path.exists(control_socket):
        logger.warning("Stopping existing SSH tunnel")
        subprocess.Popen([
            'ssh',
            '-S', control_socket,
            '-q',
            '-O', 'exit',
            jumphost],
            stdin=subprocess.PIPE, stdout=subprocess.PIPE)

    args = [
        '/usr/bin/ssh',
        '-T',  # Disable pseudo-terminal allocation
        '-L', '{0}:{1}:{2}'.format(local_port, remote_server, remote_port),  # Specify connection forwarding
        '-M',  # Master mode for connection sharing
        '-S', control_socket,  # Control socket for connection sharing
        jumphost
    ]
    logger.info("Establishing SSH tunnel: {}".format(' '.join(args)))
    subprocess.Popen(args, stdin=subprocess.PIPE, stdout=subprocess.PIPE)
    time.sleep(2)