/usr/local/lib/python3.6/site-packages/fsspec/__pycache__
Edit: /usr/local/lib/python3.6/site-packages/fsspec/__pycache__/fuse.cpython-36.pyc (10110B)
3
8%Eg@' @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZmZ d dl m
Z
m Z m Z m
Z
d dlmZ d dlmZ ejdZG dd de
Zd d
d
efd d Zd
d Zedkrd dlZeejdd dS ) N)EIOENOENT)FUSE FuseOSError LoggingMixIn
Operations) __version__) url_to_fsz fsspec.fusec @ s| e Zd Zd ddZd ddZdd Zd d
Zd d Zd
d Zdd Z d ddZ
dd Z d ddZ dd Z
dd Zdd ZdS )!FUSErFc C s8 || _ i | _|jdd | _d| _tjd| || _d S )N/r zStarting FUSE at %s)fscacherstriprootcounterloggerinfo _ready_file)selfr path
ready_file r 5/usr/local/lib/python3.6/site-packages/fsspec/fuse.py__init__ s zFUSEr.__init__Nc C s t jd| | jr$|d kr$dddS dj| j|jdgjd}y| jj|}W n t k
rl t
t Y nX |j d d
|j d d
d }|j d
d}|d dkrt
j|B |d< d|d< d|d< n*t
j|B |d< |d |d< d |d< d|d< tj |d< tj |d< tj |d< |S ) Nz
getattr %s /.fuse_ready .fuse_readyfile )typest_size r uidi gid)st_uidst_gidmodei r st_moder r
st_blksizesize st_nlinkst_atimest_ctimest_mtime)r r i i P )r debugr joinr lstripr r r FileNotFoundErrorr r getstatS_IFDIRS_IFREGtime)r r fhr dataZpermr r r getattr s,
z
FUSEr.getattrc C sJ t jd| dj| j|jdg}| jj|d}dd |D }ddg| S ) Nz
readdir %sr r Fc S s g | ]}t jj|jd qS )r )osr basenamer ).0fr r r
: s z!FUSEr.readdir...z..)r r0 r1 r r2 r Zls)r r r9 filesr r r readdir6 s
z
FUSEr.readdirc C s& dj | j|jdg}| jj| dS )Nr r r )r1 r r2 r mkdir)r r r% r r r rD = s z FUSEr.mkdirc C s& dj | j|jdg}| jj| dS )Nr r r )r1 r r2 r rmdir)r r r r r rE B s z FUSEr.rmdirc C sF t jd|||f | jr$|dkr$dS | j| }|j| |j|}|S )Nzread %s /.fuse_ready .fuse_readys ready)rF rG )r r0 r r
seekread)r r r( offsetr9 r? outr r r rI G s
z
FUSEr.readc C s, t jd||f | j| }|j| t|S )Nzwrite %s)r r0 r
writelen)r r r: rJ r9 r? r r r rL R s
z FUSEr.writec C sd t jd||f dj| j|jdg}| jj| | jj|d}|| j| j < | j d7 _ | j d S )Nz create %sr r wbr+ )
r r0 r1 r r2 r touchopenr
r )r r flagsfifnr? r r r createX s z FUSEr.createc C sj t jd||f dj| j|jdg}|d dkr8d}nd}| jj||| j| j< | jd7 _| jd S ) Nzopen %sr r r) r rbrN r+ ) r r0 r1 r r2 r rP r
r )r r rQ rS r% r r r rP a s z
FUSEr.openc C s2 dj | j|jdg}|dkr"t| jj| d S )Nr r r )r1 r r2 NotImplementedErrorr rO )r r lengthr9 rS r r r truncaten s zFUSEr.truncatec C sN dj | j|jdg}y| jj|d W n ttfk
rH ttY nX d S )Nr r F) r1 r r2 r ZrmIOErrorr3 r r )r r rS r r r unlinku s
z FUSEr.unlinkc C s\ y,|| j kr*| j | }|j | j j| W n* tk
rV } zt| W Y d d }~X nX dS )Nr )r
closepop Exceptionprint)r r r9 r? er r r release| s
z
FUSEr.releasec C s8 t | jdr0dj| j|jdg}| jj||S td S )Nchmodr r )hasattrr r1 r r2 ra rV )r r r% r r r ra s z FUSEr.chmod)F)N)N)N)__name__
__module__ __qualname__r r; rC rD rE rI rL rT rP rX rZ r` ra r r r r r
s
r
TFc s^ fdd} s:t j|d}d|_|j |S y
| W n tk
rX Y nX dS )ai Mount stuff in a local directory
This uses fusepy to make it appear as if a given path on an fsspec
instance is in fact resident within the local file-system.
This requires that fusepy by installed, and that FUSE be available on
the system (typically requiring a package to be installed with
apt, yum, brew, etc.).
Parameters
----------
fs: file-system instance
From one of the compatible implementations
path: str
Location on that file-system to regard as the root directory to
mount. Note that you typically should include the terminating "/"
character.
mount_point: str
An empty directory on the local file-system where the contents of
the remote path will appear.
foreground: bool
Whether or not calling this function will block. Operation will
typically be more stable if True.
threads: bool
Whether or not to create threads when responding to file operations
within the mounter directory. Operation will typically be more
stable if False.
ready_file: bool
Whether the FUSE process is ready. The `.fuse_ready` file will
exist in the `mount_point` directory if True. Debugging purpose.
ops_class: FUSEr or Subclass of FUSEr
To override the default behavior of FUSEr. For Example, logging
to file.
c s t d dS )N)r )Z nothreads
foreground)r r )rf r mount_point ops_classr r threadsr r s zrun..)targetTN) threadingThreaddaemonstartKeyboardInterrupt) r r rg rf ri r rh functhr )rf r rg rh r r ri r run s ,
rs c s G fdddt j dtjd}|jddtd |jdtd d
|jd td d
|jd
tdd
|jddddd |jddtdd
|jddddd |jdd dd d |jd d dd d |j| } i }x| jpg D ]}|j d!\}}}|s|j
d"j |d# |j }|j
d$r0t|d%td$ }n"|j
d&rR|d%td& d2k}d*|kr|jd*d+\}} ||kr||| | < n | |i||< q|||< qW | jrtjtj| jd,d- G d.d/ d/tt}
|
} nt} t| jf|\} }
tjd0|
t| j t | | j | j| j | j | j | d1 d%S )3a Mount filesystem from chained URL to MOUNT_POINT.
Examples:
python3 -m fsspec.fuse memory /usr/share /tmp/mem
python3 -m fsspec.fuse local /tmp/source /tmp/local \
-l /tmp/fsspecfuse.log
You can also mount chained-URLs and use special settings:
python3 -m fsspec.fuse 'filecache::zip::file://data.zip' \
/ /tmp/zip \
-o 'filecache-cache_storage=/tmp/simplecache'
You can specify the type of the setting by using `[int]` or `[bool]`,
(`true`, `yes`, `1` represents the Boolean value `True`):
python3 -m fsspec.fuse 'simplecache::ftp://ftp1.at.proftpd.org' \
/historic/packages/RPMS /tmp/ftp \
-o 'simplecache-cache_storage=/tmp/simplecache' \
-o 'simplecache-check_files=false[bool]' \
-o 'ftp-listings_expiry_time=60[int]' \
-o 'ftp-username=anonymous' \
-o 'ftp-password=xieyanbo'
c s e Zd Z fddZ ZS )z*main..RawDescriptionArgumentParserc s0 t | j }|jd}| jj |d< dj|S )Nz
r+ )super format_helpsplit descriptionr r1 )r usageparts) RawDescriptionArgumentParser __class__r r ru s
z6main..RawDescriptionArgumentParser.format_help)rc rd re ru
__classcell__r )rz )r{ r rz s rz z fsspec.fuse)progrw z --versionversion)actionr~ urlzfs url)r help source_pathzsource directory in fsrg zlocal directoryz-oz--optionappendz3Any options of protocol included in the chained URL)r r z-lz
--log-filez%Logging FUSE debug info (Default: '')z-fz --foreground store_falsez-Running in foreground or not (Default: False)z-tz --threadsz-Running with threads support (Default: False)z-rz --ready-filezZThe `.fuse_ready` file will exist after FUSE is ready. (Debugging purpose, Default: False)=zWrong option: {!r})messagez[int]Nz[bool]1yestrue-r+ z%(asctime)s %(message)s)levelfilenameformatc @ s e Zd ZdS )zmain..LoggingFUSErN)rc rd re r r r r LoggingFUSEr, s r zMounting %s to %s)rf ri r rh )r r r )!argparseArgumentParsermain__doc__ add_argumentr str
parse_argsoption partitionerrorr lowerendswithintrM rv Zlog_filelogging basicConfigDEBUGr
r r r r r0 rg rs r rf ri r )argsparserkwargsitemkeysepvaluevalZfs_nameZ setting_namer Zfuserr Zurl_pathr )rz r r s~
r __main__r+ )r r r< r5 rl r8 errnor r Zfuser r r r Zfsspecr Z fsspec.corer getLoggerr r
rs r rc sysargvr r r r s(
7u