python ftp 处理

re2212

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文件

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 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186

from pyftpdlib.authorizers import DummyAuthorizer from pyftpdlib.handlers import FTPHandler from pyftpdlib.servers import FTPServer from CFileOperator import CFileOperator import ftplib import os import thread import time import socket class CFTPServer():     def __init__(self, name="song", passwd="song", port=21):         self._name = name         self._passwd = passwd         self._port = port     def Start(self):         authorizer = DummyAuthorizer()         authorizer.add_user(self._name, self._passwd, '.', perm='elradfmwM')         authorizer.add_anonymous(os.getcwd())         handler = FTPHandler         handler.authorizer = authorizer         handler.banner = "pyftpdlib based ftpd ready."         address = ('', self._port)         self._server = FTPServer(address, handler)         self._server.max_cons = 256         self._server.max_cons_per_ip = 5         self._server.serve_forever()     def Stop(self):         self._server.close_all() class CFTPCLient():     def __init__(self, host="127.0.0.1", name="song", passwd="song", port=21,savepath='./'):         self._host = host         self._name = name         self._passwd = passwd         self._port = port         self._ftp = None         self._connet = False         self._buffer = 2048         self._FileOperator = CFileOperator()         self._savepath=savepath         self._srcpath=os.getcwd()     def conneterver(self):         try:             self._ftp = ftplib.FTP(self._host)         except (socket.error, socket.gaierror), e:             print 'ERROR: cannot reach "%s"' % self._host             self._connet = False             return         print '*** Connected to host "%s"' % self._host         try:             self._ftp.login(self._name, self._passwd)         except ftplib.error_perm:             print 'ERROR: login failed with "%s" and "%s"' % self._name, self._passwd             self._ftp.quit()             self._connet = False             return         self._ftp.cwd('./')         self._ftp.nlst()         print '*** Logged in'         self._connet = True     def CmdPath(self,path):         if not self._connet:             self.conneterver()         if not self._connet:             return         self._ftp.cwd(path)     def GetCur(self):         if not self._connet:             self.conneterver()         if not self._connet:             return         return self._ftp.pwd()     def List(self):         if not self._connet:             self.conneterver()         if not self._connet:             return         self._ftp.dir()     def UPLoadFile(self, filename):         if not self._connet:             self.conneterver()         if not self._connet:             return         elem = filename         if self._FileOperator.ISDirExit(filename):             self._FileOperator.TarFile(filename)             elem += ".tar"         file_open = open(elem, 'rb')         self._ftp.storbinary('STOR %s' % os.path.basename(elem), file_open, self._buffer)         if not file_open.closed:             file_open.close()     def DeleteRomoteFile(self,filename):         if not self._connet:             self.conneterver()         if not self._connet:             return         self._ftp.delete(filename)     def DeleteRomoteDir(self,Dir):         if not self._connet:             self.conneterver()         if not self._connet:             return         self._ftp.rmd(Dir)     def RenameRomoteFile(self,oldname,newname):         if not self._connet:             self.conneterver()         if not self._connet:             return         self._ftp.rename(oldname,newname)     def get_dirs_files(self):         dir_res = []         self._ftp.dir('.', dir_res.append)         files = [f.split(None, 8)[-1] for f in dir_res if f.startswith('-')]         dirs = [f.split(None, 8)[-1] for f in dir_res if f.startswith('d')]         return (files, dirs)     def DownLoadFile(self, next_dir):         if not self._connet:             self.conneterver()         if not self._connet:             return         print 'Walking to', next_dir         self._ftp.cwd(next_dir)         try:             os.mkdir(next_dir)         except OSError:             pass         os.chdir(next_dir)         ftp_curr_dir = self._ftp.pwd()         local_curr_dir = os.getcwd()         files, dirs = self.get_dirs_files()         print "FILES: ", files         print "DIRS: ", dirs         for f in files:             print next_dir, ':', f             outf = open(f, 'wb')             try:                 self._ftp.retrbinary('RETR %s' % f, outf.write)             finally:                 outf.close()         for d in dirs:             os.chdir(local_curr_dir)             self._ftp.cwd(ftp_curr_dir)             self.walk(d) if __name__ == '__main__':     c = CFTPServer()     thread.start_new_thread(c.Start, ())     d = CFTPCLient()     time.sleep(2)     d.UPLoadFile("/home/test")     time.sleep(3000)     #d.UPLoadFile("/home/test")   #  d.DownLoadFile("/test.tar")     # f =CFileOperator()     #f.TarFile("/home/test")