`Vg dZddlmZddlmZmZddlZddlZddlZddl Z ddl Z ddl m Z m Z mZmZmZmZddlZddlZddlmZddlZddlZddlmZmZmZmZmZmZmZm Z m!Z!m"Z"ddl#m$Z$m%Z&m'Z'm(Z(m)Z)ddl*Z*ddl+Z+dd l,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3dd l4m5Z5dd l6m7Z7dd l8m9Z9dd l:m;Z;ddlZ>m?Z?m@Z@ddlAmBZBeCe)e'ze(zZDeDjdejdZGe de-ZHejGddZJejGddeeZKdKdZLe"dLdZMe"dMdZMdNdZMdOdZNe"dPdQdZOe" dP dRd ZO dS dTd"ZOd#ZPdUd$ZQe9eBd%eBd&dz' dV dWd(ZRdXd)ZSd*d*d*d*d+d,d-d.d/d0 ZTeCeTjZV dYd1ZWe9eBd&dz2 dZd3ZXd[d4ZYe"dddddd5 d\d7ZZe"ddddddd8 d]d9ZZe"ddddddd8 d^d:ZZe9eBd&d6z2ddd!d;ddd8 d^d<ZZGd=d>e eZ[Gd?d@e[Z\GdAdBe[Z]GdCdDZ^GdEdFZ_ d_dGZ`d`dHZadadIZbe jdbdJZdy)czCommon IO api utilities) annotations)ABCabstractmethodN)BufferedIOBaseBytesIO RawIOBaseStringIO TextIOBase TextIOWrapper)Path) IOAnyAnyStrGenericLiteralMappingSequenceTypeVarcastoverload)urljoinurlparse uses_netloc uses_params uses_relative) BaseBufferCompressionDictCompressionOptionsFilePath ReadBufferStorageOptions WriteBuffer) get_lzma_file)import_optional_dependency)doc)find_stack_level)is_bool is_file_like is_integer is_list_like) _shared_docsz^[A-Za-z][A-Za-z0-9+\-+.]*:// BaseBufferT)boundcHeZdZUdZded<ded<ded<ded<d Zd ed <y ) IOArgsz? Return value of io/common.py:_get_filepath_or_buffer. str | BaseBufferfilepath_or_bufferstrencodingmoder compressionFbool should_closeN)__name__ __module__ __qualname____doc____annotations__r8Q/var/www/html/hubwallet-dev/venv/lib/python3.12/site-packages/pandas/io/common.pyr0r0Ns))(M I  L$r?r0c|eZdZUdZded<ded<ej eZded<d Z d ed <dd Z dd Z ddZ y) IOHandlesau Return value of io/common.py:get_handle Can be used as a context manager. This is used to easily close created buffers and to handle corner cases when TextIOWrapper is inserted. handle: The file handle to be used. created_handles: All file handles that are created by get_handle is_wrapped: Whether a TextIOWrapper needs to be detached. z IO[AnyStr]handlerr6)default_factoryzlist[IO[bytes] | IO[str]]created_handlesFr7 is_wrappedcd|jrut|jtsJ|jj |jj |j j|j|j D]}|jg|_d|_y)z Close all created buffers. Note: If a TextIOWrapper was inserted, it is flushed and detached to avoid closing the potentially user-created buffer. FN) rF isinstancerCr flushdetachrEremoveclose)selfrCs r@rLzIOHandles.closeps ??dkk=9 99 KK    KK    ' ' 4** F LLN !r?c|SNr>rMs r@ __enter__zIOHandles.__enter__s r?c$|jyrO)rL)rMargss r@__exit__zIOHandles.__exit__s  r?NreturnNone)rVzIOHandles[AnyStr])rSrrVrW) r9r:r;r<r= dataclassesfieldlistrErFrLrQrTr>r?r@rBrB[sG    1B1B1BSW1XO.XJ "r?rBcZt|tsyt|jtvS)z Check to see if a URL has a valid protocol. Parameters ---------- url : str or unicode Returns ------- isurl : bool If `url` has a valid protocol return True otherwise False. F)rHr3 parse_urlscheme _VALID_URLSurls r@is_urlras& c3  S> K //r?r2cyrOr>r2s r@ _expand_userrdr?cyrOr>rcs r@rdrdrer?cdt|trtjj |S|S)a] Return the argument with an initial component of ~ or ~user replaced by that user's home directory. Parameters ---------- filepath_or_buffer : object to be converted if possible Returns ------- expanded_filepath_or_buffer : an expanded filepath or the input if not expandable )rHr3ospath expanduserrcs r@rdrds+$c*ww!!"455 r?c`|yt|r!tt|}|dkr tdyt |drRtt |}t tt|s tdtd|Dr tdyt|r tdtd) NrzUPassing negative integer to header is invalid. For no header, use header=None insteadF) allow_setsz*header must be integer or list of integersc3&K|] }|dk yw)rNr>).0is r@ z&validate_header_arg..s%q1u%sz8cannot specify multi-index header with negative integerszPassing a bool to header is invalid. Use header=None for no header or header=int or list-like of ints to specify the row(s) making up the column names) r)rint ValueErrorr*rallmapanyr' TypeError)headers r@validate_header_argrxs ~&c6" A:9  Fu-h'3z6*+IJ J %f% %WX Xv 4  A BBr?.cyrOr>r2convert_file_likes r@stringify_pathr|rer?cyrOr>rzs r@r|r|sr?Fc|st|rtt|St|tj r|j }t|S)a Attempt to convert a path-like object to a string. Parameters ---------- filepath_or_buffer : object to be converted Returns ------- str_filepath_or_buffer : maybe a string version of the object Notes ----- Objects supporting the fspath protocol (python 3.6+) are coerced according to its __fspath__ method. Any other object is passed through unchanged, which includes bytes, strings, buffers, or anything else that's not even path-like. )r(rr-rHrhPathLike __fspath__rdrzs r@r|r|sI. .@!AK!344$bkk2/::< * ++r?cBddl}|jj|i|S)z` Lazy-import wrapper for stdlib urlopen, as that imports a big chunk of the stdlib. rN)urllib.requestrequesturlopen)rSkwargsurllibs r@rrs#  !6>> ! !4 26 22r?ct|txr2ttj |xr|j d S)zR Returns true if the given URL looks like something fsspec can handle )zhttp://zhttps://)rHr3r7_RFC_3986_PATTERNmatch startswithr_s r@ is_fsspec_urlr sA 3 8 "((- . 867 7r?storage_optionscompression_options)rrc&t|}t|\}}t||}|r6t|dr*d|vr&t j dt td}t||}d|vr1|dvr-|d vr)t j |d |tt|}d |vr d|vr|dz }t|trt|r|xsi}d dl }|jj|| }t!|5} | j"j%dd} | dk(rddi}t'| j)} dddt+ ||d|St-|rt|tsJ|j/dr|j1dd}|j/dr|j1dd}t3d} g} t3dd dlm}m}||t:g} | j>|fd|i|xsij?}t+|||d|S|r tCdt|ttDtFjFfrt+tI|||d|St|ds%t|dsdtK|}tC|t+|||d|S#1swYkxYw#t<$rYwxYw#tA| $rB|ddi}nt|}d|d<| j>|fd|i|xsij?}YwxYw)a% If the filepath_or_buffer is a url, translate and return the buffer. Otherwise passthrough. Parameters ---------- filepath_or_buffer : a url, filepath (str, py.path.local or pathlib.Path), or buffer {compression_options} .. versionchanged:: 1.4.0 Zstandard support. encoding : the encoding to use to decode bytes, default is 'utf-8' mode : str, optional {storage_options} .. versionadded:: 1.2.0 ..versionchange:: 1.2.0 Returns the dataclass IOArgs. writebzDcompression has no effect when passing a non-binary object as input.) stacklevelN)methodw)bz2xz)zutf-16zutf-32z( will not write the byte order mark for tr)headerszContent-EncodinggziprT)r2r4r6r8r5zs3a://zs3://zs3n://fsspecbotocore) ClientErrorNoCredentialsErrorr5anonz?storage_options passed with file object or non-fsspec file pathFreadz)Invalid file path or buffer object type: )&r|get_compression_methodinfer_compressionhasattrwarningswarnRuntimeWarningr&dictUnicodeWarningrHr3rarrRequestrrgetrrr0rrreplacer$botocore.exceptionsrrPermissionError ImportErroropentuplerrbytesmmaprdtype)r2r4r6r5rcompression_method fsspec_moderreq_inforeqcontent_encodingreaderrerr_types_to_retry_with_anonrrfile_objmsgs r@_get_filepath_or_bufferrsD((:;'=[&I# *+=?QRg&8'BsRV R ') "{+=>K t - / , , mCH: N ') K +#["8s $c*v6H/I*/R >>))*+,>?#    "F+w7I7/S9$?Q:R9STo -   u ) )T   12 &#)4.#'"7*.'"v{{")49H9NBdf  s1RVW,c2'@&E&E&G # "I{!'')229="" #--dOf%<= =E )+7'',g / S/r?clt|j}|jstd|dy)z Check if parent directory of a file exists, raise OSError if it does not Parameters ---------- path: Path or str Path to check parent directory of z1Cannot save file into a non-existent directory: ''N)r parentis_dirOSError)rirs r@check_parent_directoryrJs7$Z  F ==?J6(RSTUU r?)r4r6 memory_maperrorsr path_or_bufcyrOr>rr5r4r6ris_textrrs r@ get_handlerXr?)r4r6rrrrcyrOr>rs r@rrgrr?cyrOr>rs r@rrvrr?Tc |xsd}|xsd}t||r d|vr|dz }tj|t|trtj |t |||||}|j} t| |\} }} t| t} t|j} | jd}d|vr| rtt | |r<|dk7r"|jjdd |_ n(|dk(r#d|jvr|xjdz c_ |d k(rXt| tr$tj d)| |jd | } ntj d)| |jd | } nl|d k(r$t#j$| fd|ji| } nC|dk(rt'| |jfi| } | j(jdk(r | j+| | j(j-} t/| dk(r+| j(j1| j} n| st3d|t3d| |dk(r| j5d|jt| trt7d)d| i| } n t7d)d| i| } t| t6sJd| j(jvr| j+| | j(j9}t/|dk(r%| j(j;|d}|J|} n|st3d|t3d||dk(rt=| |j} nw|dk(rbt?d}d|jvrd|j@d)i| i}nd|jBd)i| i}|j0| fd|ji|} nd|}t3|t| trJ| j+| nvt| trf|jDr3d|jvr%t1| |j|jD|d } nt1| |j} | j+| d}|s7|jd k(r(t| tFrtI| |jD!} n|r|s|st| |jrtK| d"rtK| d#r tK| d$s tM| } tO| |jD|d } | j+| t|jtxs |jP }d|jvr.tK| d%s"tSd&tU|jd'| jW|jPr7t|jtrJ| j+|jtY| | ||j(S)*a Get file handle for given path/buffer and mode. Parameters ---------- path_or_buf : str or file handle File path or object. mode : str Mode to open path_or_buf with. encoding : str or None Encoding to use. {compression_options} .. versionchanged:: 1.0.0 May now be a dict with key 'method' as compression mode and other keys as compression options if compression mode is 'zip'. .. versionchanged:: 1.1.0 Passing compression options as keys in dict is now supported for compression modes 'gzip', 'bz2', 'zstd' and 'zip'. .. versionchanged:: 1.4.0 Zstandard support. memory_map : bool, default False See parsers._parser_params for more information. Only used by read_csv. is_text : bool, default True Whether the type of the content passed to the file/buffer is string or bytes. This is not the same as `"b" not in mode`. If a string content is passed to a binary file/buffer, a wrapper is inserted. errors : str, default 'strict' Specifies how encoding and decoding errors are to be handled. See the errors argument for :func:`open` for a full list of options. storage_options: StorageOptions = None Passed to _get_filepath_or_buffer .. versionchanged:: 1.2.0 Returns the dataclass IOHandles utf-8strictr)r4r6r5rrrrrr,r)filenamer5)fileobjr5rr5rzZero files found in ZIP file z9Multiple files found in ZIP file. Only one file per ZIP: rnamerrz Zero files found in TAR archive zDMultiple files found in TAR archive. Only one file per TAR archive: r zstandarddctxcctxr)r4rnewlineFrb)r4readablewritableseekablerz1Expected file path name or file-like object, got z type)rCrErFr6r>)-_is_binary_modecodecslookuprHr3 lookup_errorrr2_maybe_memory_maprr6rrr5rrGzipFilerBZ2File _BytesZipFilebufferappendnamelistlenrrr setdefault _BytesTarFilegetnames extractfiler#r$ZstdDecompressorZstdCompressorr4r _BytesIOWrapperr _IOWrapperr r8rvrreverserB)rr5r4r6rrrrioargsrChandlesis_pathr zip_namesfilesfiler open_argsrrFs r@rrsl"7H  xF{D)co   MM(&#F#% ' F & &F #4FJ"GFJ%GF../"&&x0K $7s6{+ &  ++--c26FK F "s&++'= KK3 K & &#&#' #  ' E ![[[[#FE !# '7F}}!!S(v&"MM224 y>Q&#]]// @F"$'D[M%RSS$22;> E !  ' ' <&#&&GFG6FG '"&6fm4 44fmm(((v& ..0u:?!==44U1X>D+++!F$'G }%UVV$::?B D %]_VV[[9FF "-k:Dfkk!#%:T%:%:%N=M%NO #%8T%8%8%L;K%LM TYY[[F4K=ACS/ !fc***v FC  ??s&++5  F&&++.FvJ v{{d*z&*/M __  z_VV[[%I +6:.6:.'F __   v v00# 6 M&:M:M  fkk'&&"9 11235 :   OO f77===v001  &&  r?c6eZdZdZeddZdfd ZxZS)_BufferedWriterz Some objects do not support multiple .write() calls (TarFile and ZipFile). This wrapper writes to the underlying buffer on close. cyrOr>rPs r@write_to_bufferz_BufferedWriter.write_to_buffers r?c|jry|jr7|jd|j5|j dddn|jj t |y#1swYxYw)Nr)closedgetvalueseekrrrLsuper)rM __class__s r@rLz_BufferedWriter.closesi ;;  ==? IIaL '$$& ' ' KK       ' 's A??BrU)r9r:r;r<rrrL __classcell__rs@r@rrs&     r?rcTeZdZ d dfd ZddZddZd dZxZS) rc t|||_||_t j j d||j||d||_y)N)rr5rr>) r__init__ archive_namertarfileTarFiler extend_moder)rMrr5rr%rrs r@r$z_BytesTarFile.__init__sZ ( oo** !!$'    r?c|jdd}|dk7r|S|j-t|jj}|dvr |d|dd}|S)Nrr,r)rrr:r)rrr suffix)rMr5r+s r@r(z_BytesTarFile.extend_modes_||C$ 3;K 99 $))_++F//q - r?c"|jyt|j}|jdk(r|jdjS|jdvr*|jdjdjS|jS)z If an explicit archive_name is not given, we still want the file inside the zip file not to be named something.tar, because that causes confusion (GH39465). Nrr,)rrr)rr r+ with_suffixrMrs r@infer_filenamez_BytesTarFile.infer_filenamesz 99  ? ??f $''+00 0 __ B B''+77;@@ @}}r?c|jxs|jxsd}tj|}t |j |_|jj||y)Nr)r) r%r/r&TarInforrsizeraddfile)rMr%tarinfos r@rz_BytesTarFile.write_to_buffersT((JD,?,?,AJU //|44==?+  GT*r?)NrNN) r str | Noner5zLiteral['r', 'a', 'w', 'x']rz-ReadBuffer[bytes] | WriteBuffer[bytes] | Noner%r5rVrW)r5r3rVr3rVr5rU)r9r:r;r$r(r/rr r!s@r@rrsU ,/AE#'   * ?  !    * +r?rcBeZdZ d dfd ZddZddZxZS)rc t||jdd}||_|j dt j t j||fi||_y)Nrr,r6) rr$rr%rzipfile ZIP_DEFLATEDZipFiler)rMrr5r%rrs r@r$z_BytesZipFile.__init__sW ||C$(-)=)=>oodD;F; r?ct|jjtjt frUt |jj}|jdk(r|jdjS|jSy)z If an explicit archive_name is not given, we still want the file inside the zip file not to be named something.zip, because that causes confusion (GH39465). rr,N) rHrrrhrr3r r+r-rr.s r@r/z_BytesZipFile.infer_filenamese dkk**R[[#,> ?DKK001H&(++B/444== r?c|jxs|jxsd}|jj||j y)Nr)r%r/rwritestrr)rMr%s r@rz_BytesZipFile.write_to_buffer s:((JD,?,?,AJU  \4==?;r?rO)rz1FilePath | ReadBuffer[bytes] | WriteBuffer[bytes]r5r3r%r5rVrWr6rU)r9r:r;r$r/rr r!s@r@rrs= $( <?<<! <  <" r?r@r r s*  r?r c(eZdZdddZddZdd dZy) r c.||_||_d|_y)Nr?)rr4overflow)rMrr4s r@r$z_BytesIOWrapper.__init__4s    r?c.t|j|SrOrB)rMattrs r@rDz_BytesIOWrapper.__getattr__=rEr?c|jJ|jj|j|j}|j|z}||dks|t |k\r d|_|S|d|}||d|_|S)Nrr?)rrencoder4rLr)rMn bytestringcombined_bytestring to_returns r@rz_BytesIOWrapper.read@s{{&&&[[%%a(// > "mmj8 9Ac*=&>!>DM& &+BQ/I/3DM r?N)r)rzStringIO | TextIOBaser4r3rVrW)rNr3))rQz int | NonerVr)r9r:r;r$rDrr>r?r@r r 1s* r?r cg}|t|dxst|tz}|s|||fSt|trt|d}|j | t t j |jdt j}t|D]}|j |||gfS#t|D]}|jwxYw)zTry to memory map file/buffer.filenorr)access) rrHr3rrr rrW ACCESS_READreversedrL)rCrrwrappeds r@rrNs!#G'&(+Fz&#/FFJ z7**&#fd#v  II 4+;+;   w' F LLN  J )) w' F LLN s =B=="Ccd}t|}t|ts|S tjj |}|S#t tf$rY|SwxYw)zTest whether file exists.F)r|rHr3rhriexistsrvrr)r2r]s r@ file_existsr^ms` F'(:; (# .   23 M z "  M sAAAcd|vsd|vrd|vStjtjtjf}t t ||ryt |txsdt|d|vS)z+Whether the handle is opened in binary moderrFr5) r StreamWriter StreamReaderStreamReaderWriter issubclassrrH_get_binary_io_classesrC)rCr5 text_classess r@rr{s d{cTkd{ !! L $v, - f46 7 3'C<r?cttf}tdd}|9|jj d5}|t |fz }ddd|S|S#1swY|SxYw)z!IO classes that that expect bytesrignore)rNr?)rrr$r  stream_readerr)binary_classesrrs r@rdrdsp)7 'BN &k( CD   " " $ 2 23 7 .6 tF|o -N . > . s AA!)r`objectrVr7)r2r3rVr3)r2r-rVr-)r2str | BaseBufferTrVrk)rwrjrVrW).)r2rr{r7rVr3)r2r-r{r7rVr-)F)r2zFilePath | BaseBufferTr{r7rVrk)r`FilePath | BaseBufferrVr7)rNrN) r2rlr4r3r6rr5r3rr!rVr0)rir3rVr3)r6rrVz"tuple[str | None, CompressionDict])r2rlr6r5rVr5)riz Path | strrVrW)rrlr5r3r4r5r6rrr7rzLiteral[False]rr5rr!rVzIOHandles[bytes])rrlr5r3r4r5r6rrr7rz Literal[True]rr5rr!rVzIOHandles[str])rrlr5r3r4r5r6rrr7rr7rr5rr!rVz!IOHandles[str] | IOHandles[bytes])rCr1rr7rVz/tuple[str | BaseBuffer, bool, list[BaseBuffer]])r2rlrVr7)rCrlr5r3rVr7)rVztuple[type, ...])er< __future__rabcrrrrrX functoolsriorrrr r r rrhpathlibr rer&typingr rrrrrrrrr urllib.parserrr\rrrrr9pandas._typingrrrrr r!r" pandas.compatr#pandas.compat._optionalr$pandas.util._decoratorsr%pandas.util._exceptionsr&pandas.core.dtypes.commonr'r(r)r*pandas.core.shared_docsr+setr^discardcompilerr- dataclassr0rBrardrxr|rrrrrvaluesrrrrrrrrr r rr^r lru_cacherdr>r?r@rsc"       (>'41-+- ;< BBJJ?@m:6      )))X0$    &C:   ?B#8< $,.,,,D3  !23$%:;>RR &*&* o-oo$o  o $ o  o od0&       7>>@A 0# 0' 0F&;:* **.*4*> * r?