大龍的博客

導(dǎo)航

<

2011年12月

>

日

一

二

三

四

五

六

27

28

29

30

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

1

2

3

4

5

6

7

留言簿(43)

收藏夾

ps (rss)

隨筆檔案

文章檔案

閱讀排行榜

評論排行榜

常用鏈接

統(tǒng)計(jì)

隨筆 - 864
文章 - 2
評論 - 378
引用 - 0

python實(shí)現(xiàn)的ftp自動上傳下載程序（支持目錄遞歸操作）----轉(zhuǎn)

因?yàn)閜ython腳本可以直接用文本工具打開修改，所以沒有設(shè)置參數(shù)。使用的時(shí)候直接修改掉main中的連接下載參數(shù)即可。
修改一下，可以用來備份網(wǎng)站上的圖片，數(shù)據(jù)庫什么的。

Python代碼  
#!/usr/bin/python  
#coding=gbk  
''''' 
    ftp自動下載、自動上傳腳本，可以遞歸目錄操作 
'''  
  
from ftplib import FTP  
import os,sys,string,datetime,time  
import socket  
  
class MYFTP:  
    def __init__(self, hostaddr, username, password, remotedir, port=21):  
        self.hostaddr = hostaddr  
        self.username = username  
        self.password = password  
        self.remotedir  = remotedir  
        self.port     = port  
        self.ftp      = FTP()  
        self.file_list = []  
        # self.ftp.set_debuglevel(2)  
    def __del__(self):  
        self.ftp.close()  
        # self.ftp.set_debuglevel(0)  
    def login(self):  
        ftp = self.ftp  
        try:   
            timeout = 60  
            socket.setdefaulttimeout(timeout)  
            ftp.set_pasv(True)  
            print '開始連接到 %s' %(self.hostaddr)  
            ftp.connect(self.hostaddr, self.port)  
            print '成功連接到 %s' %(self.hostaddr)  
            print '開始登錄到 %s' %(self.hostaddr)  
            ftp.login(self.username, self.password)  
            print '成功登錄到 %s' %(self.hostaddr)  
            debug_print(ftp.getwelcome())  
        except Exception:  
            deal_error("連接或登錄失敗")  
        try:  
            ftp.cwd(self.remotedir)  
        except(Exception):  
            deal_error('切換目錄失敗')  
  
    def is_same_size(self, localfile, remotefile):  
        try:  
            remotefile_size = self.ftp.size(remotefile)  
        except:  
            remotefile_size = -1  
        try:  
            localfile_size = os.path.getsize(localfile)  
        except:  
            localfile_size = -1  
        debug_print('lo:%d  re:%d' %(localfile_size, remotefile_size),)  
        if remotefile_size == localfile_size:  
            return 1  
        else:  
            return 0  
    def download_file(self, localfile, remotefile):  
        if self.is_same_size(localfile, remotefile):  
            debug_print('%s 文件大小相同，無需下載' %localfile)  
            return  
        else:  
            debug_print('>>>>>>>>>>>>下載文件 %s ... ...' %localfile)  
        #return  
        file_handler = open(localfile, 'wb')  
        self.ftp.retrbinary('RETR %s'%(remotefile), file_handler.write)  
        file_handler.close()  
  
    def download_files(self, localdir='./', remotedir='./'):  
        try:  
            self.ftp.cwd(remotedir)  
        except:  
            debug_print('目錄%s不存在，繼續(xù)...' %remotedir)  
            return  
        if not os.path.isdir(localdir):  
            os.makedirs(localdir)  
        debug_print('切換至目錄 %s' %self.ftp.pwd())  
        self.file_list = []  
        self.ftp.dir(self.get_file_list)  
        remotenames = self.file_list  
        #print(remotenames)  
        #return  
        for item in remotenames:  
            filetype = item[0]  
            filename = item[1]  
            local = os.path.join(localdir, filename)  
            if filetype == 'd':  
                self.download_files(local, filename)  
            elif filetype == '-':  
                self.download_file(local, filename)  
        self.ftp.cwd('..')  
        debug_print('返回上層目錄 %s' %self.ftp.pwd())  
    def upload_file(self, localfile, remotefile):  
        if not os.path.isfile(localfile):  
            return  
        if self.is_same_size(localfile, remotefile):  
            debug_print('跳過[相等]: %s' %localfile)  
            return  
        file_handler = open(localfile, 'rb')  
        self.ftp.storbinary('STOR %s' %remotefile, file_handler)  
        file_handler.close()  
        debug_print('已傳送: %s' %localfile)  
    def upload_files(self, localdir='./', remotedir = './'):  
        if not os.path.isdir(localdir):  
            return  
        localnames = os.listdir(localdir)  
        self.ftp.cwd(remotedir)  
        for item in localnames:  
            src = os.path.join(localdir, item)  
            if os.path.isdir(src):  
                try:  
                    self.ftp.mkd(item)  
                except:  
                    debug_print('目錄已存在 %s' %item)  
                self.upload_files(src, item)  
            else:  
                self.upload_file(src, item)  
        self.ftp.cwd('..')  
  
    def get_file_list(self, line):  
        ret_arr = []  
        file_arr = self.get_filename(line)  
        if file_arr[1] not in ['.', '..']:  
            self.file_list.append(file_arr)  
              
    def get_filename(self, line):  
        pos = line.rfind(':')  
        while(line[pos] != ' '):  
            pos += 1  
        while(line[pos] == ' '):  
            pos += 1  
        file_arr = [line[0], line[pos:]]  
        return file_arr  
def debug_print(s):  
    print (s)  
def deal_error(e):  
    timenow  = time.localtime()  
    datenow  = time.strftime('%Y-%m-%d', timenow)  
    logstr = '%s 發(fā)生錯誤: %s' %(datenow, e)  
    debug_print(logstr)  
    file.write(logstr)  
    sys.exit()  
  
if __name__ == '__main__':  
    file = open("log.txt", "a")  
    timenow  = time.localtime()  
    datenow  = time.strftime('%Y-%m-%d', timenow)  
    logstr = datenow  
    # 配置如下變量  
    hostaddr = 'localhost' # ftp地址  
    username = 'test' # 用戶名  
    password = 'test' # 密碼  
    port  =  21   # 端口號   
    rootdir_local  = '.' + os.sep + 'bak/' # 本地目錄  
    rootdir_remote = './'          # 遠(yuǎn)程目錄  
      
    f = MYFTP(hostaddr, username, password, rootdir_remote, port)  
    f.login()  
    f.download_files(rootdir_local, rootdir_remote)  
      
    timenow  = time.localtime()  
    datenow  = time.strftime('%Y-%m-%d', timenow)  
    logstr += " - %s 成功執(zhí)行了備份\n" %datenow  
    debug_print(logstr)  
      
    file.write(logstr)  
    file.close()  

posted on 2011-12-14 11:15 大龍閱讀(2754) 評論(0) 編輯收藏引用

只有注冊用戶登錄后才能發(fā)表評論。




網(wǎng)站導(dǎo)航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品