python实现ftp上传下载文件
#!/usr/bin/env python# encoding: utf-8
__author__ = "pwy"
'''
上传：上传文件并备份到其他目录
下载：下载文件，并删除远端文件
'''
from ftplib import FTP
from time import sleep
import os,datetime,logging
from shutil import move
HOST = "192.168.1.221"
USER = "sxit"
PASSWORD = "1qaz!QAZ"
#PORT = ""
#Upload the file, change the directory
remotedir = "/home/test/"
localdir = "/home/sxit/object/"
bakdir = "/home/sxit/bak"
#Download the file, change the directory
Remoredir = "/home/sxit/object1/"
Localdir = "/root/ftp-logging"
LOGFILE = datetime.datetime.now().strftime('%Y-%m-%d')+'.log'
logging.basicConfig(level=logging.INFO,
format='%(asctime)s %(filename)s %(levelname)s %(message)s',
# datefmt='%a, %d %b %Y %H:%M:%S',
filename= LOGFILE,
filemode='a')
logging.FileHandler(LOGFILE)
class CLASS_FTP:
def __init__(self,HOST,USER,PASSWORD,PORT='21'):
self.HOST = HOST
self.USER = USER
self.PASSWORD = PASSWORD
self.PORT = PORT
self.ftp=FTP()
self.flag=0 # 0:no connected, 1: connting
def Connect(self):
try:
if self.flag == 1:
logging.info("ftp Has been connected")
else:
self.ftp.connect(self.HOST,self.PORT)
self.ftp.login(self.USER,self.PASSWORD)
# self.ftp.set_pasv(False)
self.ftp.set_debuglevel(0)
self.flag=1
except Exception:
logging.info("FTP login failed")
def Up_load(self,remotedir,localdir,bakdir):
try:
self.ftp.cwd(remotedir)
for i in os.listdir(localdir):
if i.endswith('.txt'):
file_handler = open(i,'rb')
self.ftp.storbinary('STOR %s' % i,file_handler)
logging.info("%s already upload ."%i)
try:
if os.path.isdir(bakdir):
move(i,bakdir)
logging.info("%s move to %s ." % (i,bakdir))
else:
print "Move the file FAILED"
logging.info("Move the %s to %s FAILED!"%(i,bakdir))
except Exception:
logging.info("ftp delete file faild !!!!!")
file_handler.close()
# self.ftp.quit()
except Exception:
logging.info("Up_load failed")
def Down_load(self,Remoredir,Localdir):
try:
self.ftp.cwd(Remoredir)
for i in self.ftp.nlst():
if i.endswith('.NET'): #match file
file_handler = open(i,'wb')
self.ftp.retrbinary('RETR %s' % i,file_handler.write)
logging.info("%s already down ."%i)
try:
self.ftp.delete(i)
logging.info("%s already deleted!"%i)
except Exception:
logging.info("ftp delete file faild !!!!!")
file_handler.close()
#self.ftp.quit()
except Exception:
logging.info("Down_load failed")
if __name__ == '__main__':
ftp = CLASS_FTP(HOST,USER,PASSWORD)
while True:
ftp.Connect()
# ftp.Down_load(Remoredir,Localdir)
ftp.Up_load(remotedir,localdir,bakdir)
sleep(30)
页:
[1]