掊g~ddlZddlZddlmZmZddlmZejdZedZ GddZ Gdd e Z d Z Gd d eZGd deZdZy)N)contextmanagerAsyncExitStack) ClientErrors3fsc',K dy#|$rYywxYwwN) exceptionss *lib/python3.12/site-packages/s3fs/utils.pyignoringr s     s c2eZdZdZddZdZdZdZdZy) S3BucketRegionCachec h||_t|_d|_||_i|_i|_yr)_sessionr_stack_client_client_kwargs_buckets_regions)selfsession client_kwargss r __init__zS3BucketRegionCache.__init__s0 $&  +  NcK||jvr|j|S|jd{}||S |j|d{}|ddd}||jvrnt jd|||jj|jj dd|i|jd{|j|<|j|x}|j|<|S77#t$rW}|jdj dij d}|st jd||cYd}~SYd}~d}~wwxYw7w) N)BucketResponseMetadata HTTPHeaderszx-amz-bucket-regionzDRC: HEAD_BUCKET call for %r has failed, returning the general clientz:RC: Creating a new regional client for %r on the region %r region_names3)r get_client head_bucketrresponsegetloggerdebugrrenter_async_contextr create_clientr)r bucket_namegeneral_clientr$regioneclients r get_bucket_clientz%S3BucketRegionCache.get_bucket_clientst $-- '==- -#00  ! ! X+77{7KKH01-@AVWF  & LLL  +/++*I*I+ ++&,040C0C+%DMM& ! /3mmF.CC{+ E1 L & -.]B'*+   Z&%  &*%s^1E'C>E'DDDA5E' E% 2E'D E" AEE" E'E""E'cK|jsL|jj|jjdi|j d{|_|jS7w)Nr )rrr(rr)rrs r r"zS3BucketRegionCache.get_clientFsV||!%!@!@+ ++HD4G4GH"DL||sAA)A'A)cKtjd|jj|jjd|_|j jd{y7w)NzRC: discarding all clients)r&r'rclearrrracloser1s r r3zS3BucketRegionCache.clearMsP 12   kk  """sA.A80A61A8cK|Swrr r1s r __aenter__zS3BucketRegionCache.__aenter__Ts  sc@K|jd{y7wr)r3)rexc_argss r __aexit__zS3BucketRegionCache.__aexit__Wsjjls r) __name__ __module__ __qualname__rr/r"r3r6r9r rr rrs!&P#rrc,eZdZdZdedeffd ZxZS) FileExpireda Is raised, when the file content has been changed from a different process after opening the file. Reading the file would lead to invalid or inconsistent output. This can also be triggered by outdated file-information inside the directory cache. In this case ``S3FileSystem.invalidate_cache`` can be used to force an update of the file-information when opening the file. filenamee_tagcPt|tjd|d|dy)Nz*The remote file corresponding to filename z and Etag z no longer exists.)superrerrnoEBUSY)rr?r@ __class__s r rzFileExpired.__init__ds!  KK  r)r:r;r<__doc__strr __classcell__)rEs@r r>r>[s   S  rr>cPdjd|jdDS)zl TitleCases a given string. Parameters ---------- string : underscore separated string c3<K|]}|jywr) capitalize).0xs r ztitle_case..ts=++||jvr|jjjj |}|j -t |j jjn t }||j|<|j|Sr) _kwarg_cacher!meta service_modeloperation_model input_shapesetmemberskeys)r model_namemodel valid_keyss r _get_valid_keysz!ParamKwargsHelper._get_valid_keyss T.. .GGLL..>>zJE$$0E%%--2245U  -7D  j )  ,,rct|}|j|}t|tr|j }|j Dcic] \}}||vs ||c}}Scc}}wr)rTrd isinstance SSEParams to_kwargsitems)r method_namedrarckvs r filter_dictzParamKwargsHelper.filter_dicts] , ))*5 a # A!">Aa:o1>>>s  A&A&N)r:r;r<rFrYrrdrnr rr rVrVwsL -?rrVc"eZdZ ddZdZy)rgNc<||_||_||_||_yr)ServerSideEncryptionSSECustomerAlgorithmSSECustomerKey SSEKMSKeyId)rserver_side_encryptionsse_customer_algorithmsse_customer_keysse_kms_key_ids r rzSSEParams.__init__s$%;!$:!.)rcp|jjDcic] \}}| || c}}Scc}}wr)__dict__ri)rrlrms r rhzSSEParams.to_kwargss5!%!4!4!6H!6A!-1!6HHHs 22)NNNN)r:r;r<rrhr rr rgrgs $# *Irrgc#bKtd||D]}|t||zdz |dz fyw)z Chunk up a file into zero-based byte ranges Parameters ---------- size : file size block : block size rN)rangemin)sizeblockoffsets r _get_brangers:4'c&5.1,dQh777(s-/)rClogging contextlibrrbotocore.exceptionsr getLoggerr&r rIOErrorr>rTobjectrVrgrr rr rsw 5+   6 "  FFR ' ">??DII" 8r