python的ftp功能程序
- 2020 年 1 月 9 日
- 筆記
ftp类模块：
#!/usr/bin/python
# -*- coding: utf-8 -*- from ftplib import FTP import sys import datetime import os.path import ConfigParser time=datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S') class Ftp: def __init__ (self,IP,USERNAME,PASSWD,URL,FILENAME): """初始化ip和端口""" self.IP=IP self.USERNAME=USERNAME self.PASSWD=PASSWD self.URL=URL self.FILENAME=FILENAME def ftp_down(self): try: ftp=FTP(self.IP) except Exception: print "连接服务器失败" try: ftp.login(self.USERNAME,self.PASSWD) except Exception: print "登陆服务器失败" ftp.cwd(self.URL) ftp.voidcmd("TYPE I") if len(ftp.nlst(self.URL+os.sep+self.FILENAME)) != 0: Datasock,estsize = ftp.ntransfercmd("RETR %s" % self.FILENAME ) Transbytes=0 FO=open(self.FILENAME,'wb') while True: buf=Datasock.recv(2048) if not len(buf): break FO.write(buf) Transbytes+=len(buf) sys.stdout.write("Received %d" %Transbytes) if estsize: sys.stdout.write("of %d bytes (%.2f%%)rn" % (estsize,100.0 * float(Transbytes) / float(estsize))) else: sys.stdout.write("bytesr") sys.stdout.flush() sys.stdout.write("bytesr") FO.close() Datasock.close() ftp.voidresp() ftp.quit() else: print "下载文件不存在!–%s" % self.FILENAME def ftp_up(self): """上传""" try: ftp=FTP(self.IP) except Exception: print "连接服务器失败" try: ftp.login(self.USERNAME,self.PASSWD) except Exception: print "登陆服务器失败" ftp.cwd(self.URL) ftp.voidcmd("TYPE I") if os.path.isfile(self.FILENAME): FO=open(self.FILENAME,'rb') Datasock,esize=ftp.ntransfercmd('STOR %s' % self.FILENAME ) esize=os.stat(self.FILENAME)[6] Transbytes = 0 while True: buf = FO.read(2048) if not len(buf): break Datasock.sendall(buf) Transbytes+=len(buf) sys.stdout.write("send %d of %d bytes (%.1f%%)r" % ( Transbytes,esize,100 * float(Transbytes) / float(esize))) sys.stdout.flush() Datasock.close() sys.stdout.write("n") FO.close() ftp.voidresp() ftp.quit() else: print "上传文件不存在!–%s" % self.FILENAME class Config: def DOWN(self): config=ConfigParser.ConfigParser() config_file=open('config.ini','r') config.readfp(config_file) ip=config.get('FTP_APP_DOWN','ip') user=config.get('FTP_APP_DOWN','user') password=config.get('FTP_APP_DOWN','password') url=config.get('FTP_APP_DOWN','url') filename=config.get('FTP_APP_DOWN','filename') config_file.close() down=Ftp(ip,user,password,url,filename) down.ftp_down() def UP(self): config=ConfigParser.ConfigParser() config_file=open('config.ini','r') config.readfp(config_file) ip=config.get('FTP_APP_UP','ip') user=config.get('FTP_APP_UP','user') password=config.get('FTP_APP_UP','password') url=config.get('FTP_APP_UP','url') filename=config.get('FTP_APP_UP','filename') config_file.close() up=Ftp(ip,user,password,url,filename) up.ftp_up() if __name__ == '__main__': sys.stdout=open('ftp.log','a') print '开始下载:%s' % time FTP_2=Config() FTP_2.DOWN() print '下载结束:%s' % time print '' print '开始上传:%s' % time FTP_2.UP() print '上传结束:%s' % time print '' sys.stdout.close()
读取的配置文件config.ini：
[FTP_APP_DOWN] ip=192.168.10.1 user=RHL password=RHL4321 url=/usr/mpsp/yunxing/RHL filename=ABC.txt [FTP_APP_UP] ip=192.168.10.2 user=RHL password=RHL4321 url=/usr/mpsp/yunxing filename=ABC.txt
