zoukankan      html  css  js  c++  java
  • Python ftplib模块

    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
  • 相关阅读:
    Sublime Text3快捷键大全
    IntelliJ IDEA常用快捷键(Mac)
    shell脚本执行错误 $' ':command not found
    Shell脚本中"command not found"报错处理
    Shell 数值、字符串比较
    Java线程池的构造以及使用
    Host 'xxx' is not allowed to connect to this MySQL server
    Linux下Mysql安装(tar安装)
    Linux下Mysql安装(RPM安装)
    Mac安装Mysql
  • 原文地址:https://www.cnblogs.com/-wenli/p/10738250.html
Copyright © 2011-2022 走看看