Python运维之远程登录paramiko（VsCode）_vscode怎么用paramiko

Python运维之远程登录----paramiko

paramiko是一个用于做远程控制的模块，使用该模块可以对远程服务器进行命令或文件操作,paramiko是用python语言写的一个模块，遵循SSH2协议，支持以加密和认证的方式，进行远程服务器的连接。

paramiko包含两个核心组件，一个为SSHClient类，另一个为SFTPClient类。
SSHClient类是SSH服务会话的高级表示，该类封装了传输(transport)、通道(channel)及SFTPClient的校验、建立的方法，通常用于执行远程命令。
SFTPClient作为一个SFTP客户端对象，根据SSH传输协议的sftp会话，实现远程文件操作，比如文件上传、下载、权限、状态等操作。需要注意的是，put和get方法需要指定文件名，不能省略。

安装paramiko Module：

py -m pip install paramiko
1

远程连接：

# paramiko是用python语言写的一个模块，遵循SSH2协议，支持以加密和认证的方式，进行远程服务器的连接。
#!/bin/python
#coding:utf-8
import paramiko
import sys

transport = paramiko.Transport(('20.85.223.**', 22))
#公钥连接
'''
私钥链接
private_key = paramiko.RSAKey.from_private_key_file('/root/.ssh/id_rsa')
transport = paramiko.Transport(('192.168.1.**', 22))
transport.connect(username='root', pkey=private_key)
'''
try:
    transport.connect(username='****', password='*****')
except Exception as err:
    print("connection failure")
    print(err)
    sys.exit()
ssh = paramiko.SSHClient()
ssh._transport = transport
stdin, stdout, stderr = ssh.exec_command('kubectl get node')
print (stdout.read())
transport.close()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

sftp上传和下载文件：

#!/bin/python
import os,sys
import paramiko

t = paramiko.Transport(('20.85.223.**',22))
try:
    t.connect(username='*****',password='*****')
except Exception as err:
    print("connection failure")
    print(err)
    sys.exit()
sftp = paramiko.SFTPClient.from_transport(t)
#将error.jpg上传到服务器20.85.223.12的/home/junwang目录
sftp.put('C:/Users/Daisy/python/test/system_infor.py','/home/junwang/systeminfo.py')
#将sftp.txt下载到本机
#sftp.get('/home/junwang/test.py','C:/Users/Daisy/python/test/test.py')

t.close()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

check server端：

check 本地：

连接多台服务器：

#导入paramiko，（导入前需要先在环境里安装该模块）
import paramiko
import sys
#定义函数ssh,把操作内容写到函数里,函数里接收参数（写在括号里）,其中port=是设置一个默认值如果没传就用默认
def sshExeCMD(ip, username, password, port=22):
    #定义一个变量ssh_clint使用SSHClient类用来后边调用
    ssh_client=paramiko.SSHClient()
    #通过这个set_missing_host_key_policy方法用于实现登录是需要确认输入yes，否则保存
    ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    #使用try做异常捕获
    try:
    #使用cnnect类来连接服务器
        ssh_client.connect(hostname=ip, port=port, username=username, password=password)
    #如果上边命令报错吧报错信息定义到err变量，并输出。
    except Exception as err:
        print("服务器链接失败！！！"% ip)
        print(err)
        #如果报错使用sys的exit退出脚本
        sys.exit()
    #使用exec_command方法执行命令，并使用变量接收命令的返回值并用print输出
    #这里也可以把命令做成参数传进来
    stdin, stdout, stderr = ssh_client.exec_command("hostname")
    #使用decode方法可以指定编码
    print(stdout.read().decode("utf-8"))
#通过判断模块名运行上边函数
if __name__ == '__main__':
    #定义一个字典，写服务器信息
    servers = {
        #以服务器IP为键,值为服务器的用户密码端口定义的字典
        "20.85.223.12": {
            "username": "junwang",
            "password": "QAZwsx123456!",
            "port": 22,
        },
        "20.232.176.247": {
            "username": "junwang",
            "password": "QAZwsx123456!",
            "port": 22,
        },
    }
    #使用items方法遍历，使用ip 和info把字典里的键和值遍历赋值，传给函数sshExeCMD
    for ip, info in servers.items():
        # 这里的info也就是上边定义的ip对应值的字典，使用get获取这个字典里对应username键对应的值，赋值给变量username传给函数中使用
        sshExeCMD(
            ip=ip,
            username=info.get("username"),
            password=info.get("password"),
            port=info.get("port")
        )

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

远程连接到多个server上传文件：

'''
批量通过ssh协议在服务器上传文件
时间：2022-04-09
localfile:本地文件名
remotedir:服务器目录名
'''

import paramiko
#后续需要用到os模块的方法
import os

#定义函数并且接收变量
def sshPutfile(ip, port, username, password, localfile, remotedir):
    #获取源文件的文件名,把进来的localfile变量的值处理只剩文件名
    file_name = os.path.basename(localfile)

    #处理服务器目录名，如果输入的目录名没有带后边的/(不是以/结尾)则添加一个，方便后边拼接文件名
    if not remotedir.endswith("/"):
        remotedir = remotedir + "/"
    dest_file_name = remotedir + file_name

    #创建ssh连接
    ssh_conn = paramiko.Transport((ip, port))
    ssh_conn.connect(username=username, password=password)
    #创建ftp工具（变量）
    ftp_client = paramiko.SFTPClient.from_transport(ssh_conn)
    #上传文件
    ftp_client.put(localfile, dest_file_name)
    # 关闭ssh连接
    ssh_conn.close()

if __name__ == '__main__':
    #定义一个字典，写服务器的信息
    servers = {
        #以服务器IP为键,值为服务器的用户密码端口定义的字典
        "20.232.176.247": {
            "username": "******",
            "password": "******",
            "port": 22,
        },
        "20.85.221.160": {
            "username": "******",
            "password": "******",
            "port": 22,
        },
    }
    source_file = input("请输入源文件路径（绝对路径）：")
    remote_dir = input("服务器路径（绝对路径）：")
    for ip, info in servers.items():
        sshPutfile(
            ip=ip,
            port=info.get("port"),
            username=info.get("username"),
            password=info.get("password"),
            localfile=source_file,
            remotedir=remote_dir
        )

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58

结果: