Python ftplib模块

Posted 2021-02-17 -wenli

Python ftplib模块

 

官方文档：https://docs.python.org/3/library/ftplib.html?highlight=ftplib#module-ftplib

实例：https://www.example-code.com/python/ftp.asp

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.abort ()        #中止正在进行的文件传输。使用这种方法并不总是有效，但是值得一试。
ftp.sendcmd (cmd)        #向服务器发送一个简单的命令字符串并返回响应字符串。
ftp.voidcmd(cmd)        #向服务器发送一个简单的命令字符串并处理响应。如果接收到与成功对应的响应代码(范围为200-299)，则不返回任何内容。提高error_reply否则。
ftp.retrbinary(cmd, callback, blocksize=8192, rest=None)   #以二进制传输模式检索文件。cmd应该是一个适当的RETR命令:‘RETR filename‘。对于接收到的每个数据块调用回调函数，并使用一个字节参数给出数据块。可选块大小参数指定要读取的底层套接字对象的最大块大小，该套接字对象是为执行实际传输而创建的(这也是传递给回调的数据块的最大大小)。选择一个合理的默认值。rest与transfercmd()方法中的含义相同。
ftp.retrlines (cmd,callback=)        #检索ASCII传输模式下的文件或目录列表。cmd应该是一个适当的RETR命令(请参阅retrbinary())或一个类似LIST或NLST的命令(通常只是字符串“LIST”)。LIST检索文件列表和有关这些文件的信息。NLST检索文件名列表。为每一行调用回调函数，其中包含一个字符串参数，该参数包含删除了尾随CRLF的行。默认回调函数将该行打印到sys.stdout。
ftp.set_pasv (val)        #如果val为真，则启用“被动”模式，否则禁用被动模式。默认情况下处于被动模式。
ftp.storbinary(cmd, fp, blocksize=8192, callback=None, rest=None)  #以二进制传输模式存储文件。cmd应该是一个适当的STOR命令:“STOR filename”。fp是一个文件对象(以二进制模式打开)，直到EOF使用其read()方法以块大小块大小的方式提供要存储的数据为止。块大小参数默认为8192。回调是一个可选的单参数可调用，它在发送数据块之后对每个数据块调用。rest与transfercmd()方法中的含义相同。
ftp.cmd("xxx/xxx")                #进入远程目录
file_handle=open(filename,"wb").write #以写模式在本地打开文件
ftp.retrbinaly("RETR filename.txt",file_handle,bufsize) #接收服务器上文件并写入本地文件
ftp.set_debuglevel(0)             #关闭调试模式

ftp相关命令操作
ftp.cwd(pathname)                 #设置FTP当前操作的路径
ftp.dir()                         #显示目录下所有目录信息
ftp.nlst()                        #获取目录下的文件
ftp.mkd(pathname)                 #新建远程目录
ftp.pwd()                         #返回当前所在位置
ftp.rmd(dirname)                  #删除远程目录
ftp.delete(filename)              #删除远程文件
ftp.size(文件名)        #请求服务器上名为filename的文件的大小。成功时，文件大小作为整数返回，否则不返回任何值。注意，SIZE命令不是标准化的，但是许多常见的服务器实现都支持它。
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 ()            #向服务器发送退出命令并关闭连接。这是关闭连接的“礼貌”方式，但如果服务器对QUIT命令响应错误，则可能引发异常。这意味着对close()方法的调用将使FTP实例对后续调用无效(参见下面)。
ftp.close ()          #单方面关闭连接。这不应该应用于已经关闭的连接，例如成功调用quit()之后。然后调用FTP实例
ftp.storlines (cmd, fp, callback=None)  #以ASCII传输模式存储文件。cmd应该是一个适当的STOR命令(参见storbinary())。使用readline()方法从文件对象fp(以二进制模式打开)中读取行，直到EOF，以提供要存储的数据。回调是一个可选的单参数可调用，它在发送后的每一行上调用。
ftp.transfercmd (cmd,rest=None)  #通过数据连接启动传输。如果传输活动，发送EPRT或PORT命令和cmd指定的传输命令，并接受连接。如果服务器是被动的，发送一个EPSV或PASV命令，连接到它，并启动传输命令。无论哪种方式，返回连接的套接字。如果提供了可选rest，则向服务器发送一个rest命令，并将rest作为参数传递。rest通常是请求文件中的字节偏移量，它告诉服务器在请求偏移量处重新发送文件的字节，跳过初始字节。但是请注意，RFC 959只要求rest是一个字符串，包含ASCII码33到ASCII码126之间可打印范围内的字符。因此，transfercmd()方法将rest转换为字符串，但是不检查字符串的内容。如果服务器不识别REST命令，将引发error_reply异常。如果发生这种情况，只需调用transfercmd()而不使用rest参数。
ftp.ntransfercmd (cmd,rest=None) #与transfercmd()类似，但是返回数据连接的元组和数据的期望大小。如果无法计算预期大小，则不会返回任何作为预期大小的值。cmd和rest与transfercmd()中的含义相同。
ftp.mlsd(路径= " ", facts= [])   #使用MLSD命令(RFC 3659)以标准格式列出目录。如果省略path，则假定当前目录。facts是表示所需信息类型的字符串列表(例如["type"、"size"、"perm"])。返回生成器对象，该对象为path中找到的每个文件生成一个由两个元素组成的元组。第一个元素是文件名，第二个元素是包含文件名事实的字典。此字典的内容可能受到事实参数的限制，但服务器不能保证返回所有请求的事实。

FTP.quit()与FTP.close()的区别
FTP.quit():发送QUIT命令给服务器并关闭掉连接。这是一个比较“缓和”的关闭连接方式，但是如果服务器对QUIT命令返回错误时，会抛出异常。
FTP.close()：单方面的关闭掉连接，不应该用在已经关闭的连接之后，例如不应用在FTP.quit()之后。

异常ftplib.error_reply  #当从服务器接收到意外响应时引发异常。

异常ftplib.error_temp  #当接收到表示临时错误的错误代码(范围为400-499的响应代码)时引发异常。

异常ftplib.error_perm  #当接收到表示永久错误的错误代码(范围为500-599的响应代码)时引发异常。

异常ftplib.error_proto  #当从服务器接收到不符合文件传输协议的响应规范(即以数字开头)的响应时，会引发异常

ftplib.all_errors     #FTP实例的方法可能由于FTP连接问题(与调用方所犯的编程错误相反)而引发的所有异常的集合(作为一个元组)。这个集合包括上面列出的四个异常以及OSError。

FTP_TLS对象  #FTP_TLS类继承自FTP，定义这些附加对象:

FTP_TLS.ssl_version  #要使用的SSL版本(默认为SSL . protocol_sslv23)。

FTP_TLS.auth ()    #根据ssl_version属性中指定的内容，使用TLS或SSL设置安全控制连接。

#在3.4版中更改:该方法现在支持使用ssl.SSLContext检查主机名。check_hostname和服务器名指示(参见ssl.HAS_SNI)。

FTP_TLS.ccc ()  #将控制通道还原为纯文本。这对于利用防火墙非常有用，因为防火墙知道如何在不打开固定端口的情况下使用不安全的FTP处理NAT。

FTP_TLS.prot_p ()  #建立安全的数据连接。

FTP_TLS.prot_c ()    #设置明文数据连接。

 

 

(Python) FTP中的主动和被动模式

被动属性控制上传/下载的数据连接是在主动模式还是被动模式下建立的。若要使用主动模式，请设置被动属性 Passive property= False。这是默认值。若要使用被动模式，请设置被动属性  Passive property= True。

被动模式/主动模式:

主动模式:
FTP客户机选择一个端口号并向FTP服务器发送一个“port”命令。然后FTP客户机在选择的端口侦听，FTP服务器发出连接请求来建立连接。数据连接从FTP服务器发出，并传入FTP客户机。

被动模式:
FTP客户机向FTP服务器发送一个PASV命令。FTP服务器选择一个端口号并在PASV响应中发送它。然后FTP服务器在该端口侦听来自FTP客户机的传入连接请求。数据连接传入FTP服务器，并从FTP客户机发出。

Python模块适用于Windows, Linux, Alpine Linux，
MAC OS X, Solaris, FreeBSD, OpenBSD，

import sys
import chilkat

ftp = chilkat.CkFtp2 ()

#任何字符串在前30天内解锁组件。
success = ftp.UnlockComponent(“Anything for 30-day trial”)
if (success != True):
print (ftp.lastErrorText ())
sys.exit ()

ftp.put_Hostname (“ftp.something.com”)
ftp.put_Username(“测试”)
ftp.put_Password(“测试”)

#连接并登录到FTP服务器。
succes= ftp.Connect ()
if (success != True):
print (ftp.lastErrorText ())
sys.exit ()

#使用被动模式:
ftp.put_Passive(True)

#使用主动模式:
ftp.put_Passive(False)

View Code

 

 

 

下载、上传文件

#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 ftp
    
def 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()

View Code

 

上传、下载文件/目录

#coding:utf-8
from ctypes import *
import os
import sys
import ftplib

class 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 )
            
    def Login(self, user, passwd):
        self.ftp.login( user, passwd )
        print self.ftp.welcome

    def DownLoadFile(self, LocalFile, RemoteFile):
        file_handler = open( LocalFile, ‘wb‘ )
        self.ftp.retrbinary( "RETR %s" %( RemoteFile ), file_handler.write ) 
        file_handler.close()
        return True
    
    def UpLoadFile(self, LocalFile, RemoteFile):
        if os.path.isfile( LocalFile ) == False:
            return False
        file_handler = open(LocalFile, "rb")
        self.ftp.storbinary(‘STOR %s‘%RemoteFile, file_handler, 4096)
        file_handler.close()
        return True

    def UpLoadFileTree(self, LocalDir, RemoteDir):
        if os.path.isdir(LocalDir) == False:
            return False
        print "LocalDir:", LocalDir
        LocalNames = os.listdir(LocalDir)
        print "list:", LocalNames
        print RemoteDir
        self.ftp.cwd( RemoteDir )
        for Local in LocalNames:
            src = os.path.join( LocalDir, Local)
            if os.path.isdir( src ): self.UpLoadFileTree( src, Local )
            else:
                self.UpLoadFile( src, Local )
                
        self.ftp.cwd( ".." )
        return
    
    def DownLoadFileTree(self, LocalDir, RemoteDir):
        print "remoteDir:", RemoteDir
        if os.path.isdir( LocalDir ) == False:
            os.makedirs( LocalDir )
        self.ftp.cwd( RemoteDir )
        RemoteNames = self.ftp.nlst()  
        print "RemoteNames", RemoteNames
        print self.ftp.nlst("/del1")
        for file in RemoteNames:
            Local = os.path.join( LocalDir, file )
            if self.isDir( file ):
                self.DownLoadFileTree( Local, file )                
            else:
                self.DownLoadFile( Local, file )
        self.ftp.cwd( ".." )
        return
    
    def show(self, list):
        result = list.lower().split( " " )
        if self.path in result and "<dir>" in result:
            self.bIsDir = True
     
    def isDir(self, path):
        self.bIsDir = False
        self.path = path
        #this ues callback function ,that will change bIsDir value
        self.ftp.retrlines( ‘LIST‘, self.show )
        return self.bIsDir
    
    def close(self):
        self.ftp.quit()

if __name__ == "__main__":
    ftp = myFtp(‘*****‘)
    ftp.Login(‘***‘,‘***‘)

    ftp.DownLoadFileTree(‘del‘, ‘/del1‘)#ok
    ftp.UpLoadFileTree(‘del‘, "/del1" )
    ftp.close()
    print "ok!"

View Code

注：目录内为文件，若为目录则无法传输

 

异常处理

#coding: utf-8
#from ftplib import FTP
import ftplib
import socket
import os

def ftpconnect(ftp_info):
    try:
        ftp = ftplib.FTP(ftp_info[0])
    except (socket.error, socket.gaierror):
        print "ERROR: cannot reach %s" % ftp_info[0]
        return None

    username = ftp_info[1]
    passwd = ftp_info[2]
    try:
        ftp.login(username, passwd)
    except ftplib.error_perm:
        print "ERROR: cannot login anonymously"
        ftp.quit()
        return None
    return 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)

    #是否有目录，没有就创建；有的话看是否有权限创建
    a = ftp.dir()
    try:
        ftp.cwd("jimi")
    except ftplib.error_perm:
        try:
            ftp.mkd("jimi")
        except ftplib.error_perm:
            print "WARNING: U have no authority to make dir"
    finally:
        ftp.quit()

View Code