具体代码如下所示：
|
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
|
# -*- coding: utf-8 -*- ''''''' ftp自动检测源文件夹的更新，将源文件夹更新的内容拷贝到目标文件夹中 使用树的层序遍历算法，支持深度目录拷贝 ''' import os import os,sys,string,datetime,time import shutil import socket class MyUpdateMonitor(object): def __init__(self, hostaddr, username, password, remotedir_old, remotedir_new, port = 21): self.hostaddr = hostaddr self.username = username self.password = password self.remotedir_old = remotedir_old self.remotedir_new = remotedir_new # self.port = port self.ftp = FTP() # 源文件文件队列 self.FolderListOld = [] # 目标文件文件队列 self.FolderListNew = [] def __del__(self): self.ftp.close() self.FolderListOld.clear() self.FolderListNew.clear() def FtpLogin(self): ftp = self.ftp try: timeout = 300 socket.setdefaulttimeout(timeout) ftp.set_pasv(True) print u'开始连接到 %s' %(hostaddr) ftp.connect(hostaddr) print u'成功连接到 %s' %(hostaddr) print u'开始登录到 %s' %(hostaddr) ftp.login(username, password) print u'成功登录到 %s' %(hostaddr) ftp.getwelcome() except Exception, e: print 'find exception now:',e # 使用树的层序遍历来检查文件目录 def LevelOrderFolder(self): # 新增文件起始位置和终止位置 start = 0 end = 0 try: # 将根目录放入队列中 self.FolderListOld.append(self.remotedir_old) self.FolderListNew.append(self.remotedir_new) while not (0 == len(self.FolderListOld)): end = start # 将文件夹下的文件全部压入队列 if os.path.isdir(self.FolderListOld[0]): files = os.listdir(self.FolderListOld[0]) for file in files: self.FolderListOld.append(os.path.join(self.FolderListOld[0], file)) # 确定新增文件在队列中的位置 end += len(files) # 将已经查看的文件夹删除 del self.FolderListOld[0] # 检查目标文件夹该级目录 if os.path.isdir(self.FolderListNew[0]): # 将该级目录的文件都列出 files = os.listdir(self.FolderListNew[0]) # 检查源文件该级目录下的文件在目标该级目录下是否有 for file in self.FolderListOld[start:end]: temp = file.split('\\') if temp[-1] in files: # 这里判断文件大小是否一致，不一致拷过去 if os.path.isfile(file) and not os.path.getsize(file) == os.path.getsize(os.path.join(self.FolderListNew[0], temp[-1])): print 'Find the file（%s） size is changed!\n' % file # print r'Start delete...\n' # os.remove(os.path.join(self.FolderListNew[0], temp[-1])) # print r'delete is over...\n' print 'Start Copy...\n' shutil.copyfile(file, os.path.join(self.FolderListNew[0], temp[-1])) print 'Copy is over...\n' # # 如果是文件夹存在，但是修改过，没有必要全部拷贝文件夹，可以到文件夹中拷贝单个文件 # if os.path.isfile(file) and not (os.path.getmtime(file) == os.path.getmtime(os.path.join(self.FolderListNew[0], temp[-1]))): # print 'Find the file（%s） size is changed!\n' % file # changetime = os.path.getmtime(file) #以毫秒为单位的时间，自1970年开始到现今 # changetime = float(changetime) # print 'Change Time is', time.strftime('%Y-%m-%d %H:%M:%S', time.gmtime(changetime)), r'\n' # # print 'Start Copy...\n' # shutil.copyfile(file, os.path.join(self.FolderListNew[0], temp[-1])) # print 'Copy is over...\n' else: if os.path.isdir(file): # 如果是文件夹不存在使用，目录树拷贝 print 'Find the folder（%s） is updated!\n' % file print 'Start Copy...\n' shutil.copytree(file, os.path.join(self.FolderListNew[0], temp[-1])) print 'Copy is over...\n' else: # 如果是文件 print 'Find the file（%s） is updated!\n' % file print 'Start Copy...\n' shutil.copyfile(file, os.path.join(self.FolderListNew[0], temp[-1])) print 'Copy is over...\n' self.FolderListNew.append(os.path.join(self.FolderListNew[0], temp[-1])) del self.FolderListNew[0] start = end - 1 except Exception, e: print 'find exception now:',e if __name__ == '__main__': # 配置如下变量 hostaddr = r'10.204.16.28' # ftp地址 username = r' ' # 用户名 password = r' ' # 密码 remotedir_old = r'\\10.204.16.28\Home\TDME\Test\Old\TMUMH_1.6.1055' remotedir_new = r'\\10.204.16.28\Home\TDME\Test\New\TMUMH_1.6.1055' monitorfileupdae = MyUpdateMonitor(hostaddr, username, password, remotedir_old, remotedir_new) monitorfileupdae.FtpLogin() while True: print 'Start Check Update...\n' monitorfileupdae.LevelOrderFolder() print 'Check Update is Over...\tSleep one hour...' time.sleep(3600) print 'hello' |
总结
以上所述是小编给大家介绍的Python FTP两个文件夹间的同步实例代码，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对服务器之家网站的支持！
原文链接：https://blog.csdn.net/hanyuyang19940104/article/details/80431876
