python paramiko

 代码如下

复制代码

# yum install gcc python-crypto python-paramiko python-devel  -y 

 代码如下

复制代码

import paramiko
 ssh = paramiko.SSHClient()
 ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
 ssh.connect("某IP地址",22,"用户名", "口令")

 代码如下

复制代码

import paramiko
 t = paramiko.Transport(("主机","端口"))
 t.connect(username = "用户名", passWord = "口令")

 代码如下

复制代码

t.connect(username = "用户名", password = "口令",  hosTKEy="密钥")

 代码如下

复制代码

#!/usr/bin/python
 #-*- coding: utf-8 -*-
 import paramiko
 #paramiko.util.log_to_file('/tmp/sshout')
 def ssh2(ip,username,passwd,cmd):
     try:
         ssh = paramiko.SSHClient()
          ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
          ssh.connect(ip,22,username,passwd,timeout=5)
         stdin,stdout,stderr =  ssh.exec_command(cmd)
 #            stdin.write("Y")   #简单交互，输入 ‘Y’
         print stdout.read()
 #        for x in   stdout.readlines():
 #          print x.strip("＼n")
         print '%s＼tOK＼n'%(ip)
         ssh.close()
     except :
         print '%s＼tError＼n'%(ip)
 ssh2("192.168.0.102","root","361way","hostname;ifconfig")
 ssh2("192.168.0.107","root","123456","ifconfig")

 代码如下

复制代码

import paramiko
 #建立一个加密的管道
 scp=paramiko.Transport(('192.168.0.102',22))
 #建立连接
 scp.connect(username='root',password='361way')
 #建立一个sftp客户端对象，通过ssh  transport操作远程文件
 sftp=paramiko.SFTPClient.from_transport(scp)
 #Copy a remote file (remotepath) from the SFTP server to the local host
 sftp.get('/root/testfile','/tmp/361way')
 #Copy a local file (localpath) to the SFTP server as remotepath
 sftp.put('/root/crash-6.1.6.tar.gz','/tmp/crash-6.1.6.tar.gz')
 scp.close()

 代码如下

复制代码

#!/usr/bin/env python
 #-*- coding: utf-8 -*-
 import paramiko,datetime,os
 hostname='192.168.0.102'
 username='root'
 password='361way'
 port=22
 local_dir='/tmp/getfile'
 remote_dir='/tmp/abc'
 try:
     t=paramiko.Transport((hostname,port))
     t.connect(username=username,password=password)
     sftp=paramiko.SFTPClient.from_transport(t)
     #files=sftp.listdir(dir_path)
     files=sftp.listdir(remote_dir)
     for f in files:
         print ''
         print  '#########################################'
         print 'Beginning to download  file  from %s  %s ' % (hostname,datetime.datetime.now())
         print 'Downloading  file:',os.path.join(remote_dir,f)
          sftp.get(os.path.join(remote_dir,f),os.path.join(local_dir,f))#下载
          #sftp.put(os.path.join(local_dir,f),os.path.join(remote_dir,f))#上传
         print 'Download file success %s '  % datetime.datetime.now()
         print ''
         print  '##########################################'
     t.close()
 except Exception:
        print "connect error!" 

 代码如下

复制代码

import paramiko
 transport = paramiko.Transport(('localhost',22))
 transport.connect(username='root', password = 'password')
 sftp = paramiko.SFTPClient.from_transport(transport)
 sftp.get(remotefile,localfile)
 #如果是上传则用:
 #sftp.put(localfile, remotefile)
 transport.close()
 #用socket连接
 tcpsock =  socket.socket(socket.AF_INET,socket.SOCK_STREAM)
 tcpsock.settimeout(5)
 tcpsock.connect((ip,22),)
 ssh = paramiko.Transport(tcpsock)
 ssh.connect(username=user,password=password)
 sftpConnect=paramiko.SFTPClient.from_transport(ssh)

 代码如下

复制代码

import socket
 import sys
 # windows does not have termiOS...
 try:
     import termios
     import tty
     has_termios = True
 except ImportError:
     has_termios = False
 def interactive_shell(chan):
     if has_termios:
         posix_shell(chan)
     else:
         windows_shell(chan)
 def posix_shell(chan):
     import select
     oldtty = termios.tcgetattr(sys.stdin)
     try:
         tty.setraw(sys.stdin.fileno())
         tty.setcbreak(sys.stdin.fileno())
         chan.settimeout(0.0)
         while True:
             r, w, e =  select.select([chan, sys.stdin], [], [])
             if chan in  r:
                  try:
                      x = chan.recv(1024)
                      if len(x) == 0:
                          print '＼r＼n*** EOF＼r＼n',
                          break
                      sys.stdout.write(x)
                      sys.stdout.flush()
                  except socket.timeout:
                      pass
             if  sys.stdin in r:
                  x = sys.stdin.read(1)
                  if len(x) == 0:
                      break
                  chan.send(x)
     finally:
         termios.tcsetattr(sys.stdin,  termios.TCSADRaiN, oldtty)
 # thanks to Mike Looijmans for this code
 def windows_shell(chan):
     import threading
     sys.stdout.write("Line-buffered terminal emulation.  Press F6 or ^Z to send EOF.＼r＼n＼r＼n")
     def writeall(sock):
         while True:
             data =  sock.recv(256)
             if not  data:
                  sys.stdout.write('＼r＼n*** EOF  ***＼r＼n＼r＼n')
                  sys.stdout.flush()
                  break
              sys.stdout.write(data)
              sys.stdout.flush()
     writer = threading.Thread(target=writeall, args=(chan,))
     writer.start()
     try:
         while True:
             d =  sys.stdin.read(1)
             if not d:
                  break
              chan.send(d)
     except EOFError:
         # user hit ^Z or F6
         pass

 代码如下

复制代码

import paramiko
 import interactive
 #记录日志
 paramiko.util.log_to_file('/tmp/test')
 #建立ssh连接
 ssh=paramiko.SSHClient()
 ssh.load_system_host_keys()
 ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
 ssh.connect('192.168.0.102',port=22,username='root',password='xxxxxx',compress=True)
 #建立交互式shell连接
 channel=ssh.invoke_shell()
 #建立交互式管道
 interactive.interactive_shell(channel)
 #关闭连接
 channel.close()
 ssh.close()