时间戳

首页 > 解决方案 > 在 FTP 中使用 Python 创建年/月/日文件夹结构

python - 在 FTP 中使用 Python 创建年/月/日文件夹结构

问题描述

我正在寻找使用 Python ftplib 模块创建年/月/日文件夹结构的选项

联系：

ftp = ftplib.FTP(ftp_servidor, ftp_usuario, ftp_clave)

加载变量：

ftp_raiz = 'TEST/'
filename = '2019-10-01T00-00-00.txt'

功能：

def cdTree(ftp, filename=None, path=None):

    if filename is not None:
        date = datetime.datetime.strptime(filename, '%Y-%m-%dT%H-%M-%S.txt')
        path = ftp_raiz + date.strftime('%Y') + '/' + date.strftime('%m') + '/' + date.strftime('%d')
        print filename
    if path != "":
        try:
            ftp.cwd(path)
        except error_perm as e:
            print e, ", creating folder"
            print path
            cdTree(ftp, path="/".join(path.split("/")[:-1]))
            ftp.mkd(path)
            ftp.cwd(path)

cdTree(ftp, filename, 'TEST')

最后我没有创建文件夹结构，它抛出了以下错误：

2018-10-18T00-00-00.txt
550 Failed to change directory. , creating folder
2018/10/18
550 Failed to change directory. , creating folder
2018/10
Traceback (most recent call last):
  File "ftp2.py", line 34, in <module>
    cdTree(ftp, filename)
  File "ftp2.py", line 30, in cdTree
    cdTree(ftp, path="/".join(path.split("/")[:-1]) )
  File "ftp2.py", line 31, in cdTree
    ftp.mkd(path)
  File "C:\python27\lib\ftplib.py", line 589, in mkd
    resp = self.sendcmd('MKD ' + dirname)
  File "C:\python27\lib\ftplib.py", line 251, in sendcmd
    return self.getresp()
  File "C:\python27\lib\ftplib.py", line 226, in getresp
    raise error_perm, resp
ftplib.error_perm: 550 Create directory operation failed.

注意：执行只创建一个文件夹的测试，它可以工作！

标签： pythonlinuxftpftplib

解决方案

我不确定这是否有帮助，但在 HDFS 文件系统上尝试了同样的方法，它帮助我解决了我的要求。可以在函数 generateDateFromThisYear() 中更改所需的输出

import datetime as d
import subprocess

def run_cmd(args_list):
    """
    run linux commands
    """
    # import subprocess
    print('Running system command: {0}'.format(' '.join(args_list)))
    proc = subprocess.Popen(args_list, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
    s_output, s_err = proc.communicate()
    s_return = proc.returncode
    return s_return, s_output, s_err

def hdfsMakedir(hdfs_file_path):
    (ret, out, err) = run_cmd(['hdfs', 'dfs', '-mkdir','-p', hdfs_file_path])



def make_necessary_dirs(dir_to_create: str):
    # print(pathExists(dir_to_create))
    if pathExists(dir_to_create) == 1:
        hdfsMakedir(dir_to_create)
        return dir_to_create
    else:
        return "the folder already exists"


list_of_dates =[]

def generateDateFromThisYear(year) :    

    months = [1,2,3,4,5,6,7,8,9,10,11,12]
    dt = "" #str(d.date(2012, 1, 1))
    for month in months:
        no_of_days = monthrange(year, month)[1] # Taking only second Value as it returns number of weeks and no of days 
        for day in range(1,no_of_days+1) :
            x = d.date(year,month,day)
            y= x.strftime("%Y")+'/'+x.strftime("%m")+'/'+x.strftime("%d")
            list_of_dates.append(y)

    for i in list_of_dates:
        make_necessary_dirs(i)

推荐阅读