DhladdlZddlZddlZddlZddlZddlmZmZddl m Z m Z m Z m Z mZmZmZmZmZmZmZmZmZmZmZmZmZmZddlZddlmZej@e!Z"GddejFjHZ%GddeZ&Gd d e&eZ'Gd d eZ(Gd de&eZ)GddeZ*GddeZ+GddeZ,y)N)InvalidIMDSEndpointErrorMetadataRetrievalError) DEFAULT_METADATA_SERVICE_TIMEOUTMETADATA_BASE_URLRETRYABLE_HTTP_ERRORS ArnParserBadIMDSRequestError ClientErrorContainerMetadataFetcherHTTPClientError IMDSFetcherIMDSRegionProviderInstanceMetadataFetcherInstanceMetadataRegionFetcherReadTimeoutErrorS3RegionRedirectorS3RegionRedirectorv2get_environ_proxiesosresolve_imds_endpoint_mode)asynccontextmanagerc.eZdZfdZedZxZS)_RefCountedSessionc@t||i|d|_d|_y)Nr)super__init___RefCountedSession__ref_count_RefCountedSession__lock)selfargskwargs __class__s s/var/www/fastuser/data/www/generator.snapmosaic.io/flask_app/venv/lib/python3.12/site-packages/aiobotocore/utils.pyrz_RefCountedSession.__init__'s$ $)&) c K|jstj|_|j4d{|xjdz c_ |jdk(r|j d{dddd{ ||j4d{|jdk(r|j dddd{|xjdzc_dddd{y77#t $r|xjdzc_wxYw7#1d{7swYxYw77j7G#1d{7swYyxYw#|j4d{7|jdk(r|j dddd{7|xjdzc_dddd{7w#1d{7swYwxYwxYww)N)rasyncioLockr __aenter__ BaseException __aexit__)rs r#acquirez_RefCountedSession.acquire,s{{!,,.DK;;      !  ##q(//+++    &J{{ & &##q(..tT:::  A%  & & &  ,    A%        &: & & & &t{{ & &##q(..tT:::  A%  & & & & &s6GC5GD"C95C76C9: GDG EG D3!G$&D9 D5 D9$ G/D70G7C99 DDGD0$D' %D0,G5D97G9E ?E E GG E" G $&F7 F F7% G 0F31G 7G =G>G G  G)__name__ __module__ __qualname__rrr, __classcell__)r"s@r#rr&s &&r$rcLeZdZededdddfdZdZd dZdZdZ dZ d d Z y) AioIMDSFetcherr&Nc||_||_|i}|j|||_||_|t j j}|jddj|_ |jdk(|_ ||_ |xs*t|jt|j|_y)NAWS_EC2_METADATA_DISABLEDfalsetrue)timeoutproxies)_timeout _num_attempts_select_base_url _base_url_configrenvironcopygetlower _disabled _user_agentrr_session)rr7 num_attemptsbase_urlenv user_agentconfigsessions r#rzAioIMDSFetcher.__init__Gs  ) >F..x@ ;**//#C!wuj$?@2371MM )    @s B H  EH H +"E E"E0E1E4H 6 H EH EH  H "E#H (EH  H H H EEH H  H'H ) H 4E75H ;HF!H ! H-AHHH  H  HH HH c K|j| |j}|j|}i}|||d<|j||jj 4d{}t |jD]} tjjd||}|j|jd{} || } tj| r | d{} | s| ccdddd{Sdddd{|j%77f7A7-#t$r#} t j#d|| dYd} ~ d} ~ wwxYw7K#1d{7swY|j%xYww)Nzx-aws-ec2-metadata-tokenGETrMrRTrS)rZ_default_retryr[r^rDr,rbr:r_r`rarcrdinspect isawaitablerrgrh_RETRIES_EXCEEDED_ERROR_CLS) rurl_path retry_functokenrOrPrJrlrkrm should_retryrns r# _get_requestzAioIMDSFetcher._get_requests   ,,J!!(+  27G. / W%==((*  g4--. &11<<$#w=G&-\\'//2C%DDH#-h#7L**<8-9'9 ''   (   *..00+  E(: -LL4!% !    *..00sA(F*D1+F.E*AD9 D3 &D93D54D9;E*= F D7 FE* FE(F3D95D97F9 E%E E* E%%E*(F*F 0E3 1F 8FczK|j|d{xs|j|d{S77wN_is_non_ok_response _is_emptyrrms r#rrzAioIMDSFetcher._default_retry>--   ,>>(+ + , +;7;9;;chK|jdk7r|j|ddd{yy7w)NrQznon-200Tlog_bodyF)re_log_imds_responsers r#r~z"AioIMDSFetcher._is_non_ok_responses;   3 &))(I)M M M Ns '202cvK|jd{s|j|ddd{yy7"7w)Nzno bodyTrF)contentrrs r#rzAioIMDSFetcher._is_emptys?%%%%))(I)M M M& Ms959799cKd}||j|jg}|r(|dz }|j|jd{t j |g|y7w)NzHMetadata service returned %s response with status code of %s for url: %sz, content body: %s)rerOappendrrgrh)rrm reason_to_logr statement logger_argss r#rz!AioIMDSFetcher._log_imds_responsesc 1 %h&:&:HLLI  - -I   X%5%55 6 Y-- 6s=A!A A!r|)F) r-r.r/rrrrorzrrr~rrr$r#r2r2FsC1"  8,\1B,  16 .r$r2c4eZdZdZddZddZdZdZdZy) AioInstanceMetadataFetcherc.K |jd{}|j|d{}|j||d{}|j|r'||d|d|d|dd}|j ||Sd|vrd|vrt j d|iS77x7`#|j$r$t j d |jYiSt$r+}t j d |jYd}~iSd}~wwxYww) N AccessKeyIdSecretAccessKeyToken Expiration) role_name access_key secret_keyrx expiry_timeCodeMessagez7Error response received when retrievingcredentials: %s.\Max number of attempts exceeded (%s) when attempting to retrieve data from metadata service.zBad IMDS request: %s) ro _get_iam_role_get_credentials_contains_all_credential_fields_evaluate_expirationrgrhrur:r rk)rrxr credentialsrns r#retrieve_iam_role_credentialsz8AioInstanceMetadataFetcher.retrieve_iam_role_credentialss( <4466E"0077I $ 5 5i GGK33K@!*"-m"<"-.?"@(1#.|#<  ))+6""[(Y+-ELL+#  )77G&//  LLE""  # < LL/ ; ;  J?B JJcXK|d}|dd}d|vr|dS|jdijdd}||S |jj|d{}|dd}|jdd}|S7 #t$r}|jdd}Yd}~6d}~wwxYww) a- There are multiple potential sources for the new region to redirect to, but they aren't all universally available for use. This will try to find region from response elements, but will fall back to calling HEAD on the bucket if all else fails. :param bucket: The bucket to find the region for. This is necessary if the region is not available in the error response. :param response: A response representing a service request that failed due to incorrect region configuration. r&rrrrrNBucketr@r head_bucketr rmrrrmservice_responseresponse_headersrrPrns r#rz)AioS3RegionRedirectorv2.get_bucket_regions$A;+,>? N $4 4#$9: :"%%gr266xF  M D!\\55V5DDH12=AG2D9 E Djj!34]CG DA=B*BB B,B*B B' B"B*"B''B*Nr-r.r/r rrr$r#rrXspdr$rceZdZdZdZy)AioS3RegionRedirectorc K|y|j|jdirtjdy|jdijdrtjdy|djdi}|jd}|djdi}|d vxr|jd k(}|d vxr%|jd k(xrd |jd iv} |dk(xrd|v} |dduxr|dj dv} |dk(} t || | | | gsy|ddd} |djd}|j| |d{}|tjd|d| dytjd|d| d|d|jjd|}|d}|| |d}||dd<||j| <|j||dd|dd<y7w)Nrz=S3 request was previously to an accesspoint, not redirecting. s3_redirectedrr&rrrrrrrrrrrrrrrrrrrrrs3 endpoint_url)rrrYT) _is_s3_accesspointr@rgrhrrerr_endpoint_resolverresolverr)rrrmrr!rUrrrrrrrrrrrYr s r#r z)AioS3RegionRedirector.redirect_from_errorsy     " "<#3#3Ir#B C LLO     Ir * . . ? LLH   ,YYv& $QKOO,>C . ( KY^^|-K  . ( 8,. 8% $$]B78  8 8 NX=N &a[4) : +:)!+.A A&'%&"    i(3H=$Y/33OD 11&(CC   LL0=fF   fj 2 **224DN+!   .= Y *- F \< +BC37 Y0ADsEG?G=BG?cXK|d}|dd}d|vr|dS|jdijdd}||S |jj|d{}|dd}|jdd}|S7 #t$r}|jdd}Yd}~6d}~wwxYww)Nr&rrrrrrrrs r#rz'AioS3RegionRedirector.get_bucket_regionHs#A;+,>? N $4 4#$9: :"%%gr266xF  M D!\\55V5DDH12=AG2D9 E Djj!34]CG DrNrrr$r#rrsYvr$rcHeZdZdejfdZddZdZddZdZ y)AioContainerMetadataFetcherNcP|t|j}||_||_y)N)r7)rTIMEOUT_SECONDSrD_sleep)rrJsleeps r#rz$AioContainerMetadataFetcher.__init__`s' ?(1E1EFG  r$cdK|j||j||d{S7wr|)_validate_allowed_url_retrieve_credentials)rfull_urlrPs r#retrieve_full_uriz-AioContainerMetadataFetcher.retrieve_full_urihs- ""8,//'BBBBs '0.0cbK|j|}|j|d{S7w)zRetrieve JSON metadata from ECS metadata. :type relative_uri: str :param relative_uri: A relative URI, e.g "/foo/bar?id=123" :return: The parsed JSON response. N)r*r))r relative_urir*s r# retrieve_uriz(AioContainerMetadataFetcher.retrieve_urils-==.//9999s &/-/c^Kddi}||j|d} |j|||jd{S7#t$r[}tj d|d|j |jd{7|dz }||jk\rYd}~nd}~wwxYww)NAcceptzapplication/jsonrTzAReceived error when attempting to retrieve container metadata: %srSr&) update _get_responser$rrgrhr% SLEEP_TIMERETRY_ATTEMPTS)rr* extra_headersrPattemptsrns r#r)z1AioContainerMetadataFetcher._retrieve_credentialsxs/0  $ NN= ) !//gt';';*  -!  kk$//222A t2223  sJB- AAAB-A B)6B$BB$B-$B))B-cK |jj4d{}tjj}|d||}|j |j d{}|jd{jd}|jdk7rtd|jd| tj|cdddd{S77{7i7 #t$r&d} tjd | |t| wxYw#1d{7swYyxYw#t $r} d | z} t| d} ~ wwxYww) NrqrMzutf-8rQzReceived non 200 response (z) from ECS metadata: ) error_msgz8Unable to parse JSON returned from ECS metadata servicesz%s:%sz;Received error when attempting to retrieve ECS metadata: %s)rDr,r_r`rarcrdrdecodererrrrrgrhr) rr*rPr7rJrarkrm response_textr8rns r#r2z)AioContainerMetadataFetcher._get_responsesW >}},,. F F'%00;; $ h")goo.?!@@'/'7'7!7 ? ? H ''3.0$//#@ F::m4! F F F A!7  F""F ZILL)]C09EEF# F F F,% >#%&' )9= =  >sED7C(D7AD".C*/D"C,>D"C0 D7"C.#D7'E(D7*D",D".D70/DD""D4(D+ )D40D73E4D77 EEEEr|) r-r.r/r'r&rr+r.r)r2rr$r#r"r"_s%'--C :,>r$r")-r'rsrloggingbotocore.awsrequestr_botocore.exceptionsrrbotocore.utilsrrrrr r r r r rrrrrrrrraiobotocore.httpsession aiobotocoreaiobotocore._helpersr getLoggerr-rg httpsessionAIOHTTPSessionrr2rrrrrr"rr$r#rEs *4   8 $&00??&@H.[H.VE 1HE P!.!H16Q2Qhp.pfL>":L>r$