具体代码如下所示：
|
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