Summer's Blog
😈酷炫主页
✨运维
🎉安装
👀踩坑
  • k8s
  • shell
  • python
  • redis
  • elasticsearch
  • mysql
  • ceph
  • spark
  • 关于
  • 思维
  • 命令
  • 友链
  • 分类
  • 标签
  • 归档
👨‍👩‍👦‍👦腾讯云社区
🗣GitHub

Summer———夏苏文

💨运维界的前行者
😈酷炫主页
✨运维
🎉安装
👀踩坑
  • k8s
  • shell
  • python
  • redis
  • elasticsearch
  • mysql
  • ceph
  • spark
  • 关于
  • 思维
  • 命令
  • 友链
  • 分类
  • 标签
  • 归档
👨‍👩‍👦‍👦腾讯云社区
🗣GitHub
  • K8s

  • shell

  • spark

  • Python

    • Python实现ssh远程执行
      • ssh执行远程命令脚本
      • ssh上传下载文件脚本
    • Python搭建http共享文件
    • Python合并多个excl表格
    • Python提取log参数生成图表
    • Python算法-冒泡排序
    • Python算法-查找
    • Python算法-汉诺塔
    • Python通过librbd操作ceph
  • Redis

  • ceph

  • Elasticsearch

  • Mysql

  • 学习
  • Python
summer
2020-05-18

Python实现ssh远程执行

paramiko是基于Python实现的SSH2远程安全连接,支持认证及密钥方式。可以实现远程命令执行、文件传输、中间SSH代理等功能,相对于Pexpect,封装的层次更高,更贴近SSH协议的功能

# ssh执行远程命令脚本

点击查看
import paramiko
import sys
def pl_ssh(ip,password,username,cmd,port="22"):
    ssh_client=paramiko.SSHClient()
    ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy)
    try:
        ssh_client.connect(hostname=ip,username=username,password=password)
    except Exception as e:
        print('服务器%s连接失败' %ip)
        print(e)
        sys.exit()
    stdin,stdout,stderr=ssh_client.exec_command(cmd)
    print('服务器%s磁盘使用率情况' %ip)
    print(stdout.read().decode("utf-8"))
    ssh_client.close()
if __name__ == '__main__':
    servers={
        "192.168.0.7":{
            "username": "root",
            "password": "hadoop",
            "cmd": "df -h",
            "port": "22"
        },
        "192.168.0.8":{
            "username": "root",
            "password": "hadoop",
            "cmd": "df -h",
            "port": "22"
        }
    }
    for ip,info in servers.items():
        pl_ssh(ip=ip,
               username=info.get("username"),
               password=info.get("password"),
               cmd=info.get("cmd"),
               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
  • 效果验证

# ssh上传下载文件脚本

点击查看
import  paramiko
transport = paramiko.Transport(('192.168.0.66', 22))
transport.connect(username='root', password='hadoop')
sftp = paramiko.SFTPClient.from_transport(transport)  #ftp+ssh

#将当前主机F:\学习\k8s\微服务、k8s文档\jb51.net.txt文件 放到 192.168.0.66的/home/jb51.net.txt
sftp.put('F:\学习\k8s\微服务、k8s文档\jb51.net.txt', '/home/jb51.net.txt')
# 下载用get
# sftp.get('/home/jb51.net.txt', 'F:\学习\k8s\微服务、k8s文档\jb51.net.txt')
transport.close()
1
2
3
4
5
6
7
8
9
10
  • 效果验证
[root@summer ~]# cd /home/
[root@summer home]# ll
total 8
-rw-r--r-- 1 root        root        4848 Dec 19 00:30 jb51.net.txt
drwx--x--x 5 summer summer  106 Dec 17 00:36 summer
[root@summer home]# pwd
/home
[root@summer home]# 
1
2
3
4
5
6
7
8
#python
上次更新: 1/14/2021, 6:11:51 PM
spark笔记
Python搭建http共享文件

← spark笔记 Python搭建http共享文件→

最近更新
01
centos8安装部署ovirt-engine
11-21
02
安装Acunetix
11-02
03
三大漏洞扫描工具报告获取
05-24
更多文章>
Theme by Vdoing | Copyright © 2019-2022 夏苏文 | MIT License

网站已在灾难中运行:

蜀ICP备2022029853号-1
  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式