好的。假设您的FTP服务器支持MLSD
命令,请使用以下代码创建模块(这是我用来将远程FTP站点与本地目录同步的脚本中的代码):
模块代码
import sys, os, time, ftplib
import collections
FTPDir= collections.namedtuple("FTPDir", "name size mtime tree")
FTPFile= collections.namedtuple("FTPFile", "name size mtime")
class FTPDirectory(object):
def __init__(self, path='.'):
self.dirs= []
self.files= []
self.path= path
def getdata(self, ftpobj):
ftpobj.retrlines('MLSD', self.addline)
def addline(self, line):
data, _, name= line.partition('; ')
fields= data.split(';')
for field in fields:
field_name, _, field_value= field.partition('=')
if field_name == 'type':
target= self.dirs if field_value == 'dir' else self.files
elif field_name in ('sizd', 'size'):
size= int(field_value)
elif field_name == 'modify':
mtime= time.mktime(time.strptime(field_value, "%Y%m%d%H%M%S"))
if target is self.files:
target.append(FTPFile(name, size, mtime))
else:
target.append(FTPDir(name, size, mtime, self.__class__(os.path.join(self.path, name))))
def walk(self):
for ftpfile in self.files:
yield self.path, ftpfile
for ftpdir in self.dirs:
for path, ftpfile in ftpdir.tree.walk():
yield path, ftpfile
class FTPTree(FTPDirectory):
def getdata(self, ftpobj):
super(FTPTree, self).getdata(ftpobj)
for dirname in self.dirs:
ftpobj.cwd(dirname.name)
dirname.tree.getdata(ftpobj)
ftpobj.cwd('..')
单目录情况
如果你想要操作一个目录下的文件,你可以:
import ftplib, time
quite_old= time.time() - 7*86400
site= ftplib.FTP(hostname, username, password)
site.cwd(the_directory_to_work_on)
folder= FTPDirectory()
folder.getdata(site)
for path, ftpfile in folder.walk():
if ftpfile.mtime < quite_old:
site.delete(ftpfile.name)
这应该可以满足您的需求。
一个目录及其所有子目录
现在,如果您需要递归地执行此操作,您需要对“单个目录情况”的代码进行以下两个更改:
folder= FTPTree()
并且
site.delete(os.path.join(path, ftpfile.name))
可能存在的注意点
我所使用过的服务器没有在STOR
和DELE
命令中使用相对路径时出现任何问题,因此使用相对路径的site.delete
也可以正常工作。如果您的FTP服务器需要无路径文件名,请先使用提供的path
进行.cwd
,再删除ftpfile.name
,最后.cwd
回到基础文件夹。
os.directory
是什么?你的代码没什么意义。为什么要尝试删除本地系统中的文件? - SilentGhost