python下载FTP上面的文件夹

zp307300084

FTP指定文件夹里的内容下载到本地，文件夹到底有多少层不知道

这个地方用递归我知道，但是写了几次都报错

希望哪位大侠贴下代码，十分感谢了

iamacnhero

ftp_mirror.py

1. # -*- encoding: utf8 -*-
   
2. import os
   
3. import sys
   
4. import ftplib
   
5. 
   
6. class FTPSync(object):
   
7.     def __init__(self):
   
8.         self.conn = ftplib.FTP('10.22.14.23', 'user', 'pass')
   
9.         self.conn.cwd('/')        # 远端FTP目录
   
10.         os.chdir('/data/')                # 本地下载目录
    
11. 
    
12.     def get_dirs_files(self):
    
13.         u''' 得到当前目录和文件, 放入dir_res列表 '''
    
14.         dir_res = []
    
15.         self.conn.dir('.', dir_res.append)
    
16.         files = [f.split(None, 8)[-1] for f in dir_res if f.startswith('-')]
    
17.         dirs = [f.split(None, 8)[-1] for f in dir_res if f.startswith('d')]
    
18.         return (files, dirs)
    
19. 
    
20.     def walk(self, next_dir):
    
21.         print 'Walking to', next_dir
    
22.         self.conn.cwd(next_dir)
    
23.         try:
    
24.             os.mkdir(next_dir)
    
25.         except OSError:
    
26.             pass
    
27.         os.chdir(next_dir)
    
28. 
    
29.         ftp_curr_dir = self.conn.pwd()
    
30.         local_curr_dir = os.getcwd()
    
31. 
    
32.         files, dirs = self.get_dirs_files()
    
33.         print "FILES: ", files
    
34.         print "DIRS: ", dirs
    
35.         for f in files:
    
36.             print next_dir, ':', f
    
37.             outf = open(f, 'wb')
    
38.             try:
    
39.                 self.conn.retrbinary('RETR %s' % f, outf.write)
    
40.             finally:
    
41.                 outf.close()
    
42.         for d in dirs:
    
43.             os.chdir(local_curr_dir)
    
44.             self.conn.cwd(ftp_curr_dir)
    
45.             self.walk(d)
    
46. 
    
47.     def run(self):
    
48.         self.walk('.')
    
49. 
    
50. def main():
    
51.     f = FTPSync()
    
52.     f.run()
    
53. 
    
54. if __name__ == '__main__':
    
55.     main()

复制代码

zp307300084

回复 2# iamacnhero


        def get_dirs_files(self):
        print('得到当前目录和文件, 放入dir_res列表 ')
        dir_res = []
        self.conn.dir('.', dir_res.append)
        
        print(dir_res)
        files = [f.split(None, [-1] for f in dir_res if f.startswith('-')]
        print(files)
        dirs = [f.split(None, [-1] for f in dir_res if f.startswith('d')]
        print(dirs)
        return (files, dirs)

我是用3.2写的，运行出来没有取出结果啊，files和dirs是空的.........

这个打印出来的结果是
得到当前目录和文件, 放入dir_res列表
['06-08-11  15:50         <DIR>          .', '06-08-11  15:50         <DIR>          ..', '06-08-11  15:51                  14443 collog_report_result.txt', '06-08-11  15:50         <DIR>          SEC-LOG', '06-08-11  15:50         <DIR>          BSC-LOG', '06-08-11  15:51         <DIR>          CFG-LOG', '06-08-11  15:50         <DIR>          PFM-LOG', '06-08-11  15:50         <DIR>          ALM-LOG', '06-08-11  15:50         <DIR>          OPT-LOG', '06-08-11  15:50         <DIR>          SINGLE-BAM']
[]
[]

zp307300084

回复 2# iamacnhero


            print('06-08-11  15:51                  14443 collog_report_result.txt'.split(None, [-1])
        print('06-08-11  15:51                  14443 collog_report_result.txt'.find('<DIR>'))
        #sys.exit()
        dir_res = []
        self.conn.dir('.', dir_res.append)
        
   
        
        files = [f.split(None, [-1] for f in dir_res if f.find('<DIR>')=='-1']

        print(files)
        dirs = [f.split(None, [-1] for f in dir_res if f.find('<DIR>')!='-1']
   
        return (files, dirs)


这是我做修改后的，不过成了死循环了，而且还是不出任何files

zp307300084

回复 2# iamacnhero


            dir_res = []
        conn.dir('.', dir_res.append)  
        files = [f.split(None, [-1] for f in dir_res if f.find('<DIR>')==-1]#隐患
     dirs = [f.split(None, [-1] for f in dir_res if f.find('<DIR>')>=0][2:]

修改成这样就OK了


不过这里用空格来分割不合适，应为有文件和文件夹中间是有空格的

iamacnhero

我运行是成功的，能把你的源代码发来吗？

zp307300084

1. # -*- coding: cp936 -*-
   
2. #!/usr/bin/env python
   
3. 
   
4. '''
   
5. Created on 2011-6-2
   
6. 
   
7. @author: zKF30352
   
8. '''
   
9. 
   
10. 
    
11. 
    
12. from ftplib import FTP
    
13. import shutil, sys, os, time
    
14. from datetime import datetime
    
15. from xml.etree import ElementTree as ET
    
16. from Dev_Data.LoadXml import loadItem
    
17. 
    
18. 
    
19. 
    
20. 
    
21. 
    
22. 
    
23. def main(host,ftpuser,pwd,traitname,startTime,logtype):
    
24. 
    
25.     #生成本地路径
    
26.     currentDir = os.path.dirname(sys.argv[0])
    
27.    
    
28.     ccfile = open(currentDir+'\\Dev_Cfg\\resultPath.txt', 'r')
    
29.     txns = ccfile.read()   
    
30.     ccfile.close()
    
31.    
    
32.     gtrBgnTime = startTime.replace(":", "_").replace('-', '_').replace(' ', '_')
    
33.     filepath = txns + 'log\\'+gtrBgnTime+traitname+'\\'+logtype+'\\'
    
34.     if not os.path.exists(filepath):     
    
35.         os.makedirs(filepath)
    
36.    
    
37.    
    
38.    
    
39.     #连接到FTP   
    
40.     try:   
    
41.         conn = FTP(host, ftpuser, pwd)
    
42.     except:
    
43.         print('FTP连接失败')
    
44.     #获取xml中配置的下载路径   
    
45.     fadName =getXml(logtype)
    
46.     conn.cwd(fadName)  
    
47.       
    
48.     os.chdir(filepath)  
    
49. 
    
50.    
    
51.     walk(conn,'.')
    
52.    
    
53. 
    
54. 
    
55.    
    
56.    
    
57.    
    
58.    
    
59. def walk(conn, next_dir):
    
60.         #next_dir路径，下级目录的路径
    
61.         conn.cwd(next_dir)
    
62.         print(next_dir)
    
63.         try:
    
64.             os.mkdir(next_dir)#这个是在当前工作路径创建文件夹
    
65.         except OSError:
    
66.             pass
    
67.         os.chdir(next_dir)#切换到当前路径为工作空间
    
68. 
    
69.         ftp_curr_dir = conn.pwd()
    
70.         local_curr_dir = os.getcwd()
    
71. 
    
72. 
    
73.         dir_res = []
    
74.         conn.dir('.', dir_res.append)  
    
75.    
    
76.         files = [f.split(None, 8)[-1] for f in dir_res if f.find('<DIR>')==-1]#隐患
    
77.         dirs = [f.split(None, 8)[-1] for f in dir_res if f.find('<DIR>')>=0][2:]
    
78. 
    
79.   
    
80.         for f in files:
    
81.             outf = open(f, 'wb')
    
82.             try:
    
83.                 conn.retrbinary('RETR %s' % f, outf.write)
    
84. 
    
85.             finally:
    
86.                 outf.close()
    
87.         print(local_curr_dir)
    
88.         print(ftp_curr_dir)
    
89.         for d in dirs:
    
90.             os.chdir(local_curr_dir)
    
91.             conn.cwd(ftp_curr_dir)
    
92.             walk(conn,d)
    
93.             
    
94. def getXml(logtype):
    
95.     #获取自动化运行结果目录
    
96.     currentDir = os.path.dirname(sys.argv[0])
    
97.    
    
98.     xmlPath = currentDir + "\\Dev_Cfg\\LOG_CFG.xml"
    
99.     xmlTree = ET.parse(xmlPath)
    
100.     fadName = loadItem(xmlTree, logtype+"/name")           #日志名
     
101.    
     
102.     return fadName
     
103.         
     
104. 
     
105. 
     
106. 
     
107. 
     
108. if __name__ == '__main__':
     
109.     print('------------------------日志生成开始-----------------------------')
     
110.     ftphost ='10.141.149.74'
     
111.     ftpusr='FtpUsr'
     
112.     ftppwd='111111'
     
113.   
     
114.     #生成fad日志
     
115.     startTime = datetime.now().strftime(format="%Y-%m-%d %H:%M:%S")
     
116.     traitname=sys.argv[1]#特性名称
     
117. 
     
118.     #生成fad日志
     
119.     logtype="fad"
     
120.     main(ftphost,ftpusr,ftppwd,traitname,startTime,logtype)
     
121.     #生成fam日志
     
122.     logtype="fam"
     
123.     main(ftphost,ftpusr,ftppwd,traitname,startTime,logtype)
     
124.     #生成col日志
     
125.     logtype='collog'
     
126.     main(ftphost,ftpusr,ftppwd,traitname,startTime,logtype)
     
127.    
     
128.     print('------------------------日志生成结束-----------------------------')

复制代码

iamacnhero

你用的是 Windows的FTP，并且使用的是python 3?

zp307300084

回复 8# iamacnhero


    硬件使用的linux,我是直接使用windows访问linux上的FTP服务器，大概就是这样的

iamacnhero

我测试用的是Ubuntu下的vsftp，脚本环境也是Ubuntu，python版本2.6，你的python版本是3.x ??