python ftp和sftp的例子

￡神魔★判官ぃ 2022-09-30 06:51 181阅读 0赞

python ftp 上传、下载文件

\#获取昨天日期

TODAY = datetime.date.today()

YESTERDAY = TODAY - datetime.timedelta(days=1)

CURRENTDAY=YESTERDAY.strftime('%Y%m%d')

\---------------------------------------------------------------------------------------

\#!/usr/bin/env

python

\# -\*- coding: cp936 -\*-

\#导入ftplib扩展库

import ftplib

\#创建ftp对象实例

ftp = ftplib.FTP()

\#指定IP地址和端口，连接到FTP服务，上面显示的是FTP服务器的Welcome信息

FTPIP= "218.108.\*\*\*.\*\*\*"

FTPPORT= 21

USERNAME= "ybmftp"

USERPWD= "ybm\*\*\*"

ftp.connect(FTPIP,FTPPORT)

\#通过账号和密码登录FTP服务器

ftp.login(USERNAME,USERPWD)

\#如果参数 pasv 为真，打开被动模式传输 (PASV MODE) ，

\#否则，如果参数 pasv 为假则关闭被动传输模式。

\#在被动模式打开的情况下，数据的传送由客户机启动，而不是由服务器开始。

\#这里要根据不同的服务器配置

ftp.set\_pasv(0)

\#在FTP连接中切换当前目录

CURRTPATH= "/home1/ftproot/ybmftp/testupg/payment"

ftp.cwd(CURRTPATH)

\#为准备下载到本地的文件，创建文件对象

DownLocalFilename="YBM\_20110629\_9001\_CHK"

f = open(DownLocalFilename,'wb')

\#从FTP服务器下载文件到前一步创建的文件对象，其中写对象为f.write，1024是缓冲区大小

DownRoteFilename="YBM\_20110629\_9001\_CHK"

ftp.retrbinary('RETR ' + DownRoteFilename , f.write ,1024)

\#关闭下载到本地的文件

\#提醒：虽然Python可以自动关闭文件，但实践证明，如果想下载完后立即读该文件，最好关闭后重新打开一次

f.close()

\#关闭FTP客户端连接

ftp.close()

**\#\#\#上传文件**

\#! /usr/bin/env python

from ftplib import FTP

import sys, getpass, os.path

host="218.108.\*\*\*.\*\*\*"

username="ybmftp"

password="ybm!\*\*\*"

localfile="/home/gws/xym/script/duizhang.txt"

remotepath="~/testpayment"

f=FTP(host)

f.login(username, password)

f.cwd(remotepath)

fd=open(localfile,'rb')

print os.path.basename(localfile)

\#否则，如果参数

pasv 为假则关闭被动传输模式。

\#在被动模式打开的情况下，数据的传送由客户机启动，而不是由服务器开始。

\#这里要根据不同的服务器配置

ftp.set\_pasv(0)

f.storbinary('STOR %s ' % os.path.basename(localfile),fd)

fd.close()

f.quit

Python中的ftplib模块

Python中默认安装的ftplib模块定义了FTP类，其中函数有限，可用来实现简单的ftp客户端，用于上传或下载文件

FTP的工作流程及基本操作可参考协议RFC959

ftp登陆连接

from ftplib import FTP \#加载ftp模块

ftp=FTP() \#设置变量

ftp.set\_debuglevel(2) \#打开调试级别2，显示详细信息

ftp.connect("IP","port") \#连接的ftp sever和端口

ftp.login("user","password")\#连接的用户名，密码

print ftp.getwelcome() \#打印出欢迎信息

ftp.cmd("xxx/xxx") \#更改远程目录

bufsize=1024 \#设置的缓冲区大小

filename="filename.txt" \#需要下载的文件

file\_handle=open(filename,"wb").write \#以写模式在本地打开文件

ftp.retrbinaly("RETR filename.txt",file\_handle,bufsize) \#接收服务器上文件并写入本地文件

ftp.set\_debuglevel(0) \#关闭调试模式

ftp.quit \#退出ftp

ftp相关命令操作

ftp.cwd(pathname) \#设置FTP当前操作的路径

ftp.dir() \#显示目录下文件信息

ftp.nlst() \#获取目录下的文件

ftp.mkd(pathname) \#新建远程目录

ftp.pwd() \#返回当前所在位置

ftp.rmd(dirname) \#删除远程目录

ftp.delete(filename) \#删除远程文件

ftp.rename(fromname, toname)\#将fromname修改名称为toname。

ftp.storbinaly("STOR filename.txt",file\_handel,bufsize) \#上传目标文件

ftp.retrbinary("RETR filename.txt",file\_handel,bufsize)\#下载FTP文件

from ftplib import FTP

ftp = FTP()

timeout = 30

port = 21

ftp.connect('192.168.1.188',port,timeout) \# 连接FTP服务器

ftp.login('UserName','888888') \# 登录

print ftp.getwelcome()  \# 获得欢迎信息

ftp.cwd('file/test')    \# 设置FTP路径

list = ftp.nlst()       \# 获得目录列表

for name in list:

print(name)             \# 打印文件名字

path = 'd:/data/' + name    \# 文件保存路径

f = open(path,'wb')         \# 打开要保存文件

filename = 'RETR ' + name   \# 保存FTP文件

ftp.retrbinary(filename,f.write) \# 保存FTP上的文件

ftp.delete(name)            \# 删除FTP文件

ftp.storbinary('STOR '+filename, open(path, 'rb')) \# 上传FTP文件

ftp.quit()                  \# 退出FTP服务器

import ftplib

import os

import socket

HOST = 'ftp.mozilla.org'

DIRN = 'pub/mozilla.org/webtools'

FILE = 'bugzilla-3.6.7.tar.gz'

def main():

try:

f = ftplib.FTP(HOST)

except (socket.error, socket.gaierror):

print 'ERROR:cannot reach " %s"' % HOST

return

print '\*\*\*Connected to host "%s"' % HOST

try:

f.login()

except ftplib.error\_perm:

print 'ERROR: cannot login anonymously'

f.quit()

return

print '\*\*\* Logged in as "anonymously"'

try:

f.cwd(DIRN)

except ftplib.error\_perm:

print 'ERRORL cannot CD to "%s"' % DIRN

f.quit()

return

print '\*\*\* Changed to "%s" folder' % DIRN

try:

\#传一个回调函数给retrbinary() 它在每接收一个二进制数据时都会被调用

f.retrbinary('RETR %s' % FILE, open(FILE, 'wb').write)

except ftplib.error\_perm:

print 'ERROR: cannot read file "%s"' % FILE

os.unlink(FILE)

else:

print '\*\*\* Downloaded "%s" to CWD' % FILE

f.quit()

return

if \_\_name\_\_ == '\_\_main\_\_':

main()

os.listdir(dirname)：列出dirname下的目录和文件

os.getcwd()：获得当前工作目录

os.curdir:返回当前目录（'.')

os.chdir(dirname):改变工作目录到dirname

os.path.isdir(name):判断name是不是一个目录，name不是目录就返回false

os.path.isfile(name):判断name是不是一个文件，不存在name也返回false

os.path.exists(name):判断是否存在文件或目录name

os.path.getsize(name):获得文件大小，如果name是目录返回0L

os.path.abspath(name):获得绝对路径

os.path.normpath(path):规范path字符串形式

os.path.split(name):分割文件名与目录（事实上，如果你完全使用目录，它也会将最后一个目录作为文件名而分离，同时它不会判断文件或目录是否存在）

os.path.splitext():分离文件名与扩展名

os.path.join(path,name):连接目录与文件名或目录

os.path.basename(path):返回文件名

os.path.dirname(path):返回文件路径

os.remove(dir) \#dir为要删除的文件夹或者文件路径

os.rmdir(path) \#path要删除的目录的路径。需要说明的是，使用os.rmdir删除的目录必须为空目录，否则函数出错。

os.path.getmtime(name) ＃获取文件的修改时间

os.stat(path).st\_mtime＃获取文件的修改时间

os.stat(path).st\_ctime \#获取文件修改时间

os.path.getctime(name)\#获取文件的创建时间

**python中对文件、文件夹的操作需要涉及到os模块和shutil模块。**

创建文件：

1) os.mknod("test.txt")       创建空文件

2) open("test.txt",w)           直接打开一个文件，如果文件不存在则创建文件

创建目录：

os.mkdir("file")                   创建目录

复制文件：

shutil.copyfile("oldfile","newfile")       oldfile和newfile都只能是文件

shutil.copy("oldfile","newfile")            oldfile只能是文件夹，newfile可以是文件，也可以是目标目录

复制文件夹：

shutil.copytree("olddir","newdir")        olddir和newdir都只能是目录，且newdir必须不存在

重命名文件（目录）

os.rename("oldname","newname")       文件或目录都是使用这条命令

移动文件（目录）

shutil.move("oldpos","newpos")

删除文件

os.remove("file")

删除目录

os.rmdir("dir")                   只能删除空目录

shutil.rmtree("dir")            空目录、有内容的目录都可以删

转换目录

os.chdir("path")                  换路径

判断目标

os.path.exists("goal")          判断目标是否存在

os.path.isdir("goal")             判断目标是否目录

os.path.isfile("goal")            判断目标是否文件

**Python 实现文件复制、删除**

import os

import shutil

filelist=\[\]

rootdir="/home/zoer/aaa"

filelist=os.listdir(rootdir)

for f in filelist:

filepath = os.path.join( rootdir, f )

if os.path.isfile(filepath):

os.remove(filepath)

print filepath+" removed!"

elif os.path.isdir(filepath):

shutil.rmtree(filepath,True)

print "dir "+filepath+" removed!"

用python实现了一个小型的自动发版本的工具。这个“自动发版本”有点虚， 只是简单地把debug 目录下的配置文件复制到指定目录，把Release下的生成文件复制到同一指定，过滤掉不需要的文件夹(.svn)，然后再往这个指定目录添加几个特定的 文件。

这个是我的第一个python小程序。

下面就来看其代码的实现。

首先插入必要的库：

import os

import os.path

import shutil

import time,  datetime

然后就是一大堆功能函数。第一个就是把某一目录下的所有文件复制到指定目录中：

def copyFiles(sourceDir,  targetDir):

if sourceDir.find(".svn") > 0:

return

for file in os.listdir(sourceDir):

sourceFile = os.path.join(sourceDir,  file)

targetFile = os.path.join(targetDir,  file)

if os.path.isfile(sourceFile):

if not os.path.exists(targetDir):

os.makedirs(targetDir)

if not os.path.exists(targetFile) or(os.path.exists(targetFile) and (os.path.getsize(targetFile) != os.path.getsize(sourceFile))):

open(targetFile, "wb").write(open(sourceFile, "rb").read())

if os.path.isdir(sourceFile):

First\_Directory = False

copyFiles(sourceFile, targetFile)

删除一级目录下的所有文件：

def removeFileInFirstDir(targetDir):

for file in os.listdir(targetDir):

targetFile = os.path.join(targetDir,  file)

if os.path.isfile(targetFile):

os.remove(targetFile)

def coverFiles(sourceDir,  targetDir):

for file in os.listdir(sourceDir):

sourceFile = os.path.join(sourceDir,  file)

targetFile = os.path.join(targetDir,  file)

\#cover the files

if os.path.isfile(sourceFile):

open(targetFile, "wb").write(open(sourceFile, "rb").read())

复制指定文件到目录：

def moveFileto(sourceDir,  targetDir):

shutil.copy(sourceDir,  targetDir)

往指定目录写文本文件：

def writeVersionInfo(targetDir):

open(targetDir, "wb").write("Revison:")

返回当前的日期，以便在创建指定目录的时候用：

def getCurTime():

nowTime = time.localtime()

year = str(nowTime.tm\_year)

month = str(nowTime.tm\_mon)

if len(month) < 2:

month = '0' + month

day =  str(nowTime.tm\_yday)

if len(day) < 2:

day = '0' + day

return (year + '-' + month + '-' + day)

然后就是主函数的实现了：

if  \_\_name\_\_ =="\_\_main\_\_":

print "Start(S) or Quilt(Q) \\n"

flag = True

while (flag):

answer = raw\_input()

if  'Q' == answer:

flag = False

elif 'S'== answer :

formatTime = getCurTime()

targetFoldername = "Build " + formatTime + "-01"

Target\_File\_Path += targetFoldername

copyFiles(Debug\_File\_Path,   Target\_File\_Path)

removeFileInFirstDir(Target\_File\_Path)

coverFiles(Release\_File\_Path,  Target\_File\_Path)

moveFileto(Firebird\_File\_Path,  Target\_File\_Path)

moveFileto(AssistantGui\_File\_Path,  Target\_File\_Path)

writeVersionInfo(Target\_File\_Path+"\\\\ReadMe.txt")

print "all sucess"

else:

print "not the correct command"

linux下python脚本判断目录和文件是否存在

if os.path.isdir('E:test'):

pass

else:

os.mkdir('E:test')

\#\#os.mkdir() 只会创建一个目录，不可以级联创建

eg2：

if not os.path.exists('E:test'):  \#\#\#判断文件是否存在，返回布尔值

os.makedirs('E:test')

\#\#os.makedirs() 这个连同中间的目录都会创建，类似于参数mkdir -p

eg3：

try:

fp = open("file\_path")

catch exception:                 except 和catch的区别？

os.mkdir('file\_path') \#\#os.mkdir() 只会创建一个目录，不可级联创建，但要有异常处理的意识

fp = open("file\_path"

eg4：实测

\#!/<a href="http://so.21ops.com/cse/search?s=9181936462520079739&entry=1&q=usr" class="bdcs-inlinelink" target="\_blank">usr</a>/bin/env python

import os

FILE\_PATH='/home/wuxy/aaa111/222/333/444.txt'  \#\#\#444.txt 不会当做文件，而是当做目录

if os.path.exists('FILE\_PATH'):   \#\#目录存在，返回为真

print 'dir not exists'

os.makedirs(FILE\_PATH)   \#\#\#FILE\_PATH不用加引号。否则会报错

else:

print 'dir exists'

python实现ftp上传下载文件

\#!/usr/bin/env python

\# encoding: utf-8

\_\_author\_\_ = "pwy"

'''

上传：上传文件并备份到其他目录

下载：下载文件，并删除远端文件

'''

from ftplib import FTP

from time import sleep

import os,datetime,logging

from shutil import move

HOST = "192.168.1.221"

USER = "sxit"

PASSWORD = "1qaz!QAZ"

\#PORT = ""

\#Upload the file, change the directory

remotedir = "/home/test/"

localdir = "/home/sxit/object/"

bakdir = "/home/sxit/bak"

\#Download the file, change the directory

Remoredir = "/home/sxit/object1/"

Localdir = "/root/ftp-logging"

LOGFILE = datetime.datetime.now().strftime('%Y-%m-%d')+'.log'

logging.basicConfig(level=logging.INFO,

format='%(asctime)s %(filename)s %(levelname)s %(message)s',

\# datefmt='%a, %d %b %Y %H:%M:%S',

filename= LOGFILE,

filemode='a')

logging.FileHandler(LOGFILE)

class CLASS\_FTP:

def \_\_init\_\_(self,HOST,USER,PASSWORD,PORT='21'):

self.HOST = HOST

self.USER = USER

self.PASSWORD = PASSWORD

self.PORT = PORT

self.ftp=FTP()

self.flag=0     \# 0:no connected, 1: connting

def Connect(self):

try:

if self.flag == 1:

logging.info("ftp Has been connected")

else:

self.ftp.connect(self.HOST,self.PORT)

self.ftp.login(self.USER,self.PASSWORD)

\# self.ftp.set\_pasv(False)

self.ftp.set\_debuglevel(0)

self.flag=1

except Exception:

logging.info("FTP login failed")

def Up\_load(self,remotedir,localdir,bakdir):

try:

self.ftp.cwd(remotedir)

for i in os.listdir(localdir):

if i.endswith('.txt'):

file\_handler = open(i,'rb')

self.ftp.storbinary('STOR %s' % i,file\_handler)

logging.info("%s already upload ."%i)

try:

if os.path.isdir(bakdir):

move(i,bakdir)

logging.info("%s move to %s ." % (i,bakdir))

else:

print "Move the file FAILED"

logging.info("Move the %s to %s FAILED!"%(i,bakdir))

except Exception:

logging.info("ftp delete file faild !!!!!")

file\_handler.close()

\# self.ftp.quit()

except Exception:

logging.info("Up\_load failed")

def Down\_load(self,Remoredir,Localdir):

try:

self.ftp.cwd(Remoredir)

for i in self.ftp.nlst():

if i.endswith('.NET'):   \#match file

file\_handler = open(i,'wb')

self.ftp.retrbinary('RETR %s' % i,file\_handler.write)

logging.info("%s already down ."%i)

try:

self.ftp.delete(i)

logging.info("%s already deleted!"%i)

except Exception:

logging.info("ftp delete file faild !!!!!")

file\_handler.close()

\#self.ftp.quit()

except Exception:

logging.info("Down\_load failed")

if \_\_name\_\_ == '\_\_main\_\_':

ftp = CLASS\_FTP(HOST,USER,PASSWORD)

while True:

ftp.Connect()

\# ftp.Down\_load(Remoredir,Localdir)

ftp.Up\_load(remotedir,localdir,bakdir)

sleep(30)

常用函数

用手册查看，以下只是简略，因为没用用到，\[待整理\]：

pwd()                       当前工作目录

cwd(path)                   把当前工作目录设置为path

dir(\[path\[,...\[,cb\]\])       显示path 目录里的内容，可选的参数cb 是一个回调函数，会被传给retrlines()方法

nlst(\[path\[,...\])           与dir()类似，但返回一个文件名的列表，而不是显示这些文件名

retrlines(cmd \[, cb\])       给定FTP 命令（如“RETR filename”），用于下载文本文件。可选的回调函数cb 用于处理文件的每一行

retrbinary(cmd, cb\[,bs=8192\[, ra\]\])     与retrlines()类似，只是这个指令处理二进制文件。回调函数cb 用于处理每一块（块大小默认为8K）下载的数据。

storlines(cmd, f)   给定FTP 命令（如“STOR filename”），以上传文本文件。要给定一个文件对象f

storbinary(cmd, f\[,bs=8192\])    与storlines()类似，只是这个指令处理二进制文件。要给定一个文件对象f，上传块大小bs 默认为8Kbs=8192\])

rename(old, new)    把远程文件old 改名为new

delete(path)     删除位于path 的远程文件

mkd(directory)  创建远程目录

ftp

'''第一个例子'''

def get\_C(self,target\_dir=None):

C = \[\]

print "PWD:", self.ftp.pwd()

if target\_dir is not None:

self.ftp.cwd(target\_dir)\# change working directory to target\_dir

server\_file\_list = \[\]

fuck\_callback = lambda x: (server\_file\_list.append(x))

self.ftp.retrlines('LIST', fuck\_callback)

\# print server\_file\_list

server\_file\_items = self.filter\_dir\_list(server\_file\_list)

for item in server\_file\_items:

if item.is\_dir:

print 'name = ', item.name

sub\_C = self.get\_C(item.name)

\# sub\_C = \['/'+item.name+'/'+cc.name for cc in sub\_C\]

for cc in sub\_C:

cc.name = '/' + item.name + cc.name

print 'name --- ',cc.name

C.extend(sub\_C)

else:

item.name = '/' + item.name

C.append(item)

self.ftp.cwd('..')

return C

def runtest(self,next\_dir):

C = ftp.get\_C(next\_dir)

next\_dir2=next\_dir\[2:\]

C = \[cc.pack for cc in C\]

for i in C:

print i

next\_dir1=i

pos=next\_dir1.rindex('/')

next\_dir3= next\_dir1\[0:pos\]

all\_path=next\_dir2 + next\_dir3

print all\_path

next\_dir\_local = all\_path.decode('utf8').encode('gbk')

try:

print next\_dir\_local

\#os.makedirs(next\_dir\_local)

except OSError:

pass

\#os.chdir(next\_dir\_local)

localfile=next\_dir1\[pos+1:\]

print localfile

allall\_path=all\_path + "/" + localfile

self.ftp.cwd('/')

print self.ftp.pwd()

\#file\_handler = open(localfile, 'wb')

\#self.ftp.retrbinary('RETR %s' % (allall\_path), file\_handler.write)

\#file\_handler.close()

'''第一个例子获取成/home/user/test.txt这样的列表'''

第二个例子

def download\_files(self, localdir='./', remotedir='./'):

try:

self.ftp.cwd(remotedir)

except:

debug\_print('目录%s不存在，继续...' % remotedir)

return

if not os.path.isdir(localdir):

pass

\#os.makedirs(localdir)

debug\_print('切换至目录 %s' % self.ftp.pwd())

self.file\_list = \[\]

self.ftp.dir(self.get\_file\_list)

remotenames = self.file\_list

print(remotenames)

\# return

for item in remotenames:

filetype = item\[0\]

filename = item\[1\]

print "filename:",filename

local = os.path.join(localdir, filename)

if filetype == 'd':

self.download\_files(local, filename)

elif filetype == '-':

self.download\_file(local, filename)

self.ftp.cwd('..')

debug\_print('返回上层目录 %s' % self.ftp.pwd())

f.download\_files(rootdir\_local, rootdir\_remote)

'''第二个例子'''

sftp

s\_file =  path.join(path\_name,name).replace('\\\\','/')

def process\_sftp\_dir(path\_name):

"""

此函数递归处理sftp server端的目录和文件,并在client端创建所有不存在的目录,然后针对每个文件在两端的全路径执行get操作.

path\_name第一次的引用值应该是source\_path的值

"""

d\_path = path\_name.replace(source\_path,destination\_path,1)

if not  path.exists(d\_path):    \# 若目标目录不存在则创建

print('%s----Create Local Dir: %s' % (' '\*8,d\_path))

try:

makedirs(d\_path)    \# 递归创建不存在的目录

except Exception as err:

print('%s----Create %s Failed' % (' '\*8,d\_path))

print('\{\}----\{\}'.format(' '\*8,err))

exit(10)

for name in (i for i in sftp.listdir(path=path\_name) if not i.startswith('.')):

"""去掉以.开头的文件或目录"""

s\_file =  path.join(path\_name,name).replace('\\\\','/')    \# 在win环境下组合路径所用的'\\\\'换成'/'

d\_file = s\_file.replace(source\_path,destination\_path,1)    \# 目标端全路径

chk\_r\_path\_result = check\_remote\_path(s\_file)

if chk\_r\_path\_result == 'file':    \# 文件

sftp\_get(s\_file,d\_file,12)

elif chk\_r\_path\_result == 'directory':    \# 目录

process\_sftp\_dir(s\_file)    \# 递归调用本身

process\_sftp\_dir(source\_path)

区别很大

ftp:

ftp.retrlines('LIST', fuck\_callback)

完全是循环，目录的进行循环操作，而文件下载。最底层目录的文件下载完，回归上级目录。继续循环。

self.ftp.pwd()

self.ftp.dir(self.get\_file\_list)

get\_file\_list(self, line)

self.ftp.cwd('..')

self.ftp.cwd(remotedir)

self.download\_file(local, filename)

sftp：

sftp.listdir

s\_file =  path.join(path\_name,name).replace('\\\\','/')

指定源全路径下载

代码格式乱了，详细例子

ftp 第一个例子

\# !/usr/bin/env python

\# -\*-coding:utf-8-\*-

from ftplib import FTP

from time import sleep

import os, datetime,logging,time

import string,re

d1 = datetime.datetime.now()

'''months=\['Jan','Feb','March','Apr','May','Jun','Jul','Aug','Sep'\]

patternm = r'2017.\*|201611.\*|201612.\*|201610.\*'

patternxml = r'.\*2016'

patternx = r'xx.\*'''''

HOST = "192.168.1.100"

USER = "ftpuser3"

PASSWORD = "test1passwd"

class Myfile(object):

def \_\_init\_\_(self, name, size, mtime):

self.name = name  \# 文件名字

self.mtime = mtime  \# 文件创建时间

self.is\_dir = False   \# 是否为文件夹，默认为不是文件夹

\#self.size = float(size) / (1024 \* 1024)  \# 文件大小

size = float(size)

if size > 1024\*1024:

self.size = str('%.2f'%(size / (1024\*1024))) + 'MB'

elif size > 1024:

self.size = str('%.2f'%(size / 1024)) + 'KB'

else:

self.size = str(size) + 'Bytes'

@property

def is\_file(self):

return not self.is\_dir

@property

def dir\_property(self):

if self.is\_dir==True:

return 'dir'

return 'file'

def show(self):

print '\[%s\], \[%s\], \[%s\], \[%s\]' % (self.name, self.size, self.mtime, self.dir\_property)

@property

def pack(self):

"""

将myfile对象封装为一个字符串

:return:

"""

\#return '\[%s\]\[%s\]\[%s\]'%(self.name, self.size, self.mtime)

\#return '\[%s\]\[%s\]'%(self.name, self.size)

return '%s' %(self.name)

class CLASS\_FTP:

def \_\_init\_\_(self, HOST, USER, PASSWORD, PORT='21'):

self.HOST = HOST

self.USER = USER

self.PASSWORD = PASSWORD

self.PORT = PORT

self.ftp = FTP()

self.flag = 0  \# 0:no connected, 1: connting

def Connect(self):

try:

if self.flag == 1:

logging.info("ftp Has been connected")

else:

self.ftp.connect(self.HOST, self.PORT)

self.ftp.login(self.USER, self.PASSWORD)

\# self.ftp.set\_pasv(False)

self.ftp.set\_debuglevel(0)

self.flag = 1

except Exception:

logging.info("FTP login failed")

def str\_codec\_std(self,mystr):

return mystr.decode('utf8').encode('gbk')

def dirmakedirs(self,next\_dir\_local,local\_dir):

\# next\_dir\_local2= next\_dir\_local.split('/')\[1:\]

next\_dir\_local2 = next\_dir\_local\[1:\].replace('/', '\\\\')

\# next\_dir\_localw = next\_dir\_local2.decode('utf8').encode('gbk')  \# windows用这个

s\_file = os.path.join(local\_dir, next\_dir\_local2)

print "s\_file", s\_file

if not os.path.exists(s\_file):

try:

os.makedirs(s\_file)

except OSError:

pass

os.chdir(s\_file)

def filter\_dir\_list(self,mystr\_list):

res = \[\]

for mystr in mystr\_list:

\#mystr = self.str\_codec\_std(mystr)

\# print "mystr is :%s" % mystr

file\_info = string.split(mystr, maxsplit=8)

name = file\_info\[8\]

print 'name = ', name

if name == '.' or name == '..':

continue

size = file\_info\[4\]

mtime = '%s-%s-%s' % (file\_info\[5\], file\_info\[6\], file\_info\[7\])

myfile = Myfile(name=name, size=size, mtime=mtime)

dir\_info = file\_info\[0\]

if dir\_info\[0\] == 'd':

myfile.is\_dir = True

res.append(myfile)

return res

def get\_C(self,target\_dir=None,local\_dir=None):

C = \[\]

if target\_dir is not None:

self.ftp.cwd(target\_dir)\# change working directory to target\_dir

server\_file\_list = \[\]

fuck\_callback = lambda x: (server\_file\_list.append(x))

self.ftp.retrlines('LIST', fuck\_callback)

next\_dir\_local = self.ftp.pwd()

self.dirmakedirs(next\_dir\_local, local\_dir)

server\_file\_items = self.filter\_dir\_list(server\_file\_list)

for item in server\_file\_items:

if item.is\_dir:

sub\_C = self.get\_C(item.name,local\_dir)

for cc in sub\_C:

cc.name = '/' + item.name + cc.name

C.extend(sub\_C)

else:

item.name = '/' + item.name

C.append(item)

self.ftp.cwd('..')

return C

def runtest(self,local\_dir,next\_dir):

os.chdir(local\_dir)

C = ftp.get\_C(next\_dir,local\_dir)

next\_dir2=next\_dir\[2:\]

C = \[cc.pack for cc in C\]

print "C:",C

for i in C:

next\_dir1=i

pos=next\_dir1.rindex('/')

next\_dir3= next\_dir1\[0:pos\]

all\_path=next\_dir2 + next\_dir3

self.dirmakedirs(all\_path, local\_dir)

next\_dir\_localz = all\_path\[1:\].replace('/', '\\\\')

'''\# next\_dir\_local = next\_dir\_localz

\# next\_dir\_local = next\_dir\_localz.decode('utf8').encode('gbk') \#windows用这个'''

\# s\_file = os.path.join(local\_dir, next\_dir\_localz)

\# try:

\#     os.makedirs(s\_file)

\# except OSError:

\#     pass

\# os.chdir(s\_file)

localfile=next\_dir1\[pos+1:\]

print localfile

allall\_path=all\_path + "/" + localfile

file\_handler = open(localfile, 'wb')

self.ftp.retrbinary('RETR %s' % (allall\_path), file\_handler.write)

file\_handler.close()

if \_\_name\_\_ == '\_\_main\_\_':

ftp = CLASS\_FTP(HOST, USER, PASSWORD)

ftp.Connect()

ftp.runtest('D:\\\\ftp','./')

d2 = datetime.datetime.now()

print d2 - d1

'''参数乱七八糟'''

ftp 第二个例子 别人2010写好的

\# !/usr/bin/env python

\# coding:utf-8

from ftplib import FTP

import os, sys, string, datetime, time

import socket

class MYFTP:

def \_\_init\_\_(self, hostaddr, username, password, remotedir, port=21):

self.hostaddr = hostaddr

self.username = username

self.password = password

self.remotedir = remotedir

self.port = port

self.ftp = FTP()

self.file\_list = \[\]

\# self.ftp.set\_debuglevel(2)

def \_\_del\_\_(self):

self.ftp.close()

\# self.ftp.set\_debuglevel(0)

def login(self):

ftp = self.ftp

try:

timeout = 60

socket.setdefaulttimeout(timeout)

ftp.set\_pasv(True)

print '开始连接到 %s' % (self.hostaddr)

ftp.connect(self.hostaddr, self.port)

print '成功连接到 %s' % (self.hostaddr)

print '开始登录到 %s' % (self.hostaddr)

ftp.login(self.username, self.password)

print '成功登录到 %s' % (self.hostaddr)

debug\_print(ftp.getwelcome())

except Exception:

deal\_error("连接或登录失败")

try:

print "now:",self.ftp.pwd()

self.ftp.cwd(self.remotedir)

except(Exception):

deal\_error('切换目录失败')

def is\_same\_size(self, localfile, remotefile):

try:

remotefile\_size = self.ftp.size(remotefile)

except:

remotefile\_size = -1

try:

localfile\_size = os.path.getsize(localfile)

except:

localfile\_size = -1

debug\_print('lo:%d  re:%d' % (localfile\_size, remotefile\_size), )

if remotefile\_size == localfile\_size:

return 1

else:

return 0

def download\_file(self, localfile, remotefile):

if self.is\_same\_size(localfile, remotefile):

debug\_print('%s 文件大小相同，无需下载' % localfile)

return

else:

print "remotefile:",remotefile

debug\_print('>>>>>>>>>>>>下载文件 %s ... ...' % localfile)

\# return

file\_handler = open(localfile, 'wb')

self.ftp.retrbinary('RETR %s' % (remotefile), file\_handler.write)

file\_handler.close()

def download\_files(self, localdir='./', remotedir='./'):

try:

print "remotedir:",remotedir

self.ftp.cwd(remotedir)

except:

debug\_print('目录%s不存在，继续...' % remotedir)

return

if not os.path.isdir(localdir):

\# pass

os.makedirs(localdir)

debug\_print('切换至目录 %s' % self.ftp.pwd())

self.file\_list = \[\]

print(self.ftp.dir())

self.ftp.dir(self.get\_file\_list)

remotenames = self.file\_list

\# print(remotenames)

\# return

for item in remotenames:

filetype = item\[0\]

filename = item\[1\]

print "filename:",filename

local = os.path.join(localdir, filename).replace('\\\\', '/')

if filetype == 'd':

self.download\_files(local, filename)

elif filetype == '-':

self.download\_file(local, filename)

self.ftp.cwd('..')

debug\_print('返回上层目录 %s' % self.ftp.pwd())

def upload\_file(self, localfile, remotefile):

if not os.path.isfile(localfile):

return

if self.is\_same\_size(localfile, remotefile):

debug\_print('跳过\[相等\]: %s' % localfile)

return

file\_handler = open(localfile, 'rb')

self.ftp.storbinary('STOR %s' % remotefile, file\_handler)

file\_handler.close()

debug\_print('已传送: %s' % localfile)

def upload\_files(self, localdir='./', remotedir='./'):

if not os.path.isdir(localdir):

return

localnames = os.listdir(localdir)

self.ftp.cwd(remotedir)

for item in localnames:

src = os.path.join(localdir, item)

if os.path.isdir(src):

try:

self.ftp.mkd(item)

except:

debug\_print('目录已存在 %s' % item)

self.upload\_files(src, item)

else:

self.upload\_file(src, item)

self.ftp.cwd('..')

def get\_file\_list(self, line):

print "line1:", line

ret\_arr = \[\]

file\_arr = self.get\_filename(line)

print "file\_arr:",file\_arr

if file\_arr\[1\] not in \['.', '..'\]:

self.file\_list.append(file\_arr)

def get\_filename(self, line):

print "line2:",line

print type(line)

pos = line.rfind(':')

while (line\[pos\] != ' '):

pos += 1

while (line\[pos\] == ' '):

pos += 1

print pos

file\_arr = \[line\[0\], line\[pos:\]\]

return file\_arr

def debug\_print(s):

print (s)

def deal\_error(e):

timenow = time.localtime()

datenow = time.strftime('%Y-%m-%d', timenow)

logstr = '%s 发生错误: %s' % (datenow, e)

debug\_print(logstr)

file.write(logstr)

sys.exit()

if \_\_name\_\_ == '\_\_main\_\_':

file = open("log.txt", "a")

timenow = time.localtime()

datenow = time.strftime('%Y-%m-%d', timenow)

logstr = datenow

\# 配置如下变量

hostaddr = '192.168.1.100'  \# ftp地址

username = 'ftpuser3'  \# 用户名

password = 'test1passwd'  \# 密码

port = 21  \# 端口号

\#rootdir\_local = '.' + os.sep + 'bak/'  \# 本地目录

rootdir\_local = 'D:/ftp/'

rootdir\_remote = './'  \# 远程目录

f = MYFTP(hostaddr, username, password, rootdir\_remote, port)

f.login()

f.download\_files(rootdir\_local, rootdir\_remote)

timenow = time.localtime()

datenow = time.strftime('%Y-%m-%d', timenow)

logstr += " - %s 成功执行了备份\\n" % datenow

debug\_print(logstr)

file.write(logstr)

file.close()

python ftp和sftp的例子

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 ftp sftp

相关 FTP、FTPS、SFTP的概念和区别

相关 SFTP和FTP的区别

相关 python ftp和sftp的例子

相关 java sftp 和 ftp util例子

相关 SFTP & FTP Upload

相关 FTPS和SFTP的区别

相关 FTP和SFTP的区别

相关 SFTP和FTP区别及安装配置SFTP

相关 FTP、FTPS和SFTP