用Python實現定時備份Mongodb數據並上傳到FTP服務器

# python3.6.1
import zipfile
import os
import datetime
from ftplib import FTP

# 定義配置信息
srcFolder = r"F:\Data"       # 被壓縮的源數據，文件夾形式
desFolder = r'F:\MongoDbData\\'   # 壓縮好的數據臨時存放的位置
ftp_url = "192.168.0.101"      # FTP服務器地址
ftp_port = 21            # FTP服務端口號
ftpUploadFolder = "MongoDBup"    # 壓縮數據在FTP服務器上存放的位置

# 壓縮文件夾
def zipFolder(srcFolder, desFolder, date):
  '''
  :param srcFolder: 被壓縮的源數據位置
  :param desFolder: 壓縮之後文件的存放路徑
  :param date: 執行壓縮的當前時間，datetime產生(ext:2017-08-16 14:56:40.872613)
  :return: 壓縮文件的路徑
  '''
  startTime = datetime.datetime.now()
  print(f"Enter func zipFolder, time:{startTime}")
  desName = f"{desFolder}mongodb{date.year}{date.month}{date.day}.zip"

  # 檢查是否已經壓縮過瞭
  if os.path.exists(desName):
    endTime = datetime.datetime.now()
    print(f"Already exsist, leave func zipFolder, time:{endTime}, usedTime:{endTime-startTime}")
    return desName

  z = zipfile.ZipFile(desName, 'w', zipfile.ZIP_DEFLATED)
  for dirpath, dirnames, filenames in os.walk(srcFolder):
    print(f"dirpath:{dirpath}, dirnames:{dirnames}, filenames:{filenames}")
    for filename in filenames:
      try:
        # Mongodb在運行時，有幾個關於lock的文件無法壓縮，為瞭避免程序終止，忽略這幾個文件
        z.write(os.path.join(dirpath, filename))
      except Exception as e:
        print(f"except: {e}, cannot zip file: {dirpath}{filename}")
  z.close()
  endTime = datetime.datetime.now()
  print(f"zip done, leave func zipFolder, time:{endTime}, usedTime:{endTime-startTime}")
  return desName

# 上傳文件至FTP服務器
def ftpUpload(filename, folder, ftp_url, ftp_port):
  '''
  :param filename: 待上傳文件路徑
  :param folder: 文件上傳至FTP服務器上的存儲目錄
  :param ftp_url: FTP服務器IP
  :param ftp_port: 端口號,默認為21
  :return: status code
  '''
  startTime = datetime.datetime.now()
  print(f"Enter func ftpUpload, time:{startTime}")
  ftp = FTP()
  ftp.set_debuglevel(2)          # set debug level, detail info:2, close:0
  ftp.connect(ftp_url, ftp_port)
  ftp.login('', '')            # 登錄,如果匿名登錄則用空串代替
  print(ftp.getwelcome())         # ext: *welcome* '220 Microsoft FTP Service'
  ftp.cwd(folder)             # Change to a directory on FTP server
  bufsize = 1024             # 設置緩沖塊大小
  file_handler = open(filename, 'rb')   # 讀模式在本地打開文件
  res = -1
  try:
    # 為瞭避免程序終止，忽略可能出現的錯誤
    res = ftp.storbinary(f"STOR {os.path.basename(filename)}", file_handler, bufsize) # upload file
  except Exception as e:
    print(f"except: {e}, cannot upload file: {ftp_url}:{ftp_port} {filename}")
  finally:
    ftp.set_debuglevel(0)          # 關閉debug信息
    file_handler.close()
    ftp.quit()
  endTime = datetime.datetime.now()
  print(f"Upload done, leave func ftpUpload, time:{endTime}, usedTime:{endTime-startTime}")
  return res

# main
backupTime = datetime.datetime.now()
zip_des_name = zipFolder(srcFolder, desFolder, backupTime)
print(zip_des_name)
ftp_res = ftpUpload(zip_des_name, ftpUploadFolder, ftp_url, ftp_port)
print(f"ftp_res: {ftp_res}")

ftp.connect("172.16.7.107", 21)

enter ftpUpload
*get* ''
Traceback (most recent call last):
 File "AutoBackupMongoTest.py", line 64, in <module>
  ftp_res = ftpUpload(zip_des_name, ftpUploadFolder)
 File "AutoBackupMongoTest.py", line 42, in ftpUpload
  ftp.connect('172.16.7.107', 21)
 File "E:\Miniconda\lib\ftplib.py", line 155, in connect
  self.welcome = self.getresp()
 File "E:\Miniconda\lib\ftplib.py", line 234, in getresp
  resp = self.getmultiline()
 File "E:\Miniconda\lib\ftplib.py", line 220, in getmultiline
  line = self.getline()
 File "E:\Miniconda\lib\ftplib.py", line 208, in getline
  raise EOFError
EOFError

enter ftpUpload
Traceback (most recent call last):
 File "AutoBackupMongoTest.py", line 63, in <module>
  ftp_res = ftpUpload(zip_des_name, ftpUploadFolder)
 File "AutoBackupMongoTest.py", line 41, in ftpUpload
  ftp.connect("192.168.0.101", 21)
 File "E:\Miniconda\lib\ftplib.py", line 152, in connect
  source_address=self.source_address)
 File "E:\Miniconda\lib\socket.py", line 722, in create_connection
  raise err
 File "E:\Miniconda\lib\socket.py", line 713, in create_connection
  sock.connect(sa)
TimeoutError: [WinError 10060] 由於連接方在一段時間後沒有正確答復或連接的主機沒
有反應，連接嘗試失敗。