Python FTP两个文件夹间的同步实例代码

具体代码如下所示：

# -*- coding: utf-8 -*-
'''''''
  ftp自动检测源文件夹的更新，将源文件夹更新的内容拷贝到目标文件夹中
  使用树的层序遍历算法，支持深度目录拷贝
'''
import os
from ftplib import FTP
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两个文件夹间的同步实例代码，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对我们网站的支持！