(phNSrSSKrSSKJr SSKJr SSKJr SrSr1Skr 1S kr "S S \R5r "S S \R5r "SS\5rg)zFModule for file-like access of blobs, usually invoked via Blob.open().N)RequestRangeNotSatisfiable) DEFAULT_RETRY)ConditionalRetryPolicyii>retrytimeout raw_downloadif_generation_matchif_generation_not_matchif_metageneration_matchif_metageneration_not_match> rrchecksum content_typepredefined_aclr r r r cl\rSrSrSrS\4SjrSSjrSSjrSSjr Sr \ S 5r S r S rS rS rg) BlobReader7aA file-like object that reads from a blob. :type blob: 'google.cloud.storage.blob.Blob' :param blob: The blob to download. :type chunk_size: long :param chunk_size: (Optional) The minimum number of bytes to read at a time. If fewer bytes than the chunk_size are requested, the remainder is buffered. The default is the chunk_size of the blob, or 40MiB. :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will define retriable response codes and errors and configure backoff and timeout options. A google.cloud.storage.retry.ConditionalRetryPolicy value wraps a Retry object and activates it only if certain conditions are met. This class exists to provide safe defaults for RPC calls that are not technically safe to retry normally (due to potential data duplication or other side-effects) but become safe to retry if a condition such as if_metageneration_match is set. See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. Media operations (downloads and uploads) do not support non-default predicates in a Retry object. The default will always be used. Other configuration changes for Retry objects such as delays and deadlines are respected. :type download_kwargs: dict :param download_kwargs: Keyword arguments to pass to the underlying API calls. The following arguments are supported: - ``if_generation_match`` - ``if_generation_not_match`` - ``if_metageneration_match`` - ``if_metageneration_not_match`` - ``timeout`` - ``raw_download`` Note that download_kwargs (excluding ``raw_download``) are also applied to blob.reload(), if a reload is needed during seek(). Nc UHnU[;dM[SUS35e XlSUl[R "5UlU=(d UR=(d [Ul X0l X@l g)Nz-BlobReader does not support keyword argument .r) VALID_DOWNLOAD_KWARGS ValueError_blob_posioBytesIO_buffer chunk_sizeDEFAULT_CHUNK_SIZE _chunk_size_retry_download_kwargs)selfblobrrdownload_kwargskwargs N/var/www/html/venv/lib/python3.13/site-packages/google/cloud/storage/fileio.py__init__BlobReader.__init__ksk$E11 CE7!L%   zz| %NNUR5 URRU5nU[U5- nUS:dUS:GaFU=RURR 5- sl[U5nURR S5 URRS5 URnUS:aU[X0R5-nOSnX RR"SUUSURS.URD6- nUS:aL[U5U:a=URRX!S5 URR S5 USUnU=R[U5U- - slU$![a Nf=f)Nr)startendr r) _checkClosedrreadlenrtellseektruncatemaxrrdownload_as_bytesrr rwrite)r!sizeresultremaining_size read_size fetch_start fetch_ends r%r.BlobReader.readysl ""4(F + A  II**, ,IF I LL  a LL ! !! $))Kax'#n>N>N*OO  **66%!!++  ++ axCK$. ""6%=1 !!!$ IIVy0 0I .  s#7F FFc$URU5$N)r.)r!r6s r%read1BlobReader.read1syyr(c2UR5 URRcRURR 5VVs0sHup4US:wdM X4_M nnnURR "S0UD6 UR URR5-nUS:XaUnO*US:XaXa-nOUS:XaURRU-nUS;a [S5eWURR:aURRnXpR :a@URRS5 URRS5 UnXplU$Xv- n UR URRU S5-nU$s snnf)zSeek within the blob. This implementation of seek() uses knowledge of the blob size to validate that the reported position does not exceed the blob last byte. If the blob size is not already known it will call blob.reload(). rr>rrBrCzinvalid whence valuer,) r-rr6r itemsreloadrrr0rr1r2) r!poswhencekv reload_kwargsinitial_offset target_posnew_pos differences r%r1BlobReader.seeksd  ::?? "!%!6!6!!>!~BU!>  JJ   . .T\\%6%6%88 Q;J q['-J q[3.J  "34 4   'J  ! LL  a LL ! !! $ G"I $4Jii$,,"3"3J"BBG?s  FFc8URR5 gr>rcloser!s r%rRBlobReader.closes r(c.URR$r>rclosedrSs r%rWBlobReader.closed||"""r(cgNTr,rSs r%readableBlobReader.readabler(cgNFr,rSs r%writableBlobReader.writabler(cgr[r,rSs r%seekableBlobReader.seekabler^r()rrrr rr)r)__name__ __module__ __qualname____firstlineno____doc__rr&r.r?r1rRpropertyrWr\rare__static_attributes__r,r(r%rr7sM1f)-M 0+Z)V##r(rc\rSrSrSrSS\4Sjr\S5r\RS5rSr S r S r S r S rS rSrSr\S5rSrSrSrSrg) BlobWritera A file-like object that writes to a blob. :type blob: 'google.cloud.storage.blob.Blob' :param blob: The blob to which to write. :type chunk_size: long :param chunk_size: (Optional) The maximum number of bytes to buffer before sending data to the server, and the size of each request when data is sent. Writes are implemented as a "resumable upload", so chunk_size for writes must be exactly a multiple of 256KiB as with other resumable uploads. The default is the chunk_size of the blob, or 40 MiB. :type ignore_flush: bool :param ignore_flush: Makes flush() do nothing instead of raise an error. flush() without closing is not supported by the remote service and therefore calling it on this class normally results in io.UnsupportedOperation. However, that behavior is incompatible with some consumers and wrappers of file objects in Python, such as zipfile.ZipFile or io.TextIOWrapper. Setting ignore_flush will cause flush() to successfully do nothing, for compatibility with those contexts. The correct way to actually flush data to the remote server is to close() (using this object as a context manager is recommended). :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. A None value will disable retries. A google.api_core.retry.Retry value will enable retries, and the object will define retriable response codes and errors and configure backoff and timeout options. A google.cloud.storage.retry.ConditionalRetryPolicy value wraps a Retry object and activates it only if certain conditions are met. This class exists to provide safe defaults for RPC calls that are not technically safe to retry normally (due to potential data duplication or other side-effects) but become safe to retry if a condition such as if_metageneration_match is set. See the retry.py source code and docstrings in this package (google.cloud.storage.retry) for information on retry types and how to configure them. Media operations (downloads and uploads) do not support non-default predicates in a Retry object. The default will always be used. Other configuration changes for Retry objects such as delays and deadlines are respected. :type upload_kwargs: dict :param upload_kwargs: Keyword arguments to pass to the underlying API calls. The following arguments are supported: - ``if_generation_match`` - ``if_generation_not_match`` - ``if_metageneration_match`` - ``if_metageneration_not_match`` - ``timeout`` - ``content_type`` - ``predefined_acl`` - ``checksum`` NFc UHnU[;dM[SUS35e Xl[5UlSUlU=(d UR =(d [UlX0l X@l XPl g)Nz-BlobWriter does not support keyword argument r) VALID_UPLOAD_KWARGSrr SlidingBufferr_upload_and_transportrrr _ignore_flushr_upload_kwargs)r!r"r ignore_flushr upload_kwargsr$s r%r&BlobWriter.__init__&sr#E// CE7!L#  $ %)"&NN)r-rr5r/r_upload_chunks_from_buffer)r!brF num_chunkss r%r5BlobWriter.writeVsS ll  #&$*:*::   + +J 7 r(cURnURRSS5n[U[5(aFURR S5URR S5S.nUR US9nURR"URRRURUS4URUS.URD6Ul g)Nrr r )ifGenerationMatchifMetagenerationMatch) query_params)rr)rrxpop isinstancerget"get_retry_policy_if_conditions_metr_initiate_resumable_uploadbucketclientrrrv)r!rrrs r%_initiate_uploadBlobWriter._initiate_uploadbs **..~tD  e3 4 4 &*%8%8%<%<=R%S)-)<)<)@)@-*L <<,<WE%)ZZ%J%J JJ   $ $ LL   & '' & !!& "r(c>UR(dUR5 URup#0nSUR;aSURRS50n[ U5HnUR "U40UD6 M UR R5 g)z$Upload a specified number of chunks.rN)rvrrxrrangetransmit_next_chunkrflush)r!rupload transportkwargs_s r%r%BlobWriter._upload_chunks_from_buffer~s))  ! ! # 66 ++ +!4!4!8!8!CDFz"A  & &y ;F ;# r(cbURR5[UR5-$r>)rr0r/rSs r%r0BlobWriter.tells#||  "S%666r(cRUR(d[R"S5eg)NzCannot flush without finalizing upload. Use close() instead, or set ignore_flush=True when constructing this class (see docstring).)rwrUnsupportedOperationrSs r%rBlobWriter.flushs*!!)) "r(cURR(dURS5 URR5 g)NrB)rrWrrRrSs r%rRBlobWriter.closes-||""  + +A . r(cUR(a)URupURUR5 URR 5 g)zCancel the ResumableUpload.N)rvdelete upload_urlrrR)r!rrs r% terminateBlobWriter.terminates=  % % $ : : F   V.. / r(cLUbUR5 gUR5 gr>)rrR)r!exc_typeexc_valexc_tbs r%__exit__BlobWriter.__exit__s   NN  JJLr(c.URR$r>rVrSs r%rWBlobWriter.closedrYr(cgr`r,rSs r%r\BlobWriter.readablercr(cgr[r,rSs r%raBlobWriter.writabler^r(cgr`r,rSs r%reBlobWriter.seekablercr() __chunk_sizerrrrwrrvrx)rirjrkrlrmrr&rnrsetterr5rrr0rrRrrrWr\rareror,r(r%rqrqs>F ,.!! " "  8,7  ##r(rqcb\rSrSrSrSrSrSSjrSrSr Sr S r S r S r \S 5rS rg)ruiaA non-rewindable buffer that frees memory of chunks already consumed. This class is necessary because `google-resumable-media-python` expects `tell()` to work relative to the start of the file, not relative to a place in an intermediate buffer. Using this class, we present an external interface with consistent seek and tell behavior without having to actually store bytes already sent. Behavior of this class differs from an ordinary BytesIO buffer. `write()` will always append to the end of the file only and not change the seek position otherwise. `flush()` will delete all data already read (data to the left of the seek position). `tell()` will report the seek position of the buffer including all deleted data. Additionally the class implements __len__() which will report the size of the actual underlying buffer. This class does not attempt to implement the entire Python I/O interface. cF[R"5UlSUlg)Nr)rrr_cursorrSs r%r&SlidingBuffer.__init__szz|  r(c4UR5 URR5nURRS[R 5 URR U5nURRU5 URU-$)z>Append to the end of the buffer without changing the position.r)r-rr0r1rSEEK_ENDr5r)r!rbookmarkrFs r%r5SlidingBuffer.writesm <<$$& !R[[)ll  # (#||c!!r(cUR5 URRU5nU=R[ U5- slU$)zRead and move the cursor.)r-rr.rr/)r!r6datas r%r.SlidingBuffer.reads9 ||  & D !  r(c0UR5 URR5nURRS5 URR S5 URR U5 URRS5 g)z@Delete already-read data (all data to the left of the position).rN)r-rr.r1r2r5)r!leftovers r%rSlidingBuffer.flushsj <<$$& ! a  8$ !r(cUR$)z>Report how many bytes have been read from the buffer in total.)rrSs r%r0SlidingBuffer.tells ||r(cdUR5 URR5nXR- nURR U[ R 5nXB- U:XaXR:a&URR U5 [S5eXlUR$)a5Seek to a position (backwards only) within the internal buffer. This implementation of seek() verifies that the seek destination is contained in _buffer. It will raise ValueError if the destination byte has already been purged from the buffer. The "whence" argument is not supported in this implementation. zCannot seek() to that value.)r-rr0rr1rSEEK_CURr)r!rFbuffer_initial_posrNbuffer_seek_results r%r1SlidingBuffer.seeks !\\..0<<' !\\..z2;;G"7:E\\! LL  0 1;< < ||r(cURR5nURRS[R5nURRU5 U$)z7Determine the size of the buffer by seeking to the end.r)rr0r1rr)r!rlengths r%__len__SlidingBuffer.__len__sE<<$$&""1bkk2 (# r(c6URR5$r>rQrSs r%rRSlidingBuffer.closes||!!##r(c6URR5$r>)rr-rSs r%r-SlidingBuffer._checkCloseds||((**r(c.URR$r>rVrSs r%rWSlidingBuffer.closed!rYr()rrNrg)rirjrkrlrmr&r5r.rr0r1rrRr-rnrWror,r(r%rurusH$" 4$+##r(ru)rmrgoogle.api_core.exceptionsrgoogle.cloud.storage.retryrrrrrrtBufferedIOBaserrqobjectrur,r(r%rsmM A4=!% k""k\Y""Yxb#Fb#r(