SSH Dynamic Port Forwarding средствами Python

import time
import pexpect
from urlparse import urlparse
                        
 
 
def tun(domain, username, password, local_port):
    child = pexpect.spawn('autossh -oStrictHostKeyChecking=no -oUserKnownHostsFile=/dev/null -D '+str(local_port)+' '+str(username)+'@'+str(domain)+' -N')
    child.expect('[pP]assword:')
    child.sendline(password)
    child.expect(pexpect.EOF, timeout=None)
    cmd_show_data =  child.before
    cmd_output = cmd_show_data.split('\r\n')
    for data in cmd_output:
        print data
z = './good-clear.txt'
num = range(len(open(z, 'r').readlines()))
for line,port in zip(open(z,'rb'), num):
    ftp = urlparse(line)
    print port+3130
    print ftp.hostname, ftp.username, ftp.password
    tun(domain=ftp.hostname, username=ftp.username, password=ftp.password, local_port=port+3130)

#!/usr/bin/env python
# -*- encoding: utf-8 -*-
 
import time
import pexpect
from urlparse import urlparse
from threading import Thread                       
from Queue import Queue
 
z = 'good-clear.txt'
count=3129
queue = Queue()
 
def tun(i, q):
    global count
    line = q.get()
    ftp = urlparse(line)
    count=count+1
    local_port = count
    print '127.0.0.1:'+str(count)
    username = ftp.username
    password = ftp.password
    domain   = ftp.hostname
    child = pexpect.spawn('autossh -oStrictHostKeyChecking=no -oUserKnownHostsFile=/dev/null -D '+str(local_port)+' '+str(username)+'@'+str(domain)+' -N')
    child.expect('[pP]assword:')
    child.sendline(password)
    child.expect(pexpect.EOF, timeout=None)
    #cmd_show_data =  child.before
    #cmd_output = cmd_show_data.split('\r\n')
    #for data in cmd_output:
        #print data
    
    q.task_done()
 
for i in range(len(open(z, 'rb').readlines())):
    worker = Thread(target=tun, args=(i, queue))
    worker.setDaemon(True)
    worker.start()
 
for line in open(z, 'rb'):
    queue.put(line)
    
print "Main Thread Waiting"
queue.join()
 
print "Done"