设为首页 收藏本站

运维网

查看: 412|回复: 0

[经验分享] python的paramiko模块

[复制链接]

尚未签到

发表于 2018-8-10 13:40:51 | 显示全部楼层 |阅读模式
import paramiko  
from switch import switch_ip, switch_pwd, switch_username
  
from lib.read_ini import config
  
from lib.logsys import LogSys
  
import threading
  
import time
  

  
class UpDate(object):
  

  
    def __init__(self, dev, pname):
  
        self.cf = config()
  
        self.log = LogSys()
  
        self.pname = pname
  
        self.ip = switch_ip(dev)              # 根据dev获取远程服务器ip
  
        self.username = switch_username(dev)  # 获取用户名
  
        self.password = switch_pwd(dev)       # 获取密码
  
        self.port = int(self.cf.getvalue('server_conf', 'port'))
  
        self.localpath = self.cf.getvalue('write_path', 'upfilepath') + self.pname + ".zip"
  
        self.remotepath = self.cf.getvalue('write_path', 'topath') + self.pname + ".zip"
  

  
    def __trans_file(self):                   # 文件传输
  
        try:
  
            tus = (self.ip, self.port)
  
            t = paramiko.Transport(tus)       # 创建传输对象
  
            t.connect(username=self.username, password=self.password)  # 连接远程服务器
  
            sftp = paramiko.SFTPClient.from_transport(t)  # 创建下载传输对象
  
            sftp.put(self.localpath, self.remotepath)     # 上传文件
  
            t.close()
  
            print "trans_ok"
  
            return 5
  
        except Exception, e:
  
            print "put_file:" + str(e)
  
            return 0
  

  
    def __excuteup(self):                     # 远程操作
  
        ssh = paramiko.SSHClient()
  
        comm = '/root/test.sh ' + self.pname
  
        try:
  
            ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
  
            ssh.connect(self.ip,self.port,self.username,self.password,timeout=10) # 连接远程服务器
  
            stdin, stdout, stderr = ssh.exec_command(comm)  # 执行远程服务器上的脚本
  
            out = stdout.readlines()
  
            ssh.close()
  
            return 5
  
        except Exception, e:
  
            errmsg =  "excuteup Error.__excute" + str(e)
  
            ssh.close()
  
            self.log.writelog(errmsg)         # 将错误信息保存到日志
  
            return 0
  

  
    def runup(self):                          # 执行上传和远程执行命令的操作
  
        if self.__trans_file():
  
            if self.__excuteup():
  
                print "update success."
  
                return 5
  
            else:
  
                print "trans OK. excute ERR!"
  
                return 1
  
        else:
  
            return 1

运维网声明 1、欢迎大家加入本站运维交流群:群①:263444886群②:197202523群③:485755530群④:201730672群⑤:202807635运维网交流群⑥:281548029
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、其他单位或个人使用、转载或引用本文时必须注明原文的出处
4、如本帖侵犯到任何版权问题,请立即告知本站,本站将及时予与删除并致以最深的歉意
5、运维网 - 服务您的运维操作管理专家!
6、联系人Email:admin@yunvn.com 网址:www.iyunv.com

点击关注更多内容
您需要登录后才可以回帖 登录 | 立即注册  

本版积分规则  允许回帖邮件提醒楼主

关注运维网官方微信X

关注运维网官方微信

扫描二维码关注运维网官方微信,最新一手资源尽在官方微信!快快关注我们吧...

扫描微信二维码查看详情

客服 E-mail:kefu@yunvn.com

本站由青云提供云计算服务

运维网--中国最专业的运维工程师交流社区

京ICP备14039699号-1 Copyright © 2012-2018

使用手机软件扫描微信二维码

关注我们可获取更多热点资讯

Good good study day day up !


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


独家合作伙伴: 青云cloud

快速回复 返回顶部 返回列表