访问FTP,无非两件事情:upload和download,最近在项目中需要从ftp下载大量文件,然后我就试着去实验自己的ftp操作类,如下(PS:此段有问题,别复制使用,可以参考去试验自己的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
|
import os from ftplib import FTP class FTPSync(): def __init__( self , host, usr, psw, log_file): self .host = host self .usr = usr self .psw = psw self .log_file = log_file def __ConnectServer( self ): try : self .ftp = FTP( self .host) self .ftp.login( self .usr, self .psw) self .ftp.set_pasv( False ) return True except Exception: return False def __CloseServer( self ): try : self .ftp.quit() return True except Exception: return False def __CheckSizeEqual( self , remoteFile, localFile): try : remoteFileSize = self .ftp.size(remoteFile) localFileSize = os.path.getsize(localFile) if localFileSize = = remoteFileSize: return True else : return False except Exception: return None def __DownloadFile( self , remoteFile, localFile): try : self .ftp.cwd(os.path.dirname(remoteFile)) f = open (localFile, 'wb' ) remoteFileName = 'RETR ' + os.path.basename(remoteFile) self .ftp.retrbinary(remoteFileName, f.write) if self .__CheckSizeEqual(remoteFile, localFile): self .log_file.write( 'The File is downloaded successfully to %s' + '\n' % localFile) return True else : self .log_file.write( 'The localFile %s size is not same with the remoteFile' + '\n' % localFile) return False except Exception: return False def __DownloadFolder( self , remoteFolder, localFolder): try : fileList = [] self .ftp.retrlines( 'NLST' , fileList.append) for remoteFile in fileList: localFile = os.path.join(localFolder, remoteFile) return self .__DownloadFile(remoteFile, localFile) except Exception: return False def SyncFromFTP( self , remoteFolder, localFolder): self .__DownloadFolder(remoteFolder, localFolder) self .log_file.close() self .__CloseServer() |