python ftplib模块
函数释义
Python 中默认安装的 ftplib 模块定义了FTP 类,其中函数有限,可用来实现简单的 ftp 客户端,用于上传或下载文件,函数列举如下
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 | 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.retrbinary( "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文件 |
FTP.quit()与 FTP.close() 的区别
- FTP.quit(): 发送 QUIT 命令给服务器并关闭掉连接。这是一个比较“缓和”的关闭连接方式,但是如果服务器对 QUIT 命令返回错误时,会抛出异常。
- FTP.close():单方面的关闭掉连接,不应该用在已经关闭的连接之后,例如不应用在 FTP.quit() 之后。
例 1:下载、上传文件
#coding: utf-8 from ftplib import FTP import time import tarfile #!/usr/bin/python #-*- coding: utf-8 -*-from ftplib import FTP
def ftpconnect(host, username, password):
ftp = FTP()
#ftp.set_debuglevel(2) #打开调试级别 2,显示详细信息
ftp.connect(host, 21) #连接
ftp.login(username, password) #登录,如果匿名登录则用空串代替即可
return ftpdef downloadfile(ftp, remotepath, localpath):
bufsize = 1024 #设置缓冲块大小
fp = open(localpath,'wb') #以写模式在本地打开文件
ftp.retrbinary('RETR ' + remotepath, fp.write, bufsize) #接收服务器上文件并写入本地文件
ftp.set_debuglevel(0) #关闭调试
fp.close() #关闭文件def uploadfile(ftp, remotepath, localpath):
bufsize = 1024
fp = open(localpath, 'rb')
ftp.storbinary('STOR '+ remotepath , fp, bufsize) #上传文件
ftp.set_debuglevel(0)
fp.close()if name == "main":
ftp = ftpconnect("******", "***", "***")
downloadfile(ftp, "***", "***")
uploadfile(ftp, "***", "***")ftp.quit()</span></pre>
例 2:上传、下载文件 / 目录
#coding:utf-8 from ctypes import * import os import sys import ftplibclass myFtp:
ftp = ftplib.FTP()
bIsDir = False
path = ""
def init(self, host, port='21'):
#self.ftp.set_debuglevel(2) #打开调试级别 2,显示详细信息
#self.ftp.set_pasv(0) #0 主动模式 1 #被动模式
self.ftp.connect(host, port)</span><span style="color: rgba(0, 0, 255, 1)">def</span><span style="color: rgba(0, 0, 0, 1)"> Login(self, user, passwd): self.ftp.login( user, passwd ) </span><span style="color: rgba(0, 0, 255, 1)">print</span><span style="color: rgba(0, 0, 0, 1)"> self.ftp.welcome </span><span style="color: rgba(0, 0, 255, 1)">def</span><span style="color: rgba(0, 0, 0, 1)"> DownLoadFile(self, LocalFile, RemoteFile): file_handler </span>= open( LocalFile, <span style="color: rgba(128, 0, 0, 1)">'</span><span style="color: rgba(128, 0, 0, 1)">wb</span><span style="color: rgba(128, 0, 0, 1)">'</span><span style="color: rgba(0, 0, 0, 1)"> ) self.ftp.retrbinary( </span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">RETR %s</span><span style="color: rgba(128, 0, 0, 1)">"</span> %<span style="color: rgba(0, 0, 0, 1)">( RemoteFile ), file_handler.write ) file_handler.close() </span><span style="color: rgba(0, 0, 255, 1)">return</span><span style="color: rgba(0, 0, 0, 1)"> True </span><span style="color: rgba(0, 0, 255, 1)">def</span><span style="color: rgba(0, 0, 0, 1)"> UpLoadFile(self, LocalFile, RemoteFile): </span><span style="color: rgba(0, 0, 255, 1)">if</span> os.path.isfile( LocalFile ) ==<span style="color: rgba(0, 0, 0, 1)"> False: </span><span style="color: rgba(0, 0, 255, 1)">return</span><span style="color: rgba(0, 0, 0, 1)"> False file_handler </span>= open(LocalFile, <span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">rb</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(0, 0, 0, 1)">) self.ftp.storbinary(</span><span style="color: rgba(128, 0, 0, 1)">'</span><span style="color: rgba(128, 0, 0, 1)">STOR %s</span><span style="color: rgba(128, 0, 0, 1)">'</span>%RemoteFile, file_handler, 4096<span style="color: rgba(0, 0, 0, 1)">) file_handler.close() </span><span style="color: rgba(0, 0, 255, 1)">return</span><span style="color: rgba(0, 0, 0, 1)"> True </span><span style="color: rgba(0, 0, 255, 1)">def</span><span style="color: rgba(0, 0, 0, 1)"> UpLoadFileTree(self, LocalDir, RemoteDir): </span><span style="color: rgba(0, 0, 255, 1)">if</span> os.path.isdir(LocalDir) ==<span style="color: rgba(0, 0, 0, 1)"> False: </span><span style="color: rgba(0, 0, 255, 1)">return</span><span style="color: rgba(0, 0, 0, 1)"> False </span><span style="color: rgba(0, 0, 255, 1)">print</span> <span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">LocalDir:</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(0, 0, 0, 1)">, LocalDir LocalNames </span>=<span style="color: rgba(0, 0, 0, 1)"> os.listdir(LocalDir) </span><span style="color: rgba(0, 0, 255, 1)">print</span> <span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">list:</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(0, 0, 0, 1)">, LocalNames </span><span style="color: rgba(0, 0, 255, 1)">print</span><span style="color: rgba(0, 0, 0, 1)"> RemoteDir self.ftp.cwd( RemoteDir ) </span><span style="color: rgba(0, 0, 255, 1)">for</span> Local <span style="color: rgba(0, 0, 255, 1)">in</span><span style="color: rgba(0, 0, 0, 1)"> LocalNames: src </span>=<span style="color: rgba(0, 0, 0, 1)"> os.path.join( LocalDir, Local) </span><span style="color: rgba(0, 0, 255, 1)">if</span><span style="color: rgba(0, 0, 0, 1)"> os.path.isdir( src ): self.UpLoadFileTree( src, Local ) </span><span style="color: rgba(0, 0, 255, 1)">else</span><span style="color: rgba(0, 0, 0, 1)">: self.UpLoadFile( src, Local ) self.ftp.cwd( </span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">..</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(0, 0, 0, 1)"> ) </span><span style="color: rgba(0, 0, 255, 1)">return</span> <span style="color: rgba(0, 0, 255, 1)">def</span><span style="color: rgba(0, 0, 0, 1)"> DownLoadFileTree(self, LocalDir, RemoteDir): </span><span style="color: rgba(0, 0, 255, 1)">print</span> <span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">remoteDir:</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(0, 0, 0, 1)">, RemoteDir </span><span style="color: rgba(0, 0, 255, 1)">if</span> os.path.isdir( LocalDir ) ==<span style="color: rgba(0, 0, 0, 1)"> False: os.makedirs( LocalDir ) self.ftp.cwd( RemoteDir ) RemoteNames </span>=<span style="color: rgba(0, 0, 0, 1)"> self.ftp.nlst() </span><span style="color: rgba(0, 0, 255, 1)">print</span> <span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">RemoteNames</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(0, 0, 0, 1)">, RemoteNames </span><span style="color: rgba(0, 0, 255, 1)">print</span> self.ftp.nlst(<span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">/del1</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(0, 0, 0, 1)">) </span><span style="color: rgba(0, 0, 255, 1)">for</span> file <span style="color: rgba(0, 0, 255, 1)">in</span><span style="color: rgba(0, 0, 0, 1)"> RemoteNames: Local </span>=<span style="color: rgba(0, 0, 0, 1)"> os.path.join( LocalDir, file ) </span><span style="color: rgba(0, 0, 255, 1)">if</span><span style="color: rgba(0, 0, 0, 1)"> self.isDir( file ): self.DownLoadFileTree( Local, file ) </span><span style="color: rgba(0, 0, 255, 1)">else</span><span style="color: rgba(0, 0, 0, 1)">: self.DownLoadFile( Local, file ) self.ftp.cwd( </span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">..</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(0, 0, 0, 1)"> ) </span><span style="color: rgba(0, 0, 255, 1)">return</span> <span style="color: rgba(0, 0, 255, 1)">def</span><span style="color: rgba(0, 0, 0, 1)"> show(self, list): result </span>= list.lower().split( <span style="color: rgba(128, 0, 0, 1)">"</span> <span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(0, 0, 0, 1)"> ) </span><span style="color: rgba(0, 0, 255, 1)">if</span> self.path <span style="color: rgba(0, 0, 255, 1)">in</span> result <span style="color: rgba(0, 0, 255, 1)">and</span> <span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)"><dir></span><span style="color: rgba(128, 0, 0, 1)">"</span> <span style="color: rgba(0, 0, 255, 1)">in</span><span style="color: rgba(0, 0, 0, 1)"> result: self.bIsDir </span>=<span style="color: rgba(0, 0, 0, 1)"> True </span><span style="color: rgba(0, 0, 255, 1)">def</span><span style="color: rgba(0, 0, 0, 1)"> isDir(self, path): self.bIsDir </span>=<span style="color: rgba(0, 0, 0, 1)"> False self.path </span>=<span style="color: rgba(0, 0, 0, 1)"> path </span><span style="color: rgba(0, 128, 0, 1)">#</span><span style="color: rgba(0, 128, 0, 1)">this ues callback function ,that will change bIsDir value</span> self.ftp.retrlines( <span style="color: rgba(128, 0, 0, 1)">'</span><span style="color: rgba(128, 0, 0, 1)">LIST</span><span style="color: rgba(128, 0, 0, 1)">'</span><span style="color: rgba(0, 0, 0, 1)">, self.show ) </span><span style="color: rgba(0, 0, 255, 1)">return</span><span style="color: rgba(0, 0, 0, 1)"> self.bIsDir </span><span style="color: rgba(0, 0, 255, 1)">def</span><span style="color: rgba(0, 0, 0, 1)"> close(self): self.ftp.quit()
if name == "main":
ftp = myFtp('')
ftp.Login('','*')ftp.DownLoadFileTree(</span><span style="color: rgba(128, 0, 0, 1)">'</span><span style="color: rgba(128, 0, 0, 1)">del</span><span style="color: rgba(128, 0, 0, 1)">'</span>, <span style="color: rgba(128, 0, 0, 1)">'</span><span style="color: rgba(128, 0, 0, 1)">/del1</span><span style="color: rgba(128, 0, 0, 1)">'</span>)<span style="color: rgba(0, 128, 0, 1)">#</span><span style="color: rgba(0, 128, 0, 1)">ok</span> ftp.UpLoadFileTree(<span style="color: rgba(128, 0, 0, 1)">'</span><span style="color: rgba(128, 0, 0, 1)">del</span><span style="color: rgba(128, 0, 0, 1)">'</span>, <span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">/del1</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(0, 0, 0, 1)"> ) ftp.close() </span><span style="color: rgba(0, 0, 255, 1)">print</span> <span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">ok!</span><span style="color: rgba(128, 0, 0, 1)">"</span></pre>
注:目录内为文件,若为目录则无法传输
例 3:异常处理
#coding: utf-8 #from ftplib import FTP import ftplib import socket import osdef ftpconnect(ftp_info):
try:
ftp = ftplib.FTP(ftp_info[0])
except (socket.error, socket.gaierror):
print "ERROR: cannot reach %s" % ftp_info[0]
return Noneusername </span>= ftp_info[1<span style="color: rgba(0, 0, 0, 1)">] passwd </span>= ftp_info[2<span style="color: rgba(0, 0, 0, 1)">] </span><span style="color: rgba(0, 0, 255, 1)">try</span><span style="color: rgba(0, 0, 0, 1)">: ftp.login(username, passwd) </span><span style="color: rgba(0, 0, 255, 1)">except</span><span style="color: rgba(0, 0, 0, 1)"> ftplib.error_perm: </span><span style="color: rgba(0, 0, 255, 1)">print</span> <span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">ERROR: cannot login anonymously</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(0, 0, 0, 1)"> ftp.quit() </span><span style="color: rgba(0, 0, 255, 1)">return</span><span style="color: rgba(0, 0, 0, 1)"> None </span><span style="color: rgba(0, 0, 255, 1)">return</span><span style="color: rgba(0, 0, 0, 1)"> ftp
if name == "main":
info_list = ["10.19.3.199", "fastupdate_amap", "@utonavi&A.map"]
ftp = ftpconnect(info_list)
if not ftp:
exit(1)
bufsize = 1024
fname = "20150416113942674.tar.gz"
fp = open(os.path.join(".", fname), 'wb')
remotefile = os.path.join("/ADF++", fname)
ftp.retrbinary("RETR " + remotefile, fp.write, bufsize)</span><span style="color: rgba(0, 128, 0, 1)">#</span><span style="color: rgba(0, 128, 0, 1)">是否有目录,没有就创建;有的话看是否有权限创建</span> a =<span style="color: rgba(0, 0, 0, 1)"> ftp.dir() </span><span style="color: rgba(0, 0, 255, 1)">try</span><span style="color: rgba(0, 0, 0, 1)">: ftp.cwd(</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">jimi</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(0, 0, 0, 1)">) </span><span style="color: rgba(0, 0, 255, 1)">except</span><span style="color: rgba(0, 0, 0, 1)"> ftplib.error_perm: </span><span style="color: rgba(0, 0, 255, 1)">try</span><span style="color: rgba(0, 0, 0, 1)">: ftp.mkd(</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">jimi</span><span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(0, 0, 0, 1)">) </span><span style="color: rgba(0, 0, 255, 1)">except</span><span style="color: rgba(0, 0, 0, 1)"> ftplib.error_perm: </span><span style="color: rgba(0, 0, 255, 1)">print</span> <span style="color: rgba(128, 0, 0, 1)">"</span><span style="color: rgba(128, 0, 0, 1)">WARNING: U have no authority to make dir</span><span style="color: rgba(128, 0, 0, 1)">"</span> <span style="color: rgba(0, 0, 255, 1)">finally</span><span style="color: rgba(0, 0, 0, 1)">: ftp.quit()</span></pre>