Python使用sftp实现传文件夹和文件
作者:白天丶 发布时间:2021-09-30 12:27:37
标签:python,sftp传文件夹,python,sftp传文件
利用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
还有
最后上一下执行结果
来源:https://blog.csdn.net/qq_15682489/article/details/72400055
0
投稿
猜你喜欢
- 前言最近在学习python-igraph,发现其实学习一种全新的语言看官方的文档是真的很有帮助,这次我的大部分python代码的完成都是靠着
- 本文实例讲述了Django基于ORM操作数据库的方法。分享给大家供大家参考,具体如下:1、配置数据库vim settings #HelloW
- 1. 关闭mysql服务# service mysqld stop2. 检查是否有rpm包,如果没有用rpm安装过mysql,不应该有残留,
- 反射是 Go 语言的高级主题之一。我会尽可能让它变得简单易懂。本教程分为如下小节。什么是反射?为何需要检查变量,确定变量的类型?reflec
- ♩ 背景昨天在自己的 Laravel5.5 框架项目中,希望集成 Layer 的图片上传功能 但是在 ajax(POST) 提交请求时,一直
- <?php//所谓的Bit-map就是用一个bit位来标记某个元素对应的Value, 而Key即是该元素。由于采用了Bit为单位来存储
- 本文实例讲述了MySQL数据库优化之分表分库操作。分享给大家供大家参考,具体如下:分表分库垂直拆分垂直拆分就是要把表按模块划分到不同数据库表
- PHP代码 $str = preg_replace("/(<a.*?>)(.*?)(<\/a>)/&quo
- 见以下两个文件:showimage.asp Change the HTTP header
- 一个很简单的画像素画的小工具,有意思的地方在于可以把画的图案保存成数组,以方便之后快速还原出原图..<!DOCTYPE html PU
- 目录初始化程序创建Surface对象事件监听游戏循环Pygame 作为一个入门级的游戏开发库,其实并不难学,只要掌握 Python 编程的相
- 本文实例讲述了Yii2中SqlDataProvider用法。分享给大家供大家参考,具体如下:第一种方法:$totalCount = Yii:
- 最近要对一系列数据做同比比较,需要用到numpy和pandas来计算,不过使用python安装numpy和pandas因为linux环境没有
- debian6系统:首先先安装mysql吧:打开终端(root)用户登入apt-get purge mysql-server-5.5安装完成
- 最近,找到了一种新的pycharm激活方法,支持Jetbrains全家桶,比如 idea、pychram、WebStorm等等,没得zhil
- 在Oracle数据库中,DBA可以通过观测一定的表或视图来了解当前空间的使用状况,进而作出可能的调整决定。 一.表空间的自由空间 通过对表空
- 介绍反射是元数据编程的一种形式,指的是程序获得本身结构的一种能力。不同语言的反射模型实现不一样,本文中的反射,仅仅指的是Go语言中的反射模型
- 随滚动条移动的DIV层js代码,无论你的滚动条到哪里这个DIV层就跟到哪里!代码中例举了五个方向的滚动div层例子:包括左上方的div,左下
- 一.应用场景多个组件共用一个方法时可以用 mixin 抽取到一个js文件中,作为共用方法二.实现方法1.提取js共用方法文件export c
- 以下内容都是针对Pytorch 1.0-1.1介绍。很多文章都是从Dataset等对象自下往上进行介绍,但是对于初学者而言,其实这并不好理解