Как сохранить файлы с ftp-сервера, формируя пути на основе их имён?

# -*- coding: cp866 -*-
 
from ftplib import FTP
import sys, os, re, datetime
 
# Формирование текущего значения года и месяца
now = datetime.datetime.now()
yy = now.year
mm = now.month
dd = now.day
 
# Значение времени для лог-файла [год, месяц, день, час, мин, секунда]
now_time = str(now)
now_time = now_time[:-7]
 
# Функция записи в лог-файл всей информации
def log_all(text):
    logfile = './requests.log'
    file = open(logfile, 'a')
    print('['+now_time+'] ' + text)
    file.write('['+now_time+'] ' + text + '\n')
    file.close()
 
# Функция записи в лог-файл только новых файлов
def log_newfile(text):
    logfile = './new_files.log'
    file = open(logfile, 'a')
    print('['+now_time+'] ' + text)
    file.write('['+now_time+'] ' + text + '\n')
    file.close()
 
# Функция записи ошибок в лог-файл
def log_err(text):
    logfile = './errors.log'
    file = open(logfile, 'a')
    print('['+now_time+'] ' + text)
    file.write('['+now_time+'] ' + text + '\n')
    file.close()
 
# Параметры подклчения к ФТП серверу
host = '172.189.1.251'
user = 'ftpvipl'
passwd = '123'
 
# Соединение с сервером
try:
    ftp = FTP(host,user,passwd)
    ftp.__class__.encoding = sys.getfilesystemencoding()    #Декодировка текста для правильного отображения русских символов
 
    # Добавляем 0 к цифре месяца, если он меньше 10
    if mm < 10: mm = '0%s' % mm
    yy_mm = '%s%s%s%s' % (yy,'/',mm,'/')
    if dd < 10: dd = '0%s' % dd
 
    to_path = 'u:/otd/запити/'                              # Путь куда будут копироваться файлы
    ftp_path = '/all/pens/zapiti/'+yy_mm                    # Путь откуда будут копироваться файлы
    ftp.cwd(ftp_path)                    
 
    # Массив соответствия районов на ФТП сервере
    regions_list = {'6501':6510,'6502':6517,'6503':6503,'6504':6518,'6505':6516,
                    '6506':6506,'6507':6507,'6508':6513,'6509':6502,'6511':6501,
                    '6512':6520,'6513':6505,'6515':6508,'6516':6504,'6517':6509,
                    '6518':6519,'6519':6511,'6521':6512,'6522':6514,'6523':6523}
 
    listing = []
    ftp.dir(listing.append)
    listing_len = len(listing)
    i = 0
    for el in listing:
        if i in range(listing_len):
            words = listing[i].split(None, 8)
            filename = words[-1].lstrip()
            i+=1
 
            pattern = re.compile('(?P<from>[\d]{4}).?to.?(?P<to>[\d]{4})')
            m = pattern.search(filename)
            from_ = m.group('from')
            to_ = m.group('to')
            from_reg = '65' + from_[-2:]
            to_reg = '65' + to_[-2:]
            fFPath = os.path.join(ftp_path, filename)
        
            # Скачиваем файл
            local_filename = os.path.join(to_path, str(regions_list[to_reg])+'/'+yy_mm, filename)
            lf_dir = os.path.dirname(local_filename)
            if not os.path.exists(lf_dir): os.makedirs(lf_dir)      # Создание дерева каталогов, если их не существует
 
            filename_ = filename.split('.')
            if os.path.exists(lf_dir+'/'+filename_[0]+'.ok') or os.path.exists(local_filename):
                log_all(local_filename + ' уже обработан')
            else:
                lf = open(local_filename, "wb")
                ftp.retrbinary("RETR " + fFPath, lf.write, 8*1024)
                log_all(fFPath+' => '+local_filename)
                log_newfile(fFPath+' => '+local_filename)
                lf.close()
 
    # Закрываем соединение
    ftp.close()
# Обработка ошибок и запись в лог-файл
except Exception as err:                                
    log_all(str(err))
    log_err(str(err))