L iddlZddlZddlZddlZddlZGddej ZGddejjZ y)Nc\eZdZdZdZd fd Zd dZd dZdZd dZ ddZ d Z dd Z xZ S)JupyterFileSystemz?View of the files as seen by a Jupyter server (notebook or lab))jupyterjlabc hd|vr1| tjd|d}|j ddd}|j ddz|_tj|_ |rd ||jjd <t|0d i|y#t$r}td|d}~wwxYw) aD Parameters ---------- url : str Base URL of the server, like "http://127.0.0.1:8888". May include token in the string, which is given by the process when starting up tok : str If the token is obtained separately, can be given here kwargs ?Nztoken=([a-z0-9]+)rzCould not determine token/z /api/contentsztoken Authorization) refindall IndexError ValueErrorsplitrstripurlrequestsSessionsessionheaderssuper__init__)selfrtokkwargse __class__s d/mnt/ssd/data/python-lab/Trading/venv/lib/python3.12/site-packages/fsspec/implementations/jupyter.pyrzJupyterFileSystem.__init__s #:{I**%8#>qAC))C#A&C::c?_4'') 6s##D) LL  z4&1 2 ==C #D) ) ffh x=F "I%%'A  Y0As|c |j|}|jddd|t|tj|j ddd}|j j|jd||y)Nr r r9r()r&r%sizer$r6r"r.) r)rsplitlenr9 b64encodedecoderputr)rr%value_r.s r pipe_filezJupyterFileSystem.pipe_fileLs{##D)KKQ'+J''.557   DHH:Qtf-D9r?c |j|}|r)d|vr%|j|jdddd|jddd|dddd}|jj |j d||y) Nr r rTrAr#)r&r%rBr$r"rC)r)mkdirrDrrHr)rr%create_parentsrr.s rrMzJupyterFileSystem.mkdirXs##D) cTk JJt{{3*1-t 4KKQ'+   DHH:Qtf-D9r?c l||k(ry|jj|jd|d|iy)Nr r%rC)rpatchr)rpath1path2 recursivemaxdepthrs rmvzJupyterFileSystem.mves6 E>  dhhZq0Gr?cz|j|}|jj|jd|y)Nr )r)rdeleter)rr%s r_rmzJupyterFileSystem._rmjs3##D) txxj$01r?c |j|}|dk(r&|j|}tj|St ||dS)Nrbwb)mode)r)r>ioBytesIOSimpleFileWriter)rr%r\rdatas r_openzJupyterFileSystem._opennsE##D) 4<==&D::d# ##D$T: :r?)N)T)NN)FN)rZ)__name__ __module__ __qualname____doc__protocolrr4r>rKrMrUrXra __classcell__)rs@rrr s4I"H#4(*  : :H 2;r?rceZdZddZy)r_c|dury|jjd|jj}|jj |j |y)zWNever uploads a chunk until file is done Not suitable for large files FrN)bufferseekreadfsrKr%)rfinalr`s r _upload_chunkzSimpleFileWriter._upload_chunkxsJ E> {{! $))T*r?N)F)rbrcrdror r?rr_r_ws +r?r_) r9r]r rfsspecAbstractFileSystemrspecAbstractBufferedFiler_r r?rrts?  j;11j;Z +v{{77 +r?