import paramiko

# 创建SSH对象

ssh = paramiko.SSHClient()

# 允许连接不在know_hosts文件中的主机

ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())

# 连接服务器

ssh.connect(hostname='c1.salt.com', port=22, username='wupeiqi', password='')

# 执行命令

stdin, stdout, stderr = ssh.exec_command('df')

# 获取命令结果

result = stdout.read()

# 关闭连接

ssh.close()

b'anaconda-ks.cfg\ninstall.log\ninstall.log.syslog\npackage\n\xe5\x85\xac\xe5\x85\xb1\xe7\x9a\x84\n\xe6\xa8\xa1\xe6\x9d\xbf\n\xe8\xa7\x86\xe9\xa2\x91\n\xe5\x9b\xbe\xe7\x89\x87\n\xe6\x96\x87\xe6\xa1\xa3\n\xe4\xb8\x8b\xe8\xbd\xbd\n\xe9\x9f\xb3\xe4\xb9\x90\n\xe6\xa1\x8c\xe9\x9d\xa2\n'

# -*- coding: UTF-8 -*-

#blog:http://www.cnblogs.com/linux-chenyang/

import paramiko

# 创建SSH对象

ssh = paramiko.SSHClient()

# 允许连接不在know_hosts文件中的主机

ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())

# 连接服务器

ssh.connect(hostname='10.236.62.37', port=22, username='root', password='')

# 执行命令

stdin, stdout, stderr = ssh.exec_command('sudo ls')

stdin.write('')

stdin.flush()

# 获取命令结果

result = stdout.read()

print(str(result))

# 关闭连接

ssh.close()

import paramiko

transport = paramiko.Transport(('hostname', 22))

transport.connect(username='wupeiqi', password='')

ssh = paramiko.SSHClient()

ssh._transport = transport

stdin, stdout, stderr = ssh.exec_command('df')

print stdout.read()

transport.close()

import paramiko

private_key = paramiko.RSAKey.from_private_key_file('/home/auto/.ssh/id_rsa')

# 创建SSH对象

ssh = paramiko.SSHClient()

# 允许连接不在know_hosts文件中的主机

ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())

# 连接服务器

ssh.connect(hostname='c1.salt.com', port=22, username='wupeiqi', key=private_key)

# 执行命令

stdin, stdout, stderr = ssh.exec_command('df')

# 获取命令结果

result = stdout.read()

# 关闭连接

ssh.close()

import paramiko

private_key = paramiko.RSAKey.from_private_key_file('/home/auto/.ssh/id_rsa')

transport = paramiko.Transport(('hostname', 22))

transport.connect(username='wupeiqi', pkey=private_key)

ssh = paramiko.SSHClient()

ssh._transport = transport

stdin, stdout, stderr = ssh.exec_command('df')

transport.close()

#3.基于私钥字符串的形式

import paramiko

from io import StringIO

key_str = """

zhe shi yi da dui zi fu chuan

"""

#1.相当于生成一个文件先f=StringIO(key_str)

#2.然后在读f.read()

private_key = paramiko.RSAKey(file_obj=StringIO(key_str))

# 创建SSH对象

ssh = paramiko.SSHClient()

# 允许连接不在know_hosts文件中的主机

ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())

# 连接服务器

ssh.connect(hostname='c1.salt.com', port=22, username='wupeiqi', key=private_key)

# 执行命令

stdin, stdout, stderr = ssh.exec_command('df')

# 获取命令结果

result = stdout.read()

# 关闭连接

ssh.close()

# -*- coding: UTF-8 -*-

#blog:http://www.cnblogs.com/linux-chenyang/

#

#

#传统的方式就是我上传一个文件，先连接上，然后上传完在断开，执行一个命令，先连接上，在执行命令，然后断开

#案例场景，创建一个连接，执行多条命令，执行多个上传，自己想关掉连接就关掉

#通过paramiko可以封装成个模块，

import paramiko

class SshHelper(object):

    def __init__(self,host,port,username,pwd):

        self.host = host

        self.port = port

        self.username = username

        self.pwd = pwd

        self.transport = None

    def connect(self):

        transport = paramiko.Transport((self.host, self.port))

        transport.connect(username=self.username, password=self.pwd)

        self.transport = transport

    def upload(self,local,target):

        sftp = paramiko.SFTPClient.from_transport(self.transport)

        # 将location.py 上传至服务器 /tmp/test.py

        sftp.put(local, target)

        # 将remove_path 下载到本地 local_path

        #sftp.get('remove_path', 'local_path')

    def cmd(self,shell):

        ssh = paramiko.SSHClient()

        ssh._transport = self.transport

        stdin, stdout, stderr = ssh.exec_command(shell)

        print(stdout.read())

    def close(self):

        self.transport.close()

if __name__ == '__main__':

    obj = SshHelper('..........')

    obj.connect()

    #中间可以想执行多少次命令就执行多少次

    obj.close()