/usr/local/lib/python3.6/site-packages/fsspec/implementations/__pycache__
Edit: /usr/local/lib/python3.6/site-packages/fsspec/implementations/__pycache__/ftp.cpython-36.pyc (10444B)
3
8%Eg) @ s d dl Z d dlmZmZmZ d dlmZ ddlmZm Z ddl
m Z G dd de Z G d d
d
e
ZG d d d eZdddZdS ) N)FTPError
error_perm)Any )AbstractBufferedFileAbstractFileSystem)infer_storage_optionsc s e Zd ZdZdZdZdZd. fdd Zd
d Ze d d
Z
e dd Z d/ddZ
dd Zdd Zd0 fdd Zd1ddZd d Zd2d d Zd3eeedd d!d"Zd4eedd#d$d%Zd&d' Zd(d) Zd*d+ Zd5 fd,d- Z Z S )6
FTPFileSystemz A filesystem over classic FTP/Fftp N c
s\ t t| jf | || _|| _|p$d| _|||f| _|| _|dk rJ|| _nd| _| j dS )ae
You can use _get_kwargs_from_urls to get some kwargs from
a reasonable FTP url.
Authentication will be anonymous if username/password are not
given.
Parameters
----------
host: str
The remote server name/ip to connect to
port: int
Port to connect with
username: str or None
If authenticating, the user's identifier
password: str of None
User's password on the server, if using
acct: str or None
Some servers also need an "account" string for auth
block_size: int or None
If given, the read-ahead or write buffer size.
tempdir: str
Directory on remote to put temporary files when in a transaction
timeout: int
Timeout of the ftp connection in seconds
z/tmpNr i )
superr
__init__hostporttempdircredtimeout blocksize_connect)
selfr r usernamepasswordZacct
block_sizer r kwargs) __class__ D/usr/local/lib/python3.6/site-packages/fsspec/implementations/ftp.pyr s &
zFTPFileSystem.__init__c C s2 t | jd| _| jj| j| j | jj| j d S )N)r )r r r connectr r loginr )r r r r r B s zFTPFileSystem._connectc C s dt |d jdjd S )Nr path)r lstriprstrip)clsr# r r r _strip_protocolG s z FTPFileSystem._strip_protocolc C s$ t | }|jdd |jdd |S )Nr# protocol)r pop)Zurlpathoutr r r _get_kwargs_from_urlsK s z#FTPFileSystem._get_kwargs_from_urlsTc K sf | j |}g }|| jkr2yydd | jj|D }W n tk
rV t| j|}Y nX xn|D ]f\}}|dkrrd}dj||jdg|d< |d dkrt|d |d< nd |d< |d d
kr^d |d< q^W || j|< W n\ t k
r0 y&| j
|}|d dkr
||fg}W n t t fk
r* t Y nX Y nX | jj
||}|sXtd d |D S d
d |D S )Nc S s, g | ]$\}}|dkr|d dkr||fqS )...typepdircdir)r, r- )r/ r0 r ).0fndetailsr r r
Y s z$FTPFileSystem.ls..r namer. filesizer dir directoryc S s g | ] \}}|qS r r )r1 r2 r3 r r r r4 t s c S s g | ] \}}|qS r r )r1 r2 r3 r r r r4 u s )r' dircacher Zmlsdr _mlsd2joinr$ intr info
IndexErrorFileNotFoundErrorgetsorted) r r# Zdetailr r* r2 r3 r? filesr r r lsR s<
zFTPFileSystem.lsc sr | j dkr ddddS | j| j jdd}y fdd|D d }W n tk
rl t Y nX |S )Nr r r: )r6 r8 r. Tc s g | ]}|d kr|qS )r6 r )r1 f)r# r r r4 s z&FTPFileSystem.info..)r' rE _parentr$ r@ rA )r r# r rD r* r )r# r r? w s
zFTPFileSystem.infoc s> t |d* fdd}| jjd| | j|d W d Q R X d S )Nwbc s j | d S )N)write)x)outfiler r cb s z"FTPFileSystem.get_file..cbzRETR %s)r callback)openr
retrbinaryr )r ZrpathZlpathr rL r )rK r get_file s zFTPFileSystem.get_filec sP |d k r t j|||f|S g fdd}| jjd| | j||d dj S )Nc s j | d S )N)append)rJ )r* r r rL s z"FTPFileSystem.cat_file..cbzRETR %s)r restrM )r cat_filer rO r r= )r r# startendr rL )r )r* r rT s zFTPFileSystem.cat_filerbc K s, | j |}|p| j}t| |||| j||dS )N)moder r
autocommit
cache_options)r' r FTPFiler )r r# rX r rZ rY r r r r _open s
zFTPFileSystem._openc C s* | j |}| jj| | j| j| d S )N)r' r deleteinvalidate_cacherG )r r# r r r _rm s
zFTPFileSystem._rmc C sF | j |||d}x0t|D ]$}| j|r4| j| q| j| qW d S )N) recursivemaxdepth)Z expand_pathreversedisfileZrm_filermdir)r r# r` ra pathspr r r rm s
zFTPFileSystem.rm)r# create_parentsr returnc K s\ | j |}| j|}|| jkr<| j| r<|r<| j||d | jj| | j| j| d S )N)rh )r' rG root_markerexistsmkdirr Zmkdr^ )r r# rh r parentr r r rl s
zFTPFileSystem.mkdir)r# exist_okri c C s: | j |}| j|r(|s6t| dn| j|dd d S )Nz exists without `exist_ok`T)rh )r' rk FileExistsErrorrl )r r# rn r r r makedirs s
zFTPFileSystem.makedirsc C s* | j |}| jj| | j| j| d S )N)r' r Zrmdr^ rG )r r# r r r rd s
zFTPFileSystem.rmdirc K sF | j |}| j |}| jj|| | j| j| | j| j| d S )N)r' r renamer^ rG )r Zpath1Zpath2r r r r mv s
zFTPFileSystem.mvc C s | j j d S )N)r close)r r r r __del__ s zFTPFileSystem.__del__c s6 |d kr| j j n| j j|d tt| j| d S )N)r; clearr) r r
r^ )r r# )r r r r^ s z FTPFileSystem.invalidate_cache)r
NNNNNr )T)NN)rW NNT)FN)T)F)N) __name__
__module__ __qualname____doc__rj Zcachabler( r r classmethodr' staticmethodr+ rE r? rP rT r\ r_ rg strboolr rl rp rd rr rt r^
__classcell__r r )r r r
s< )
%
r
c @ s e Zd ZdZdS ) TransferDonez+Internal exception to break out of transferN)rv rw rx ry r r r r r s r c sD e Zd ZdZd fdd Zd d
Zd d Zd
d ZdddZ Z S )r[ z9Interact with a remote FTP file with read/write bufferingrW defaultT readaheadNc sN t j||f|||||d| |sJ| j| _dj|d ttj g| _d S )N)rX r rY
cache_typerZ r r )r r r# targetr= r| uuiduuid4) r fsr# rX r rY r rZ r )r r r r s zFTPFile.__init__c C s | j j| j| j d S )N)r rr r# r )r r r r commit s zFTPFile.commitc C s | j j| j d S )N)r rg r# )r r r r discard s zFTPFile.discardc s g dg fdd}y"j jjdj j|d W nP tk
r y j jj j jj W n tk
r j j Y nX Y nX dj
S )a Get bytes between given byte limits
Implemented by raising an exception in the fetch callback when the
number of bytes received reaches the requested amount.
Will fail if the server does not respect the REST command on
retrieve requests.
r c s~ d t | 7 < d krRj| d d jk r\tn
j| d krz jk rztd S )Nr )lenrQ r8 r )rJ )rV r* r rU totalr r rM s
z&FTPFile._fetch_range..callbackzRETR %s)r rR rM rS ) r r rO r# r r abortZ getmultiliner r r= )r rU rV rM r )rV r* r rU r r _fetch_range s zFTPFile._fetch_rangeFc C s2 | j jd | jjjd| j | j | j| jd dS )Nr zSTOR )r rR T)bufferseekr r Z
storbinaryr# r offset)r finalr r r
_upload_chunk= s zFTPFile._upload_chunk)rW r Tr N)F)
rv rw rx ry r r r r r r~ r r )r r r[ s )r[ r, c C s g }g }| j ||j x|D ]z}|j }|d dj|dd |d |d |d |d d f}d
|d d d krd |d d
< n d|d d
< |j| q W |S )a(
Fall back to using `dir` instead of `mlsd` if not supported.
This parses a Linux style `ls -l` response to `dir`, but the response may
be platform dependent.
Parameters
----------
ftp: ftplib.FTP
path: str
Expects to be given path, but defaults to ".".
r r )modifyz
unix.ownerz
unix.groupz unix.moder8 dz unix.moder9 r. r7 )r9 rQ splitr= )r r# linesZminfolinethisr r r r< E s
r< )r, )r ftplibr r r typingr specr r utilsr r
Exceptionr r[ r< r r r r s dS