Python SSH 开发
使用PARAMIKO进行SSH的开发http://www.cnblogs.com/gannan/archive/2012/02/06/2339883.html
PARAMIKO使用Python2.6
1. Install Pycrypto : http://www.voidspace.org.uk/python/modules.shtml#pycrypto
2. Install https://github.com/nischu7/paramiko
Download, unzip,
C:\python\python.exe setup.py build
C:\python\python.exe setup.py install
然后就可以进行开发了。
import paramiko
import os
import datetime
import base64
import sys
import traceback
hosts=[{'hostname':'10.249.75.37','username':'username','password':'password'}]
port=22
local_dir='C:/Jojo/Work/Python/SSHConnect/grid/'
remote_dir='/Users/maui/grid'
command='deploy'
def uploadFileToMachine(client,t,local_dir,remote_dir):
try:
print('connected,create folder--'+remote_dir)
stdin,stdout,stderr = client.exec_command('mkdir '+remote_dir)
for line in stdout:
print('...'+line.strip('\n'))
if(t==None ):
t = client.get_transport()
sftp=paramiko.SFTPClient.from_transport(t)
files=os.listdir(local_dir)
print(local_dir);
dir = local_dir
for f in files:
path=dir+f
print(path)
if(os.path.isfile(path)):
print ('')
print('##################################################################')
print('Beginning to upload file %s ' % datetime.datetime.now())
print('Uploading file:',os.path.join(local_dir,f),' to ',remote_dir+"/"+f)
# sftp.get(os.path.join(dir_path,f),os.path.join(local_path,f))
#sftp.put(os.path.join(local_dir,f),os.path.join(remote_dir,f))
sftp.put(os.path.join(local_dir,f),remote_dir+"/"+f)
print('Upload file success %s ' % datetime.datetime.now() )
print ('' )
t.close()
except Exception, e:
print '*** Caught exception: ' + str(e.__class__) + ': ' + str(e)
traceback.print_exc()
try:
t.close()
except:
pass
def connectHost(host):
hostname = host['hostname']
username = host['username']
password = host['password']
print('connecting ...'+hostname)
client = paramiko.SSHClient()
client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
client.connect(hostname, username=username, password=password)
return client
if command=="deploy":
paramiko.util.log_to_file('deploy.log')
for host in hosts:
try:
client = connectHost(host)
uploadFileToMachine(client,None ,local_dir,remote_dir)
client.close()
except Exception, e:
print '*** Caught exception: ' + str(e.__class__) + ': ' + str(e)
traceback.print_exc()
try:
client.close()
except:
pass
页:
[1]