欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Python FtpLib模塊應用操作詳解

 更新時間：2019年12月12日 12:07:42   作者：jinsefm  
這篇文章主要介紹了Python FtpLib模塊應用操作,結(jié)合實例形式詳細分析了FtpLib模塊的功能、配置、應用相關(guān)操作技巧與使用注意事項,需要的朋友可以參考下

本文實例講述了Python FtpLib模塊應用操作。分享給大家供大家參考，具體如下：

Python之FtpLib模塊應用

工廠中有這樣的應用場景: 需要不間斷地把設(shè)備電腦生成的數(shù)據(jù)文件上傳到遠程文件存儲服務(wù)器NAS中。

在python自帶的標準庫中找到ftplib模塊，可以幫助實現(xiàn)文件的上傳。

場景功能的實現(xiàn)需要做到以下幾點:

  • 給定本地路徑，上傳范圍是否包含子文件夾及其文件
  • 限定或不限定 哪些文件類型的文件，文件名包含哪些字符串的文件
  • 文件上傳后，本地是否要保留
  • 掃完一次本地路徑，進行下次循環(huán)的間隔周期
  • 生成log日志方便查看報錯與已上傳的文件，日志文件保留多久之后要刪除

思路是這樣子，以上內(nèi)容設(shè)計成一個config 文件進行管控。

1.config.xml文件設(shè)置

<?xml version="1.0"?>
<Config>
 <ServerIP>10.16.xx.xx</ServerIP>
 <UserID>cc</UserID>
 <Passwd>xxx</Passwd>
 <LogBackupDay>10</LogBackupDay>
 <UploadCheck>TRUE</UploadCheck>
 <Loop_Sec>30</Loop_Sec>
 <LocalDirectory>C:\Users\Administrator\Desktop\TEST\</LocalDirectory>
 <RemoteDirectory>/DATA/AOI/T1TEST200/</RemoteDirectory>
 <FileExtension>csv</FileExtension>
 <FileNameContain>*</FileNameContain>
 <SubDirectoryCheck>TRUE</SubDirectoryCheck>
 <SubDirectoryCreateCheck>FALSE</SubDirectoryCreateCheck>
 <LocalFileBackupCheck>TRUE</LocalFileBackupCheck>
 <FileCreateTime>80</FileCreateTime>
</Config>
  • LogBackupDay 日志保留天數(shù)
  • UploadCheck 是否開啟上傳
  • Loop_Sec 掃描循環(huán)周期
  • LocalDirectory 本地路徑，結(jié)尾必須有路徑分隔符
  • RemoteDirectory 遠程路徑，結(jié)尾必須有路徑分隔符
  • FileExtension 文件類型，jpg,txt,py,log等等，為*時不限制文件類型
  • FileNameContain 文件名字符串 ， 文件名包含哪些字符串的文件，為*時不限制文件名
  • SubDirectoryCheck 子文件夾的文件是否上傳
  • SubDirectoryCreateCheck 遠程路徑是否創(chuàng)建和本地路徑一樣的文件夾
  • LocalFileBackupCheck 本地文件是否保留
  • FIleCreateTime 掃描本地路徑中創(chuàng)建時間為多少個小時內(nèi)的文件或文件夾

以下是讀取config.xml的代碼

from xml.dom.minidom import parse
def readConfig():
  '''讀取上傳配置'''
  conf=parse(os.getcwd()+os.sep+'config.xml');#config文件與程序放在同一目錄
  host=conf.getElementsByTagName("ServerIP")[0].firstChild.data
  username =conf.getElementsByTagName("UserID")[0].firstChild.data
  passwd=conf.getElementsByTagName("Passwd")[0].firstChild.data
  logBackupDay=int(conf.getElementsByTagName("LogBackupDay")[0].firstChild.data)
  uploadCheck=conf.getElementsByTagName("UploadCheck")[0].firstChild.data
  uploadLoopTime=int(conf.getElementsByTagName("Loop_Sec")[0].firstChild.data)
  localDir=conf.getElementsByTagName("LocalDirectory")[0].firstChild.data
  remoteDir=conf.getElementsByTagName("RemoteDirectory")[0].firstChild.data
  fileExtension=conf.getElementsByTagName("FileExtension")[0].firstChild.data
  fileNameContain=conf.getElementsByTagName("TxtFileNameContain")[0].firstChild.data
  subDirCheck=conf.getElementsByTagName("SubDirectoryCheck")[0].firstChild.data
  subDirCreateCheck=conf.getElementsByTagName("SubDirectoryCreateCheck")[0].firstChild.data
  backupCheck=conf.getElementsByTagName("LocalFileBackupCheck")[0].firstChild.data
  fileCreateTime=int(conf.getElementsByTagName("FileCreateTime")[0].firstChild.data)
  conflist=[host,username,passwd,logBackupDay,uploadCheck,uploadLoopTime,
       localDir,remoteDir,fileExtension,fileNameContain,
       subDirCheck,subDirCreateCheck,backupCheck,fileCreateTime]
  return conflist

2.相關(guān)邏輯實現(xiàn)

文件類型及文件名檢驗

def checkFileExtension(localfile,extension):
  '''
  檢查文件名是否符合需要上傳的文件類型
  extension為*時，無文件類型限制上傳
  '''
  if extension=="*":
    return True
  elif localfile.endswith(extension):
    return True
  else:
    return False
def checkFileNameContains(localfile,filecontain):
  '''
  檢查特定文件名的文件
  filecontain 為 * 時,不限制上傳文件名
  '''
  if filecontain=="*":
    return True
  elif filecontain in localfile:
    return True
  else:
    return False

文件上傳之后，本地是否保留

def deleteLocalFile(deleteCheck,localfile):
  if not deleteCheck:
    os.remove(localfile)
    logger.info("Remove local file:{}".format(localfile))

只上傳創(chuàng)建時間為N個小時內(nèi)的文件或文件夾

def checkFileModifiedTime(localfile,hour):
  '''只上傳創(chuàng)建時間為hour小時內(nèi)的文件'''
  if os.stat(localfile).st_ctime<time.time()-hour*3600:
    return False
  else:
    return True

生成日志，日志文件保留多久

#創(chuàng)建logger日志
logger = logging.getLogger()
logger.setLevel(logging.INFO)
#filehandler
rq = time.strftime('%Y%m%d', time.localtime(time.time()))
log_path = os.getcwd()+os.sep + 'Logs'+os.sep
if not os.path.exists(log_path):
  os.mkdir(log_path)
log_name = log_path + rq + '.log'
logfile = log_name
fh = logging.FileHandler(logfile, mode='w')
fh.setLevel(logging.DEBUG)
#filehandler輸出格式
formatter = logging.Formatter("%(asctime)s - %(filename)s[line:%(lineno)d] - %(levelname)s: %(message)s")
fh.setFormatter(formatter)
logger.addHandler(fh)


def deleteLog(days):
  '''刪除多少天之前的日志文件'''
  for file2 in os.listdir(log_path):
    logfile=os.path.join(log_path,file2)
    if os.stat(logfile).st_ctime<time.time()-days*24*3600:
      os.remove(logfile)

展開子文件夾及相關(guān)判斷邏輯

def listFile(ftp,local,remote,subdircreatecheck,extension,filenamecontains,filecreatetime,
localBackupCheck):
  '''遞歸調(diào)用出子文件或子文件夾 
  ftp FTP實例
  local 本地文件[夾]
  remote 遠程文件[夾]
  subdircreatecheck 遠程是否創(chuàng)建對應的子文件夾
  extension 文件類型
  filecontains 文件名必須包含
  filecreatetime 文件修改時間在多少小時內(nèi)的
  localBackupCheck 本地文件是否保留
  '''
  for file in os.listdir(local):
    local2=os.path.join(local,file) #路徑+文件名為 完整路徑
    remote2=remote+'/'+file
    try:
      if not checkFileModifiedTime(local2,filecreatetime):
        continue
      if not subdircreatecheck:
        remote2=remote
      if os.path.isdir(local2):
        try:             #驗證ftp遠程是否已有目錄  
          ftp.cwd(remote2)     #打開遠程目錄，無法打開則報異常，在異常處理里面創(chuàng)建遠程目錄
        except Exception as e:
          logger.error("Fail to open directory.")
          logger.info("Open directory: {} fail,so create dir.".format(remote2))
          ftp.mkd(remote2)
          logger.info("ItslocalDir:{}".format(local2))
        listFile(ftp,local2,remote2,subdircreatecheck,extension,filenamecontains,
             filecreatetime,localBackupCheck)
      else:
        if checkFileExtension(local2,extension):
          if checkFileNameContains(local2,filenamecontains):
            remote2=remote+'/'+file
            upload(ftp,local2,remote2)
            deleteLocalFile(local2,localBackupCheck)
    except Exception as e:
      logger.error(e.args[0])

上傳及異常檢驗

遠程文件已存在并且大小與本地一致時無需上傳，使用ftp.size()對比遠程文件與本地文件大小即可，出現(xiàn)異常表明遠程文件不存在。

def upload(ftp,localFile,remoteFile):
  '''以二進制形式上傳文件
  ftp.size()驗證遠程文件是否存在并且判斷文件大小
  '''
  try:
    if ftp.size(remoteFile)==os.path.getsize(localFile):
      return
  except ftplib.error_perm as err:
    logger.warning("{0}.When upload file:{1}".format(err.args[0],remoteFile))
  except Exception as e:
    logger.warning("other error!")
  uf = open(localFile, 'rb')
  bufsize = 1024 # 設(shè)置緩沖器大小
  try:
    ftp.storbinary('STOR ' + remoteFile, uf, bufsize)
    logger.info("File has upload success:{}".format(remoteFile))
  except:
    logger.error("File Upload Fail!:{}".format(remoteFile))
  finally:
    uf.close()

周期循環(huán)

logger.info("File Send Program Start!")
while uploadCheck:
  logger.info("File Send Program LoopStart!")
  deleteLog(logBackupDay)
  f=ftplib.FTP(host)
  try:
    ###
  except:
    ###
  finally:
    f.quit()
  logger.info("Loop end,wait for next loop!")
  time.sleep(loopTime)

3.打包exe文件

pyinstaller庫打包

值的注意的是，64位python環(huán)境下打包的exe不能在32位的Win7、xp運行。最后使用32位的python環(huán)境進行打包。

pyinstaller -i jftp.ico -F Jftp.py -w

code具體詳情請查看github-jftp

更多關(guān)于Python相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《Python文件與目錄操作技巧匯總》、《Python Socket編程技巧總結(jié)》、《Python數(shù)據(jù)結(jié)構(gòu)與算法教程》、《Python函數(shù)使用技巧總結(jié)》、《Python字符串操作技巧匯總》及《Python入門與進階經(jīng)典教程》

希望本文所述對大家Python程序設(shè)計有所幫助。

相關(guān)文章

最新評論