Python使用sftp实现传文件夹和文件

作者:白天丶 时间:2021-09-30 12:27:37 

利用python的sftp实现文件上传,可以是文件,也可以是文件夹。

版本Python2.7.13 应该不用pip安装更多的插件,都是自带的

不多说 上代码


# -*- coding:utf-8 -*-
import sys
reload(sys)
sys.setdefaultencoding('utf-8')
import paramiko
import os

_XFER_FILE = 'FILE'
_XFER_DIR  = 'DIR'

class MainWindow(object):
   # 构造方法
   def __init__(self, arg):
       # 超类调用
       super(MainWindow, self).__init__()

# 赋值参数[字典]
       # 参数格式 arg = {'ip':'填ip','user':'用户名','password':'密码','port':22}
       self.arg = arg
       # 赋值参数[FTP]
       self.sftp = None

# 调试日志
       print self.arg

# 启动程序
   def startup(self):
       # 连接FTP
       if self.sftp != None:
           print u'您已经成功连接了'
       tmpstr = u'开始连接...用户名:'+self.arg['user']+u'  密码:'+self.arg['password']+' IP:'+self.arg['ip']+u' 端口:'+str(self.arg['port'])
       print tmpstr
       try:
           transport = paramiko.Transport((self.arg['ip'], self.arg['port']))
           transport.connect(username=self.arg['user'], password=self.arg['password'])
           self.sftp = paramiko.SFTPClient.from_transport(transport)
           print (u'连接成功 '+self.arg['ip'])
       except Exception as e:
           print u'连接失败:'+str(e)

# 关闭程序
   def shutdown(self):
       # 关闭FTP
       if self.sftp:
           self.sftp.close()
           print '### disconnect sftp server: %s!'%self.arg['ip']
           self.sftp = None

# 处理上传
   def upload(self, source, target, replace):
       ### 操作数据
       # 来源路径
       source = source.replace('\\', '/')
       # 目标路径
       target = target.replace('\\', '/')

### 验证数据
       if not os.path.exists(source):
           print u'来源资源不存在,请检查:' + source
           return

### 格式数据
       # 格式化目标路径
       self.__makePath(target)

### 处理数据
       # 文件媒体数据(文件类型, 文件名称)
       filetype, filename = self.__filetype(source)
       # 判断文件类型
       if filetype == _XFER_DIR:
           # 1.目录
           self.uploadDir(source, target, replace)
       elif filetype == _XFER_FILE:
           # 2.文件
           self.uploadFile(source, filename, replace)

# 传送目录
   def uploadDir(self, source, target, replace):
       ### 验证数据
       # 判断目录存在
       if not os.path.isdir(source):  
           print u'这个函数是用来传送本地目录的'
           return

### 处理数据
       # 遍历目录内容,上传资源
       for file in os.listdir(source):
           # 资源路径
           filepath = os.path.join(source, file)

# 判断资源文件类型
           if os.path.isfile(filepath):
               # 1.文件
               self.uploadFile(filepath, file, replace)
           elif os.path.isdir(filepath):
               # 2.目录
               try:
                   self.sftp.chdir(file)
               except:
                   self.sftp.mkdir(file)
                   self.sftp.chdir(file)
               self.uploadDir(filepath, file, replace)

### 重置数据
       # 返回上一层目录
       self.sftp.chdir('..')

# 传送文件
   def uploadFile(self, filepath, filename, replace):
       ### 验证数据
       # 验证文件类型
       if not os.path.isfile(filepath):
           print u'这个函数是用来传送单个文件的'
           return
       # 验证文件存在
       if not os.path.exists(filepath):
           print u'err:本地文件不存在,检查一下'+filepath
           return
       # 验证FTP已连接
       if self.sftp == None:
           print u'sftp 还未链接'
           return

### 处理数据
       # 判断文件存在是否覆盖
       if not replace:
           if filename in self.sftp.listdir():
               print u'[*] 这个文件已经存在了,选择跳过:' + filepath + ' -> ' + self.sftp.getcwd() + '/' + filename
               return
       # 上传文件
       try:
           self.sftp.put(filepath, filename)
           print u'[+] 上传成功:' + filepath + ' -> ' + self.sftp.getcwd() + '/' + filename
       except Exception as e:
           print u'[+] 上传失败:' + filepath + ' because ' + str(e)

# 获得文件媒体数据({文件/目录, 文件名称})
   def __filetype(self, source):
       # 判断文件类型
       if os.path.isfile(source):
           # 1.文件
           index = source.rfind('/')
           return _XFER_FILE, source[index+1:]
       elif os.path.isdir(source):  
           # 2.目录
           return _XFER_DIR, ''

# 创建目标路径
   # 说明: 目标路径不存在则依次创建路径目录
   def __makePath(self, target):
       # 切换根目录
       self.sftp.chdir('/')

# 分割目标目录为目录单元集合
       data = target.split('/')
       # 进入目标目录, 目录不存在则创建
       for item in data:
           try:
               self.sftp.chdir(item)
               print u'要上传的目录已经存在,选择性进入合并:' + item
           except:
               self.sftp.mkdir(item)
               self.sftp.chdir(item)
               print u'要上传的目录不存在,创建目录:' + item

if __name__ == '__main__':
   # """
   # 先熟悉一下sftp有哪些用法  sftp.listdir(可以传参可以为空) 返回当前目录下清单列表
   # mkdir 创建目录对应rmdir   sftp.put(本地路径,远程要存的文件名) chdir进入子目录
   # """
   arg = {'ip':'填ip','user':'填用户名','password':'填密码','port':22}

me  = MainWindow(arg)
   me.startup()
   # 要上传的本地文件夹路径
   source = r'E:\xampp\backup\mysql\cto'
   # 上传到哪里 [远程目录]
   target = r'/home/www/cto/wp-superdo/backup/db'
   replace = False

me.upload(source, target, replace)
   me.shutdown()

def main(source, target, replace=False):
   arg = {'ip':填ip,'user':填用户名,'password':填密码,'port':22}

me  = MainWindow(arg)
   me.startup()

me.upload(source, target, replace)
   me.shutdown()

因为Python2.7对中文的支持不是很好所以如果出现中文错误
修改一下 Python27\Lib\site-packages\paramiko\py3compat.py

Python使用sftp实现传文件夹和文件

还有

Python使用sftp实现传文件夹和文件

最后上一下执行结果

Python使用sftp实现传文件夹和文件

来源:https://blog.csdn.net/qq_15682489/article/details/72400055

标签:python,sftp传文件夹,python,sftp传文件
0
投稿

猜你喜欢

  • js自定义弹框插件的封装

    2024-05-28 15:38:36
  • Python实现的基数排序算法原理与用法实例分析

    2023-11-11 10:15:12
  • 如何使用Python修改matplotlib.pyplot.colorbar的位置以对齐主图

    2021-09-28 18:01:30
  • 使用Anaconda创建Pytorch虚拟环境的排坑详细教程

    2021-06-14 09:01:03
  • HeidiSQL工具导出导入MySQL数据

    2024-01-19 23:00:32
  • Python打包为exe详细教程

    2023-08-23 03:00:21
  • 提高网页加载显示速度的方法

    2007-08-10 13:17:00
  • Python 读取 .gz 文件全过程

    2021-11-02 16:01:04
  • 在Python中使用CasperJS获取JS渲染生成的HTML内容的教程

    2021-07-01 14:41:42
  • python在前端页面使用 MySQLdb 连接数据

    2024-01-21 07:30:09
  • 手把手教你导入Go语言第三方库

    2024-04-28 10:46:13
  • 利用python Selenium实现自动登陆京东签到领金币功能

    2021-11-09 12:00:33
  • Python运算符重载详解及实例代码

    2021-07-11 23:48:41
  • laravel中短信发送验证码的实现方法

    2023-11-15 08:05:16
  • python3.6 如何将list存入txt后再读出list的方法

    2022-03-03 07:30:26
  • Python异常信息的不同展现方法总结

    2021-02-20 10:14:26
  • 详细分析Python collections工具库

    2022-06-28 01:18:57
  • 从绘画语言的发展,看视觉设计风格

    2008-08-03 17:11:00
  • 通过Python实现猜灯谜游戏的示例代码

    2022-01-10 17:49:40
  • 用Python代码自动生成文献的IEEE引用格式的实现

    2021-05-26 15:24:49
  • asp之家 网络编程 m.aspxhome.com