o پi^@s<ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl ZddlmZmZmZmZmZmZmZmZddlZddlmZddlmZddlmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/dZ0dZ1dZ2d Z3d Z4d Z5d Z6d ddddddZ7dee8effddZ9dee8fddZ:de8de8de8de8fddZ; ddee8e8fd e8d!ee<de(fd"d#Z=d$e(d%ee8e8fde(fd&d'Z>d(ee8e8fd)e8dee8e?ffd*d+Z@d,e8dee8e8e8ffd-d.ZAd,e8dee8e8e8ffd/d0ZBd,e8dee8e8e8ffd1d2ZCde8d3e8d4e8de8fd5d6ZDde8d3e8d4e8de8fd7d8ZEd9e$de8d3e8d4e8de8f d:d;ZFd9e$d,e8ddfdd?ZHd@ee8efdee8fdAdBZIdCdDdEdFdGdHdIdJdKdLdMdNdO ZJdPe8de?fdQdRZKdSee8e8fde*fdTdUZLd9e$de8d3e8d%ee8e8fdVee)deMf dWdXZNd9e$dYe8de8d%ee8e8fdee8f dZd[ZOd9e$d%ee8e8fdee8fd\d]ZPd9e$de8d3e8dee8efdVee)deeee?ff d^d_ZQd9e$d(edeee?ffd`daZRd9e$d(edeee?ffdbdcZSd9e$d$e(dddfdedfZTdge.key_fnT)rZreversecSg|]}|dqS)idre).0subrererf z)load_subscription_ids..)rIrOrTrPrQrRloadsreaddecoderUrstrrboolsort)default_profile_pathr^profilerirlrererfload_subscription_idss    r|r.templatedatacKstjd|d|fi|S)Nhttps://.blob.core.windows.net)common build_url)r.r}r~rererfrsrr_scope success_codescCs~|ddkrd|d|d}d}n|ddkr'd|d|d |d }|d }nttd |d ddditj|d|dS)Nr)rCrE) grant_typerErrr7client_credentialsr;r<)rr;r<rr=z"https://login.microsoftonline.com/z/oauth2/v2.0/tokenPOSTr!z!application/x-www-form-urlencodedutf8)urlmethodheadersr~r)AssertionErrorrurllibparse urlencodeencode)r_rrr~r=rererf_create_access_token_requests*    rreqauthc Cs|jduri}nt|j}|jduri}nt|j}d|d<tjjtjjdd|d<|j }|durAt |trAt |}t |j|j||||jt|jt|jd}|\}}|tkrgt|||d<|S|tkrtd||d<|S|tkry |S) Nz 2019-02-02z x-ms-versiontzz%a, %d %b %Y %H:%M:%S GMTz x-ms-date)rrparamsrr~preload_contentr retry_codes AuthorizationzBearer )rdictcopyrdatetimenowtimezoneutcstrftimer~ isinstancexmlunparserrrrtuplerr SHARED_KEYsign_with_shared_key OAUTH_TOKEN ANONYMOUS)rrrrr~resultkindrbrererfcreate_api_requestsB    rrZrc Csid|dd|dd|dd|dd|dd |d d |d d |dddddddddddddddddddddd}tj|}|jdd}tjd |d!|jd"d}|d|d|d||d |d |d|d|d|d |d|d|d|d|d|d|d|d#|d$|df}d%|}t t t |d&| d'd(d'|d)<tjd*d+|D}t|dd,d-d.} t| } |d/|| fS)0Nst SignedStartse SignedExpirysks SignedServicesktskesktid SignedTidskoid SignedOidskv SignedVersionsvz 2018-11-09srbsprsiprHsisprz https,httprsccrscdrsce)rsclrsct.rz/blob//rr Valuersha256sigcSsi|] \}}|dkr||qS)rHrerpkvrererf 6sz'generate_signed_url..ZGMTz%Y-%m-%dT%H:%M:%S%Z?)rrurlparsenetlocrLunquoterOjoinbase64 b64encodehmacdigest b64decoderrvritemstimestrptimereplacecalendartimegm) rZrrustorage_accountcanonicalized_resource parts_to_signstring_to_signquerytstrererfgenerate_signed_urls      "  rrOcCs4|dr t|S|drt|Std|d)Naz://rInvalid path: '') startswith split_az_pathsplit_https_pathr)rOrererf split_path=s  rcCsv|tddd}t|dkrtd|d|d}|d}|dkr-td|dd|dd}|||fS) NrrrrrrrH)lenrLrr)rOpartsr. containerobjrererfrFs  rcCs|tddd}t|dkrtd|d|d}|d}|dr*|d kr2td|dd|dd}|d d}|||fS) NrrrrrrrrrHr)rrLrendswithr)rOrhostnamerrr.rererfrRs  rrrcCsd|d|d|S)Nr.blob.core.windows.net/rrer.rrrererfcombine_https_path_rcCsd|d|d|S)Nrrrerrererfcombine_az_pathcrrconfcCs|jr t|||St|||SN)output_az_pathsrr)rr.rrrererf combine_pathgs  rcCsh|ds |d7}t|\}}}tt|d||ddddidd}t||}|jd kr2td |d dS) Nr/{container}/{blob}rblobPUTx-ms-blob-type BlockBlob)rrrrr z?Unable to create directory, account/container does not exist: 'r)rrrrexecute_api_requeststatusrrrOr.rrrresprererf mkdirfilens   rcCsg}|jdur|jD]\}}|}||d|q tj|j}|j dd}d|d|j dd}d |gt t |} |jdurOi} nt|j} g} | D] \}}|}tdd|} |d rz| |d| qZd t | } | d d }|jdurtt|j}|j| d d | d d || dd | dd | dd | dd | dd | dd | dd | dd | | g}d |}ttt||ddd}d|d|S)N:rrrrrz\s+ zx-ms-Content-LengthrHr#r$r"r!DatezIf-Modified-SinceIf-Matchz If-None-MatchzIf-Unmodified-SinceRangerrz SharedKey ) rrrNappendrrrrrrLrOrlistsortedrrrerqstriprrUr~rwrrrrrrrrrv)rrZparams_to_signnamevaluecanonical_namerr canonical_urlrrheaders_to_signcanonical_valuecanonicalized_headerscontent_lengthrr signaturerererfr}sZ                 rmetadatacCs.d|vr|d}|durdSt|SdS)Nr")rrhex)r) b64_encodedrererf_get_md5s r,010203040506070809101112) JanFebMarAprMayJunJulAugSepOctNovDectextcCsL|}|ddt|dd|dd|dd}tj|}|S)N-rrTz+00:00)rL_MONTH_NAME_TO_INDEXr fromisoformat timestamp)rEp date_stringdtrererf_parse_timestamps0 rPitemcCsbd|vr |d}n|d}d|vrt|d}nt|d}tt|d|t|t||ddS)Nz Creation-Timezx-ms-creation-timex-ms-meta-blobfilemtimez Last-ModifiedrEtag)sizemtimectimemd5version)floatrPrintr,)rQ raw_ctimerUrererf make_stats   r\ out_failurescsdddtgdtkrddtffdd }t||}|jtkr*d S|jdkrBdtkrB|td ||d S|jd vrId S|td ||d S) Nrrr%cs.tdtddddddd}t|d S) NGET /{container}rrrr()restypecomp maxresultsrrrrr)rrrrr.rrrrerf build_reqs   z(_can_access_container..build_reqTzCould not access containerFrr_) r rrrrexecute_requestrrcreate_from_request_response)rr.rrr]rkrrerjrf_can_access_containers,     rosubscription_idcsd|dddi dtffdd }t||}|jd vr#dSt|j}|d D]}|d |kr;|d Sq-d |vrBdS|d dq )Nz+https://management.azure.com/subscriptions/z,/providers/Microsoft.Storage/storageAccounts api-version 2019-04-01Tr%cstddd}t|dS)Nra)rr^rgrhrrrirrrrerfrk#s z*_get_storage_account_id..build_req)rsr^r!r ronextLink)rrrmrrRrtr~)rrpr.rrkroutrrerurf_get_storage_account_ids"       rxcsrdddig} dtffdd }t||}t|j}|dd |d Dd |vr2|S|d dq ) Nz*https://management.azure.com/subscriptionsrqz 2020-01-01Tr%cstdd}t|dS)Nrarrrrhrtrirurerfrk?s z(_get_subscription_ids..build_reqcSrn)subscriptionIdre)rprQrererfrrErsz)_get_subscription_ids..r!rv)rrrmrRrtr~extend)rrrrkrr~rerurf_get_subscription_ids9s  r|cs:dtffdd }t||}t|j}t|dftdD]}t|||dur1n#q"t |} fdd| D} | D]}t|||durQnqBdSdtffdd } t|| }t|j}|d D]&} | d d krt | d f} t |||| |d r| St d|d|dqnt d|d)Nr%c tddS)Nz%https://management.azure.com/.defaultr_rrrer_rerfbuild_req_access_token[z8_get_storage_account_key..build_req_access_token access_tokencsg|]}|vr|qSrere)rpro)stored_subscription_idsrerfrrpsz,_get_storage_account_key..cs&tdddddid}t|dS)Nrzhttps://management.azure.comz /listKeysrqrrryrhrtri)rstorage_account_idrerfbuild_req_list_keys|s   z5_get_storage_account_key..build_req_list_keyskeys permissionsFULLr!r]zIFound storage account key, but it was unable to access storage account: '' and container: 'rzCStorage account was found, but storage account keys were missing: ') rrrmrRrtr~rr|rxr|rror)rr.rr_r]rrrrpsubscription_idsunchecked_subscription_idsrrZstorage_key_authre)rr_rrrf_get_storage_account_keyLsH            rcsj|\}t}td}g}|dkrDdvr-dkr-tddddtdf}t||||drB||tfSn1|d krd tffd d }t ||}t |j } |j d kr| ddkrod| dvs| ddkr{d| dvs| ddkrd| dvrtdtd| dd| ddt| df}t||||dr||t| dfS|jrt|||d} | dur| |tfSn|dkrd tffdd }t ||}t |j } t| df}t||||dr||t| dfS|jrt|||d} | dur| |tfSn_|dkruzdd lm} Wn ty/td!w| } | d"} Wdn 1sDwYt| jf}t||||dr]|| jfS|jrut|||d} | duru| |tfStd#f}t||||dr|td$fSd%d&|d}t|dkr|D] }|d'|7}qtdkr|d(7}t|))Nr)r/r.z*Provided storage account key for account 'zA' via environment variables, but needed credentials for account 'rr0rrCr%cstddddS)Nrz.blob.core.windows.net/.default)rr )r_rrrrer.r_rerfrks  z$_get_access_token..build_reqr error invalid_grant AADSTS700082error_descriptioninteraction_required AADSTS50078 AADSTS50076zMYour refresh token is no longer valid, please run `az login` to get a new onez7Encountered an error when requesting an access token: `z: z9`. You can attempt to fix this by re-running `az login`.r expires_in)rr.rr_r]r7cr})N"https://storage.azure.com/.defaultr~rrerrerfrkrr*r)DefaultAzureCredentialzSWhen setting AZURE_USE_IDENTITY=1, you must also install the azure-identity packagerrHinfzFCould not find any credentials that grant access to storage account: 'rz Access Failure: a No Azure credentials were found. If the container is not marked as public, please do one of the following: * Log in with 'az login', blobfile will use your default credentials to lookup your storage account key * Set the environment variable 'AZURE_STORAGE_KEY' to your storage account key which you can find by following this guide: https://docs.microsoft.com/en-us/azure/storage/common/storage-account-keys-manage * Create an account with 'az ad sp create-for-rbac --name ' and set the 'AZURE_APPLICATION_CREDENTIALS' environment variable to the path of the output from that command or individually set the 'AZURE_CLIENT_ID', 'AZURE_CLIENT_SECRET', and 'AZURE_TENANT_ID' environment variables)rrgrUrrroSHARED_KEY_EXPIRATION_SECONDSrrrmrRrtr~rrrY&use_azure_storage_account_key_fallbackrazure.identityr ImportError RuntimeError get_tokenrb expires_onrr)rrZrr azure_authaccess_failuresrrkrrstorage_account_key_authrcredrbanonymous_authmsg resp_failurererrf_get_access_tokens                              rcstjd}|dtkrdttfS\dtffdd }t|}|jdkr8t ddt |j }tt}|d |fS) NrZrr%cstjjtjjd}|tjddd}|tjddd}tddd td d d d ||didd}tj d}|dt krMt dddt ||dS)Nr)hoursz%Y-%m-%dT%H:%M:%SZ)daysrrrserviceuserdelegationkey)rdreKeyInfo)StartExpiry)rr^rrrr~rrrzOnly OAuth tokens can be used to get SAS tokens. You should set the Storage Blob Data Reader or Storage Blob Data Contributor IAM role. You can run `az storage blob list --auth-mode login --account-name z --container z0` to confirm that the missing role is the issue.rh) rrrr timedeltarrraccess_token_managerrrrr)rstartexpiryrrr.rrrZrerfrk,s(     z!_get_sas_token..build_reqr^z@You do not have permission to generate an SAS token for account zh. Try setting the Storage Blob Delegator or Storage Blob Data Contributor IAM role at the account level.UserDelegationKey) rrrrSAS_TOKEN_EXPIRATION_SECONDSrrrmrrrrr~)rrZrrkrrwrrerrf_get_sas_token#s       rurllib3.BaseHTTPResponsecsrtjj}|jdd|jd}t|dkrtd|jdddt ffdd }t |S) Nrrrrzmissing container from pathrr%csttjfddS)Nrrh)rrrrer.rrrrerfrkVsz&execute_api_request..build_req) rrrrrrLrOrrrrrm)rrr path_partsrkrerrfrNs   rindex upload_idcCs>|dksJ|d>|}|dksJt|jddddS)Nilbig) byteorderr)rrto_bytesrv)rr id_plus_indexrererf_block_index_to_block_id^s   rc Cst|tddddd}t||}|jdkrdStj|jdhd}|d d dur*dS|d d d}d d d d |Dii}dd|D}tD]\} } | |vrX|| || <qJt|dtddi|d|di|dd}t||S)N blocklistrerarl)rrrrrBlock repeated_tags BlockListCommittedBlocksLatestcSrn)Namere)rprrererfrrursz-_clear_uncommitted_blocks..cS i|] \}}|dr||qSz x-ms-meta-rrrererfrw z-_clear_uncommitted_blocks..r retag)r r_rrrrr~r) rrrrrrr~r!RESPONSE_HEADER_TO_REQUEST_HEADER) rrr)rrrblocksbodyrsrcdstrererf_clear_uncommitted_blockses.    r block_ids md5_digestrXc Cs(dd|ii}i}|durt|d|d<|dur||d<t|d|tdd|d d d d tfd }t||} | jd kr`t | j } | dddkrTt j d|d|| dt j d| j|| d| jd ksj| jtkrrtd|d| jd kr| jddkrt j d| j|| dtj d|| d| S)Nrrrr rr rrr r r_r)rrrrr~rrCodeInvalidBlockListzMInvalid block list, most likely a concurrent writer wrote to the same path: ``)requestresponseunexpected status messagerrNo such file or directory: 'rx-ms-error-codeConditionNotMet etag mismatch)rrrvrrr rrrrr~rrnrFileNotFoundErrorrr) rrOrrrrXrrrrrrererf_finalize_blobsJ       rc Cs|ds |d7}t|\}}}|dkr2tt|d||ddtdddd tfd }t||}|jdkSt|t|d|d dtd d|dd dd}|D]}|ddur^d|dvp[d|dvSqHdS)z8 Return true if a path is an existing directory rrHrbrrar)rdrr_)rrrrrcrr()rerdprefix delimiterrfrrrBlobsN BlobPrefixBlobF) rrrrrr rrcreate_page_iterator) rrOr.rrrritrrererfisdirs2      rrrc cs|duri}nt|}|durd}nt|} t||||ddtfd}t||}|jdtfvr6dStj|jddhdd} | V| d durMdS| d |d <q) NTrr_rrrrEnumerationResults NextMarkermarker) rrrr rrrrr~) rrrr~rrMdrrrrererfrs0     rc s\eZdZdededeedeeddf fdd Z dd ed ed eedd fd dZ Z S)StreamingReadFilerrOrTrXr%NcsX||_|dur!t|||d}|durtd|d|j}|j|_tj|||ddS)NrXrr)rrOrT)_version maybe_statrrTrXsuper__init__)selfrrOrTrXr __class__rerfrszStreamingReadFile.__init__ streamingrendrc Cszt|j\}}}dtj||di}|jdur|j|d<tt|d||dd|d| d}t|j|} |jp9| j d |_| S) Nrrrrrrra)i)rrrrrETag) r_pathr calc_rangerrrr_confrrU) rrrrr.rrrrrrererf_request_chunks   z StreamingReadFile._request_chunkr) __name__ __module__ __qualname__rrwrrZrrxr __classcell__rererrfrs, rcsHeZdZdededeeddffdd Zded eddfd d Z Z S) StreamingWriteFilerrOrXr%Nc sR||_t|\}}}t|d||d|_tdd|_d|_||_t |jd|jr,d|jiniddd d t fd }t ||}|j dkr^|j d d krXt||j|j }|rW|j d|_nAt||n;|j dt fvsq|j d kry|j ddkrytd|d|j d kr|j ddkrtjd|j ||dtjd||dt|_tj||jddS)NrrrHEADrrr r_rrr r r rContainerNotFoundz3No such file or container/account does not exist: 'rrrrr)r chunk_size)r rr_urlrrandint _upload_id _block_indexrrr rrrrremoverrrnrhashlibrW_md5rrazure_write_chunk_size) rrrOrXr.rrrrrrerfr%sBK       zStreamingWriteFile.__init__chunkfinalizec sDd}|t|kru|jj}|||}j|t|}tjddt |  dit dtjjd|ddtd }ztj|Wn tyU~~|`~wjd 7_jtkrmtd td td |}|t|ks|rfddtjD}tjjj|j jd} | jdpj_dSdS)Nrr r"rblockreblockid)r )r )rrrrr~rrrzExceeded block count limit of z? for Azure Storage. Increase `azure_write_chunk_size` so that zI * `azure_write_chunk_size` exceeds the size of the file you are writing.csg|]}t|jqSre)rr)rpirrerfrrs z4StreamingWriteFile._upload_chunk..rrOrrrrXr )rr rrupdaterrWrrrrrrvrrrrr r Exceptionr~BLOCK_COUNT_LIMITrrangerr rrrU) rr r!rrr~ block_md5rrrrer&rf _upload_chunksZ          %  z StreamingWriteFile._upload_chunk) rrrrrwrr memoryviewrxr-rrererrfr$s"xrrrTblock_idc Csjt|dtd|ddt|it||||dddtfd}t||}|jdks+|jtkr3td |d dS) Nr r"r#rrr r_rrr)rrrwrr rrr)rrOrrTrr/rrrererfr-s   r-executorrr return_md5 dst_versionc CsLt|d }t|}Wdn1swYt|\}} } t|d| | d} tdd} t|} g}t |dt p>d}t t t | j|tjt}d}d}g}|| jkrt|| }|t|||t || j|| |}|||||d7}||7}|| jksZ|D]}|qt||| |||d|rt|d SdS) Nrhrrrr _max_workersrr'r)rQrr,rrrrrIstatgetattr cpu_countminmaxmathceilst_sizePARALLEL_COPY_MINIMUM_PART_SIZEMAX_BLOCK_SIZErsubmitr-rrrbinasciihexlifyrv)rr0rrr1r2r^rr.rrdst_urlrsr max_workers part_sizer%rfuturesr/futurerererfparallel_uploadsJ          rGrc Cst|\}}}|dkr dStt|d||ddddtfd}t||}|jdkr)dSt|j}|dur?|j|kr?t j d||d |S) NrHrrrrr_rrrrr) rrrr rrr\rrXrrn) rrOrXr.rrrrr4rererfrs"   rcCsZt|\}}}|dkrtd|dtt|d||ddddtfd }t||}|jdkS) NrH,The system cannot find the path specified: 'rrrDELETEr_rH)rrrrr rrrrererfr)s  rr hexdigestc Cst|\}}}tt|d||ddd|idd}t||}|jdvr#dSi} tD]\} } | |jvr9|j| | | <q)t t | d | d <tt|d||dd t d d i| d|idd}t||}|jdkS)Nrrrrrr_rr)r_rFrr r  propertiesr)rr^r_rrrrrrr)rrrrrrrrrrr? unhexlifyrvr) rrOrrLr.rrrrrrrrererfmaybe_update_md56s>      rQrc csri}|dur ||d<t|\}}}t|t|d|ddtd dd|d|d}|D] }t||||EdHq*dS) Nrrbrcrarr)rerdrrre)rrrr _get_entries) rrOrrr.rrrrrererf list_blobs_s rScCsD|dr |dd}t|\}}}|dd}t||ddddS)NrrTFr rOis_diris_filer4rrrLr)rOr[rr rererfentry_from_dirpathos  rXr4cCs<|drJt|\}}}|dd}t||dd|dS)NrrFTrTrW)rOr4r[rr rererfentry_from_path_statwsrYrc cs|d}|dur dSd|vr$|dD]}t||||d}t|Vqd|vrQ|dD]&}t||||d}|ddrDt|Vq,|d}t|t|Vq,dSdS)Nrrrrr Properties)rrXrrYr\) rr.rrblobsbprOrpropsrererfrR~s"    rRcCsPt|\}}}t|d||d}tj|||fd}|dur"|tdfSt||dS)NrrrrZrrZr)rrsas_token_managerrrYr)rrOr.rrrrbrererfget_urls   rarUc Cst|\}}}i}|dur||d<tt|d||ddtdd|dd}t||} | jd kr5td |d | jd kr.rRr r) rrrrrrrrrrw) rrOrUrXr.rrrrrrererf set_mtimes>       rbcCsZt|\}}}t|}d|vr"d|ddd}t||||St|||dddS)NrrrH)rrrrLr)rrOr.rrrererfdirnames rccst|\t|\dtffdd }d}d}d}t}|D]{} t|} | jdkrG| jd}| jd}| jd}n^| jtkrWtd|d |d | jd krv| jd d krntd|d |d td|d | jdkrt | j } | dddkrt j d| j|| dntd| jt| q)t}|dkrtt|ttdddd} t| } | jd|krtd| jd}| jd}|dks|dkrtd|d |rt|} | dur| j|kr| jSdS)Nr%cstdd}kr!tjfd}|dur!t||d\}}ttdddd|iddd tfd }t|tjfdd S) Nrrr^r_r x-ms-copy-sourcerKr_r`rrh)rr`rrrr rr)src_url sas_tokenr[rr dst_accountdst_blob dst_container src_accountsrc_blob src_containerrerfrks$ zremote_copy..build_reqrKz x-ms-copy-idzx-ms-copy-statusr:Source container or destination container not found: src='' dst='rr_rrzSource file not found: 'r`rrPendingCopyOperationrrzunhandled status pendingrrra)rrzCopy id mismatchsuccesszInvalid copy status: ')rrrexponential_sleep_generatorrmrrr rrrr~rrnrrsleepnextrrrrXrW)rrrr1rkcopy_id copy_statusrbackoff_generatorbackoffrrrrrergrf remote_copysn               rzarcCsN|ds |d7}t|\}}}t||}|dr |dd}t||||S)Nrr)rrrrr)rr{rr.rrrererf join_paths%s    r|c st|\}t|\}td|dtd|ddtf f dd }t|} | jdkrFtd|d|d | jtkrVtd |d|d dS) Nrrr%c stjfd}|dur}nt|d\}}tdtddd|tj ddd d tfd }t|t jfdd S) Nr^r_r r"r#r'r)rrdzx-ms-source-ranger r_rOrh) r`rrrrrr r rr)rf copy_src_urlr[r r/rrhrjrArTrkrmrerrerfrk:s"  z&_put_block_from_url..build_reqr_z?Source file/container or destination container not found: src='rorrn)rrrrrmrrr ) rrrrTrr/rlrirkrrer~rf_put_block_from_url0s$   rc CsBt||}|durtd|dd}|jdurt|j}tdd}g} |jt} | t ks1Jt |j | } d} d} g}| |jkrot | |}| t||| t| |j| ||}||| || d7} | | 7} | |jksB|D]}|qqt|\}}}t|d||d}t|||| ||d|r|durt|d SdS) NrIrrrrrrr'r)rrrWr?rPrrrTr*r=r8rrr>rr7rrrrrr@rv)rr0rrr1r2rrrrmin_block_sizerDr%rrEr/rFrhrjrirArererfparallel_remote_copy_sV              r azure_access azure_sas)r)NNr)qrr?rconcurrent.futures concurrentrrrrRr9rIrr urllib.parsertypingrrrrrrrr urllib3blobfiler rr rblobfile._commonr r rrrrrrrrrrrrrrrrrrrrr=r*rrwrgr|rrZrrrYrrrrrrrrrr,rJrPr\rxrorxr|rrrrrrbytesrrrrrr-rEExecutorrGrrrQrSrXrYrRrarbrcrzr|rrrr`rerererfs(  L S  $&*@   7    1  "  H+  " 9% !"&2 (0 $)  "$ #" \  / 8