解决python fs(filesystem)库在连接FTP服务器时无法显示文件目录的问题

Posted 蓬stephen蓬

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了解决python fs(filesystem)库在连接FTP服务器时无法显示文件目录的问题相关的知识,希望对你有一定的参考价值。

本文由Markdown语法编辑器编辑完成.

1. 问题提出:

目前有一个需求是:医院的影像数据是存储在FTP服务器上的,医院提供了连接该FTP服务器的host, user, password等参数.(注:该ftp服务是部署在windows操作系统的IIR服务上)
采用的python库是fs(filesystem2)的第三方库.fs==2.0.23版本.
在根据提供的参数,可以正常的连接到该ftp服务器,但是在显示该ftp服务器下的文件目录时,却显示为空.但是,该ftp服务器下的确是有文件夹的.

之前在连接别的医院的ftp服务器时,是可以正常显示ftp服务器下的文件目录的.

通过跟踪代码,发现是由于fs库的内部的一个函数实现,在解析服务器返回的字符串时,返回为空,而导致后续无法检索到文件夹.

定位到的函数是:fs.ftpfs下的_ftp_parse()函数.
IIR服务器返回的lines是:

[
  ‘01-20-19 04:23AM < DIR > 104794_CT‘,
  ‘01-20-19 04:22AM < DIR > 104794_SR‘,
   ‘01-19-19 07:45AM < DIR > 104795_CT‘,
   ‘01-19-19 07:43AM < DIR > 104795_SR‘,
   ‘01-15-19 07:49AM < DIR > 104796_CT‘,
   ‘01-14-19 07:47AM < DIR > 104796_SR‘,
   ‘01-13-19 08:44AM < DIR > 104797_CT‘
 ]

在运行:
python _list = [Info(raw_info) for raw_info in ftp_parse.parse(lines)]
后,_list为[], 因此后续无法检索到图像.

2. 问题分析:

要想解决这个问题,需要对比之前可以正常显示ftp服务器下的文件目录和这里的区别.
通过debug代码发现,当ftp服务是部署在linux服务器时,程序运行到上面的位置时,lines的值的格式为:

[
  u‘drwxr-xr-x    2 ftp      ftp         69632 Jan 30 03:51 3177498‘, 
  u‘drwxr-xr-x    2 ftp      ftp         73728 Jan 30 03:51 3177512‘, 
  u‘drwxr-xr-x    2 ftp      ftp         77824 Jan 30 03:52 3177517‘, 
  u‘drwxr-xr-x    2 ftp      ftp         73728 Jan 30 03:52 3177529‘
]

而fs中解析这个lines的代码为_ftp_parse.py:

re_linux = re.compile(
    """
    ^
    ([ldrwx-]{10})
    s+?
    (d+)
    s+?
    ([w-]+)
    s+?
    ([w-]+)
    s+?
    (d+)
    s+?
    (w{3}s+d{1,2}s+[w:]+)
    s+
    (.*?)
    $
    """,
    re.VERBOSE
)

def get_decoders():
    decoders = [
        (re_linux, decode_linux)
    ]
    return decoders


def parse(lines):
    info = []
    for line in lines:
        if not line.strip():
            continue
        raw_info = parse_line(line)
        if raw_info is not None:
            info.append(raw_info)
    return info


def parse_line(line):
    for line_re, decode_callable in get_decoders():
        match = line_re.match(line)
        if match is not None:
            return decode_callable(line, match)
    return None

def decode_linux(line, match):
    perms, links, uid, gid, size, mtime, name = match.groups()
    is_link = perms.startswith(‘l‘)
    is_dir = perms.startswith(‘d‘) or is_link
    if is_link:
        name, _, _link_name = name.partition(‘->‘)
        name = name.strip()
        _link_name = _link_name.strip()
    permissions = Permissions.parse(perms[1:])

    mtime_epoch = _parse_time(mtime)

    name = unicodedata.normalize(‘NFC‘, name)

    raw_info = {
        "basic": {
            "name": name,
            "is_dir": is_dir
        },
        "details": {
            "size": int(size),
            "type": int(
                ResourceType.directory
                if is_dir else
                ResourceType.file
            )
        },
        "access": {
            "permissions": permissions.dump()
        },
        "ftp": {
            "ls": line
        }
    }
    access = raw_info[‘access‘]
    details = raw_info[‘details‘]
    if mtime_epoch is not None:
        details[‘modified‘] = mtime_epoch

    access[‘user‘] = uid
    access[‘group‘] = gid

    return raw_info

从fs的源码中可以看出,_ftp_parse.py中的get_decoders()函数中,decoders这个变量数组中,只提供了一组解码器,即内部的 (re_linux, decode_linux). 因此,当ftp服务器不是部署在linux操作系统上,而是部署在windows等其他操作系统上时,ftp返回的字符串格式,就不再符合解码器中的正则表达式.

因此,要修改这个问题,就需要根据当前IIR服务器返回的字符串的格式,撰写相应的正则表达式来解码,然后加入到_ftp_parse.py中的decoders数组中.

要解决这个问题,就需要对python中的正则表达式有一定的了解.相关的教程可以阅读:正则表达式.
https://www.liaoxuefeng.com/wiki/001374738125095c955c1e6d8bb493182103fac9270762a000/001386832260566c26442c671fa489ebc6fe85badda25cd000

3. 解决方案:

在了解了正则表达式的规范后,模拟re_linux和decode_linux的函数,可以增加re_windows和decode_windows这两个函数.增加后的函数如下:

re_windows = re.compile(
    """
    ^
    ([w-]{8}s+[w:]+)
    s+?
    (<DIR>)
    s+?
    (.*?)
    $
    """,
    re.VERBOSE
)

def decode_windows(line, match):
    mtime, dir, name = match.groups()
    name = name.strip()
    raw_info = {
        "basic": {
            "name": name,
            "is_dir": True
        },
        "ftp": {
            "ls": line
        }
    }
    return raw_info

def get_decoders():
    decoders = [
        (re_linux, decode_linux),
        #这个解码组合是新增的,针对windows操作系统的解码器.
        (re_windows, decode_windows)
    ]
    return decoders

当然,这里的正则表达式是根据之前返回的字符串来撰写的.如果返回的字符串和文章中开头的字符串样式不同,还需要另外修改正则表达式.








以上是关于解决python fs(filesystem)库在连接FTP服务器时无法显示文件目录的问题的主要内容,如果未能解决你的问题,请参考以下文章

转载解决No FileSystem for scheme: hdfs问题

找不到 Spark 和 Cassandra Java 应用程序异常提供程序 org.apache.hadoop.fs.s3.S3FileSystem

类 org.apache.hadoop.fs.s3native.NativeS3FileSystem 未找到(Spark 1.6 Windows)

ubuntu 18.10 上的 std::filesystem 链接错误 [重复]

flume出现org.apache.hadoop.fs.UnsupportedFileSystemException: No FileSystem for scheme “hdfs“

Hadoop之HDFS的FileSystem接口详解