电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

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

瀏覽:44日期:2022-06-29 08:22:55

實現的功能:在win7下,每天晚上1點,自動將 F:/data中所有文件進行壓縮,以[mongodb+日期]命名,將壓縮好的文件存儲在本地目錄 F:MongoDbData,然后將這個壓縮好的文件上傳到ftp://192.168.0.101/MongoDBup/目錄下

分三步:

第一步:搭建FTP服務器,配置好FTP環境。 第二步:用python編寫壓縮文件并實現FTP上傳的腳本第三步:使用win7自帶的任務計劃程序定時執行python腳本

1. 環境

Python:3.6.1Python IDE:pycharm系統:win7

2. 搭建FTP服務器,配置好FTP環境2.1. 啟用FTP和IIS服務器

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

注意:要全部展開,勾選上。

2.2. 添加FTP服務器

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

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

2.3. 設置參數

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

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

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

2.4. 設置成功,訪問

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

3. 用python編寫壓縮文件并實現FTP上傳的腳本3.1. Import包:

# python3.6.1import zipfileimport osimport datetimefrom ftplib import FTP3.2. 定義配置信息:

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

# 壓縮文件夾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 desName3.4. 文件上傳到FTP服務器上:

# 上傳文件至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 res3.5. 主程序:

# mainbackupTime = 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}')4. 使用win7自帶的任務計劃程序定時執行python腳本

位置:開始 ——> 附件 ——> 系統工具 ——> 任務計劃程序

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

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

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

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

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

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

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

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

不需要時,右鍵——>刪除任務 即可

5. 效果5.1. 本地生成的壓縮文件

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

5.2. 上傳至FTP服務器的壓縮文件

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

5.3. 詳細信息-性能-時間

日志信息:

源文件data總共8.7G,壓縮后5.3G,壓縮時間20m,局域網內上傳時間18m。

E:Minicondapython.exe E:/PyCharmCode/Justtest/bak.pyEnter func zipFolder, time:2017-08-16 19:48:39.331200dirpath:F:Data, dirnames:[’diagnostic.data’, ’journal’], filenames:[’collection-0--394122179086539486.wt’, ’collection-102--394122179086539486.wt’, ’collection-104--394122179086539486.wt’, ’collection-106--394122179086539486.wt’, ’collection-108--394122179086539486.wt’], ’_mdb_catalog.wt’]except: [Errno 13] Permission denied: ’F:Datamongod.lock’, cannot zip file: F:Datamongod.lockexcept: [Errno 13] Permission denied, cannot zip file: F:DataWiredTiger.lockdirpath:F:Datadiagnostic.data, dirnames:[], filenames:[’metrics.2017-08-04T07-04-29Z-00000’, ’metrics.2017-08-05T10-47-22Z-00000’, ’metrics.2017-08-06T14-52-22Z-00000’, ’metrics.2017-08-07T18-17-22Z-00000’, ’metrics.2017-08-15T06-09-26Z-00000’, ’metrics.2017-08-16T09-51-29Z-00000’]dirpath:F:Datajournal, dirnames:[], filenames:[’WiredTigerLog.0000000247’, ’WiredTigerPreplog.0000000006’, ’WiredTigerPreplog.0000000007’, ’WiredTigerPreplog.0000000008’]zip done, leave func zipFolder, time:2017-08-16 20:08:22.728200, usedTime:0:19:43.397000F:MongoDbDatamongodb2017816.zipEnter func ftpUpload, time:2017-08-16 20:08:22.728200*get* ’220 Microsoft FTP Servicen’*resp* ’220 Microsoft FTP Service’*cmd* ’USER anonymous’*put* ’USER anonymousrn’*get* ’331 Anonymous access allowed, send identity (e-mail name) as password.n’*resp* ’331 Anonymous access allowed, send identity (e-mail name) as password.’*cmd* ’PASS **********’*put* ’PASS **********rn’*get* ’230 User logged in.n’*resp* ’230 User logged in.’*welcome* ’220 Microsoft FTP Service’220 Microsoft FTP Service*cmd* ’CWD MongoDBup’*put* ’CWD MongoDBuprn’*get* ’250 CWD command successful.n’*resp* ’250 CWD command successful.’*cmd* ’TYPE I’*put* ’TYPE Irn’*get* ’200 Type set to I.n’*resp* ’200 Type set to I.’*cmd* ’PASV’*put* ’PASVrn’*get* ’227 Entering Passive Mode (192,168,0,101,11,221).n’*resp* ’227 Entering Passive Mode (192,168,0,101,11,221).’*cmd* ’STOR mongodb2017816.zip’*put* ’STOR mongodb2017816.ziprn’*get* ’125 Data connection already open; Transfer starting.n’*resp* ’125 Data connection already open; Transfer starting.’*get* ’226 Transfer complete.n’*resp* ’226 Transfer complete.’Upload done, leave func ftpUpload, time:2017-08-16 20:26:20.125200, usedTime:0:17:57.397000ftp_res: 226 Transfer complete.

6. 注意事項 6.1. FTP服務器IP地址變更處理

6.1.1. 第一步,修改FTP服務器站點配置。

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

6.1.2. 第二步,修改代碼中FTP登錄IP

ftp.connect('172.16.7.107', 21)

6.1.3. 出錯信息 如果只是單純按照6.1.2 修改登錄IP,沒有修改FTP服務器站點設置的話,將會出現如下莫名其妙的錯誤:

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:Minicondalibftplib.py', line 155, in connect self.welcome = self.getresp() File 'E:Minicondalibftplib.py', line 234, in getresp resp = self.getmultiline() File 'E:Minicondalibftplib.py', line 220, in getmultiline line = self.getline() File 'E:Minicondalibftplib.py', line 208, in getline raise EOFErrorEOFError

或者是如下錯誤:

enter ftpUploadTraceback (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:Minicondalibftplib.py', line 152, in connect source_address=self.source_address) File 'E:Minicondalibsocket.py', line 722, in create_connection raise err File 'E:Minicondalibsocket.py', line 713, in create_connection sock.connect(sa)TimeoutError: [WinError 10060] 由于連接方在一段時間后沒有正確答復或連接的主機沒有反應,連接嘗試失敗。

到此這篇關于用Python實現定時備份Mongodb數據并上傳到FTP服務器的文章就介紹到這了,更多相關Python 定時備份Mongodb內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!

標簽: Python 編程
相關文章:
主站蜘蛛池模板: 双吸泵,双吸泵厂家,OS双吸泵-山东博二泵业有限公司 | 一体式钢筋扫描仪-楼板测厚仪-裂缝检测仪-泰仕特(北京) | 气动隔膜泵-电动隔膜泵-循环热水泵-液下排污/螺杆/管道/化工泵「厂家」浙江绿邦 | 专业生产动态配料系统_饲料配料系统_化肥配料系统等配料系统-郑州鑫晟重工机械有限公司 | 并网柜,汇流箱,电控设备,中高低压开关柜,电气电力成套设备,PLC控制设备订制厂家,江苏昌伟业新能源科技有限公司 | 冰晶石|碱性嫩黄闪蒸干燥机-有机垃圾烘干设备-草酸钙盘式干燥机-常州市宝康干燥 | 衬氟旋塞阀-卡套旋塞阀-中升阀门首页 | 异噻唑啉酮-均三嗪-三丹油-1227-中北杀菌剂厂家 | 东莞爱加真空科技有限公司-进口真空镀膜机|真空镀膜设备|Polycold维修厂家 | 数显恒温油浴-电砂浴-高温油浴振荡器-常州迈科诺仪器有限公司 | 分光色差仪,测色仪,反透射灯箱,爱色丽分光光度仪,美能达色差仪维修_苏州欣美和仪器有限公司 | 北京三友信电子科技有限公司-ETC高速自动栏杆机|ETC机柜|激光车辆轮廓测量仪|嵌入式车道控制器 | 儋州在线-儋州招聘找工作、找房子、找对象,儋州综合生活信息门户! | 粘度计NDJ-5S,粘度计NDJ-8S,越平水分测定仪-上海右一仪器有限公司 | 浇钢砖,流钢砖_厂家价低-淄博恒森耐火材料有限公司 | 多米诺-多米诺世界纪录团队-多米诺世界-多米诺团队培训-多米诺公关活动-多米诺创意广告-多米诺大型表演-多米诺专业赛事 | VOC检测仪-甲醛检测仪-气体报警器-气体检测仪厂家-深恒安科技有限公司 | 成都网站建设制作_高端网站设计公司「做网站送优化推广」 | 连续油炸机,全自动油炸机,花生米油炸机-烟台茂源食品机械制造有限公司 | 工业洗衣机_工业洗涤设备_上海力净工业洗衣机厂家-洗涤设备首页 bkzzy在职研究生网 - 在职研究生招生信息咨询平台 | 广东佛电电器有限公司|防雷开关|故障电弧断路器|智能量测断路器 广东西屋电气有限公司-广东西屋电气有限公司 | 环讯传媒,永康网络公司,永康网站建设,永康小程序开发制作,永康网站制作,武义网页设计,金华地区网站SEO优化推广 - 永康市环讯电子商务有限公司 | 广州中央空调回收,二手中央空调回收,旧空调回收,制冷设备回收,冷气机组回收公司-广州益夫制冷设备回收公司 | 牛奶检测仪-乳成分分析仪-北京海谊 | 除甲醛公司-甲醛检测-广西雅居环境科技有限公司 | 集装箱展厅-住人集装箱住宿|建筑|房屋|集装箱售楼处-山东锐嘉科技工程有限公司 | 创富网-B2B网站|供求信息网|b2b平台|专业电子商务网站 | 一体化预制泵站-一体化提升泵站-一体化泵站厂家-山东康威环保 | 国际线缆连接网 - 连接器_线缆线束加工行业门户网站 | 高压负荷开关-苏州雷尔沃电器有限公司 | 球形钽粉_球形钨粉_纳米粉末_难熔金属粉末-广东银纳官网 | 设定时间记录电子秤-自动累计储存电子秤-昆山巨天仪器设备有限公司 | 家庭教育吧-在线家庭教育平台,专注青少年家庭教育 | 铣刨料沥青破碎机-沥青再生料设备-RAP热再生混合料破碎筛分设备 -江苏锡宝重工 | 润滑脂-高温润滑脂-轴承润滑脂-食品级润滑油-索科润滑油脂厂家 | 健康管理师报名入口,2025年健康管理师考试时间信息网-网站首页 塑料造粒机「厂家直销」-莱州鑫瑞迪机械有限公司 | 老城街小面官网_正宗重庆小面加盟技术培训_特色面馆加盟|牛肉拉面|招商加盟代理费用多少钱 | 裹包机|裹膜机|缠膜机|绕膜机-上海晏陵智能设备有限公司 | 丹佛斯变频器-Danfoss战略代理经销商-上海津信变频器有限公司 | 超细粉碎机|超微气流磨|气流分级机|粉体改性设备|超微粉碎设备-山东埃尔派粉碎机厂家 | 无刷电机_直流无刷电机_行星减速机-佛山市藤尺机电设备有限公司 无菌检查集菌仪,微生物限度仪器-苏州长留仪器百科 |