VSrSSKJr SSKJr SSKJr SSKJr SSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK r SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSKJr SSKrSS KJr SSKrSS KJr SS KJ r SS K!J"r" SS K#J$r$ SSK%J&r' SSK(J)r) SSK*J+r, SSK-J.r. SSK/J0r0 SSK1rSSK2rSSK3J4r4 SSK5J6r6 SSK5J7r7 SSK5J8r8 SSK5J9r9 SSK5J:r: SSK5J;r; SSK5Jr> SSK5J?r? SSK5J@r@ SSK5JArA SSKBrCSS KDJErE SS!KDJFrF SS"KGJHrH SS#KGJIrI SS$KJJKrK SS%KJJLrL SS&KMJNrO SS'KPJQrQ SS(KRJSrS SS)KRJTrT SS*KRJUrU SS+KVJWrW SS,KVJXrX SS-KYJZrZ SS.KYJ[r[ SS/KYJ\r\ SS0KYJ]r] SS1KYJ^r^ SS2KYJ_r_ SS3K`Jara SS4K`Jbrb SS5KcJdrd SS6KeJfrf SS7KgJhrh SS8KiJjrj SS9KiJkrk SS:KiJlrl SS;KiJmrm SSKiJprp SS?KiJqrq SS@KiJrrr SSAKiJsrs SSBKiJtrt SSCKiJuru SSDKiJvrv SSEKwJxrx \R(a\zr{\RR\RR\RRz\RR~\RR\RGR4r\GR"5qSFq\GR "SG\GR SH9r\GR "SI5rSJrSKr"SLSM\5r"SNSO\95rg)Pz?XML/boto gsutil Cloud API implementation for GCS and Amazon S3.)absolute_import)print_function)division)unicode_literalsN) parseString) _exceptions) http_client)config)handler)Cors)LifecycleConfig)CORSConfiguration) DeleteMarker) Lifecycle)Prefix)Tags)BotoResumableUpload)AccessDeniedException)ArgumentException)BadRequestException)CloudApi)NotEmptyException)NotFoundException)PreconditionException)ResumableDownloadException)ResumableUploadAbortException)ResumableUploadException)!ResumableUploadStartOverException)ServiceException)CommandException)InvalidUrlError)GOOG_PROJ_ID_HDR)PopulateProjectId)GenerationFromUrlAndString)StorageUrlFromString)storage_v1_messages)parallelism_framework_util)ConfigureNoOpAuthIfNeeded)GetMaxRetryDelay) GetNumRetries)ListToGetFields)ValidateDstObjectMetadata)DEFAULT_FILE_BUFFER_SIZE)REQUEST_REASON_ENV_VAR)REQUEST_REASON_HEADER_KEY)S3_DELETE_MARKER_GUID)UTF8)XML_PROGRESS_CALLBACKS)Base64EncodeHash)Base64ToHexHash)AddAcceptEncodingGzipIfNeeded)multiprocessing_context)EncodeStringAsLong)AclTranslation)AddS3MarkerAclToObjectMetadata)CorsTranslation)CreateBucketNotFoundException)%CreateNotFoundExceptionForObjectWrite)CreateObjectNotFoundException)DEFAULT_CONTENT_TYPE)HeadersFromObjectMetadata)LabelTranslation)LifecycleTranslation)REMOVE_CORS_CONFIG)S3MarkerAclFromObjectMetadata)UnaryDictToXml)TWO_MIBFz.*non-\s*existent\s*object)flagsz^"*[a-fA-F0-9]{32}"*$cSSSS.nUR5HBup#[R"SUS5nUcM"[URR X45 MD g)z:Update Boto Key object with user config's custom endpoint.hostport host_header)gs_hostgs_portgs_host_header CredentialsN)itemsr getsetattrbucket connection)keyuser_setting_to_key_attribute user_setting key_attributeuser_setting_values )platform/gsutil/gslib/boto_translation.py_AddCustomEndpointToKeyrZs\%# &C%H%H%J!lM<F% cjj##]G&Kc\[R"5q[R"SS5qg)zPerform necessary initialization for multiprocessing. See gslib.command.InitializeMultiprocessingVariables for an explanation of why this is necessary. irN)r' CreateLockboto_auth_initialized_lockr6Valueboto_auth_initializedr[rY"InitializeMultiprocessingVariablesrcs& :DDF177Q?r[c$\rSrSrSrSrSrSrg)DownloadProxyCallbackHandlerzFIntermediary callback to keep track of the number of bytes downloaded.cXlX lgN) _start_byte _callback)self start_bytecallbacks rY__init__%DownloadProxyCallbackHandler.__init__s !Nr[cfUR(a URURU-U5 gg)zSaves necessary data and then calls the given Cloud API callback. Args: bytes_downloaded: Number of bytes processed so far. total_size: Total size of the ongoing operation. Nrjri)rkbytes_downloaded total_sizes rYcall!DownloadProxyCallbackHandler.calls* ~~ nnT%%(88*Er[rqN)__name__ __module__ __qualname____firstlineno____doc__rnrt__static_attributes__rbr[rYreresNFr[rec ^\rSrSrSrS;U4SjjrSrSS jr S?S jr SS jr S=S jr SrSSSS\R R"SSSSSS4 SjrS\SS4SjrSS\S4SjrS>SjrS?SjrS=SjrS?SjrS@SjrS@SjrSrSASjrSBSjrSCSjrS=Sjr SDSjr!S?Sjr"S r#S!r$S"r%S#r&S@S$jr'S@S%jr(S@S&jr)S@S'jr*S(r+S)r,S*r-S+r.S,r/S@S-jr0S?S.jr1S?S/jr2SES0jr3SFS1jr4S2r5S3r6S4r7S5r8S6r9S7r:S8r;S9r$)GBotoTranslationa-Boto-based XML translation implementation of gsutil Cloud API. This class takes gsutil Cloud API objects, translates them to XML service calls, and translates the results back into gsutil Cloud API objects for use by the caller. This class does not support encryption and ignores encryption and decryption parameters. Behavior when encountering encrypted objects is undefined. TODO: Implement support. This class does not support handling a Requester Pays user project for billing, and any given user project will be ignored. TODO: Support user_project. Nrc (>[[U] UUUUUUUU S9 Un [ [ 5 [ [ [5(aSqO S[ lSSS5 [RRSSS5Ul g!,(df  N5=f)aePerforms necessary setup for interacting with the cloud storage provider. Args: bucket_storage_uri_class: boto storage_uri class, used by APIs that provide boto translation or mocking. logger: logging.logger for outputting log messages. status_queue: Queue for relaying status to UI. provider: Provider prefix describing cloud storage provider to connect to. 'gs' and 's3' are supported. Function implementations ignore the provider argument and use this one instead. credentials: Unused. debug: Debug level for the API implementation (0..3). http_headers (dict|None): Arbitrary headers to be included in every request. trace_token: Unused in this subclass. perf_trace_token: Performance trace token to use when making API calls ('gs' provider only). user_project: Unused in this subclass )providerdebug http_headers trace_tokenperf_trace_tokenTNGSUtildefault_api_version1) superr}rnr_r( isinstanceraboolvaluebotor get_value api_version) rkbucket_storage_uri_classlogger status_queuer credentialsrrrr user_project_ __class__s rYrnBotoTranslation.__init__s: /4)*B*0*63;057C6A;K*M A $! )4 0 0 $&'# $ {{,,X7L-02D $ #s 2B Bcg)z*Service account credentials unused for S3.Nrbrks rYGetServiceAccountId#BotoTranslation.GetServiceAccountIds r[cUnURU5nUR5nURURSUS9US9$![anUR XqS9 SnAgSnAff=f),See CloudApi class for function doc strings.Tvalidateheadersfields bucket_nameN)_StorageUriForBucket_CreateBaseHeaders_BotoBucketToBucket get_bucketTRANSLATABLE_BOTO_EXCEPTIONS_TranslateExceptionAndRaise)rkrrrr bucket_urires rY GetBucketBotoTranslation.GetBucketsA**;7J%%'GC  % %j&;&;TDK'<'M-3&55 (C &&q&BCsA A& A!!A&c## Un[US9nUR5nURS:Xa[U5U['[ R "SUR-SURURS9nURUS9nUHNn URS:Xa*U RR5U R:waM=URXS9v MP g ![an URU 5 S n A g S n A ff=f7f) r list_fieldsgsz%s://Fsuppress_consec_slashesrrrs3rN)r+rrr#r"r storage_urirrget_all_bucketsnamelowerrrr) rk project_idrrr get_fieldsr provider_uri buckets_iterrRrs rY ListBucketsBotoTranslation.ListBucketssA V4J%%'G }}"3J"?g*%% DMM !"'#'#@#@ l "11'1Bl & ==D V[[%6%6%8FKK%G &&v&AA ! (* &&q))*s0>DBCD D'C=8D=DDcUnURU5n UR5n URXZ5 UR(a>[R "UR5n U R U R5U S9 U(a=U R5n X<;a[SU-5eU RX9RU S9 U(a>U R5n XL;a[SU-5eU RUU RU S9 UR(aLUR[:Xa/Ul [R "UR5n U R#U SU S9 UR$(a>[R "UR$5n U R'U R5U S9 UR((a>[*R,"UR(5nU R/5R1XS9 UR:(a1[<R>"UR:5nU RAUSU S9 URB(aURBRD(aVURBRF(a;U RIURBRDURBRFSU S9 OU RKSU S9 URL(aU ROURLU S9 URP(a$U RSURPRTU S9 URV(a=URVRXnURVRZnU R]UUU S9 UR_XS9$![2R4R6anUR8S:waeSnAGNSnAff=f![`anURcXS9 SnAgSnAff=f)rrInvalid canned ACL "%s".FNrr)2rr_AddPreconditionsToHeadersaclr8BotoAclFromMessage set_xml_aclto_xml canned_aclsr set_acl object_name set_def_aclcorsrBr:BotoCorsFromMessageset_corsdefaultObjectAclset_def_xml_acllabelsr@BotoTagsFromMessagerset_tagsr exceptionGSResponseErrorstatus lifecyclerABotoLifecycleFromMessageconfigure_lifecyclelogging logBucketlogObjectPrefixenable_loggingdisable_logging storageClassset_storage_class versioningconfigure_versioningenabledwebsitemainPageSuffix notFoundPageset_website_configrrr)rkrmetadata canned_aclcanned_def_acl preconditionsrrrrrboto_aclr boto_cors boto_tagsrboto_lifecyclemain_page_suffix error_pages rY PatchBucketBotoTranslation.PatchBucketsZ A**;7J%%'G##M;>C !44X\\Bx0'B  ,,.  ( !;j!HI I:'='=wO  ,,.  , !;n!LM M~)55'.  0  ==. .(-#77 F Iug>  " "!44X5N5NO""8??#4g"F $88I      ! * *9 * F   -FF    &&~ug&N       % %(*:*:*J*J  # #H$4$4$>$>$,$4$4$D$D$),3 $ 5  $ $UG $ <   $$X%:%:G$L   ''(;(;(C(C07 ( 9   #++::%%22 %%&6&0.5 & 7^^K^ 775~~--  XX_  6 (C &&q&BCsCF5O,N FOO8O OOO O:!O55O:cUnURU5nSnU(a+UR(aURR5nUR5n URS:Xa[ U5U [ 'Sn U(aUR(a URn U(aNUR(a=URR(a"[URR5U S'URU UU S9 OURXS9 URXS9$![an URXS9 Sn A N-Sn A ff=f![an URXS9 Sn A NSSn A ff=f) rrzx-goog-bucket-retention-period)rlocation storage_classrN)rrr)rrrrschemer#r"rretentionPolicyretentionPeriodstr create_bucketrrr) rkrrrrrrrrrrrs rY CreateBucketBotoTranslation.CreateBucketdsS A**;7JHH%%""((*h%%'GD "3J"?gm h++ -- x//  " " 2 247  $ $ 4 45601E  *2/< ! > E   D >>+> 55*E (((DE *E (((DEs06D' E ' E 1EE  E0E++E0cxX24nURU5nUR5nURUS9 g ![anUR XqS9nU(aSUR ;aUR 5(a>URS:Xa[SU-URS9e[SU-URS9e[SU-URS9e![an URXS9 S n A S nAg S n A ff=fU(aURS :Xa[S U-5eURXqS9 S nAg S nAff=f) rrrBucketNotEmptyrzVersionedBucketNotEmpty (%s). Currently, gsutil does not support listing or removing S3 DeleteMarkers, so you may need to delete these using another tool to successfully delete this bucket.rzVersionedBucketNotEmpty (%s)BucketNotEmpty (%s)NzBucket %s does not exist.) rr delete_bucketr_TranslateBotoExceptionreasonget_versioning_configrrrrr) rkrrrrrrrtranslated_exceptione2s rY DeleteBucketBotoTranslation.DeleteBucketsYA**;7J%%'GEw/ 'E!99 :&  299 9 H  - - / /}}$%(+66 $.<xx  $% 3xx , H  * *2 * G G H $8$?$?3$F ;k IJJ (((D;Es:6 D9&D4'A*C C8C3*D43C887D44D9c## Un[US9nURU5n UR5n USL=(d SU;n USL=(d [SU55n U R U=(d SU=(d SUU S9n W GH3nU (aR[U[5(a=[R"UR[RR5v M]U (dMfUn[/SQ5nU(aU(aoURU5(dYSn[!US S5(a UR"n[!US S5(a UR$nUR'UURUS 9nUR)UUS 9n[R"U[RR*5v GM6 g![ anUR XS9 SnAGN[SnAff=f![ anUR XS9 SnAgSnAff=f7f) rrNprefixesc3B# UHoRS5v M g7f)zitems/N) startswith).0fields rY .BotoTranslation.ListObjects..s*806u""sr)prefix delimiter all_versionsrr)rRetagrupdated generationmetagenerationsizer version_idrr)r+rrany list_bucketrrrrrCsObjectOrPrefixrCsObjectOrPrefixTypePREFIXsetissubsetgetattrrr _GetBotoKey_BotoKeyToObjectOBJECT)rkrrrrrrrrrryield_prefixes yield_objects objects_iterrrTkey_to_convertkey_http_fieldsr return_objects rY ListObjectsBotoTranslation.ListObjectss A V4J**;7J%%'Gt^;zV';NdN8c*806*8'8MC++6>jsL$//>>j!--k.1hh9C.EN//7A0C-))-*2*G*G*N*NP PI (C &&q&BCT (C &&q&BCs\AH $F=A$G$*CG$<H = G!GH G!!H $ H.H=H HH cUnURURUUUS9US9$![anURUUUUS9 SnAgSnAff=f)rrrrrrN)r(r'rr)rkrrrrrrrs rYGetObjectMetadata!BotoTranslation.GetObjectMetadatasv A >  " "4#3#3K4??I$4$K+1#22 (> &&q3>3>2<'>>s# A AA c^U4Sj$)aCurries a digester object into a form consumable by boto. Key instantiates its own digesters by calling hash_algs[alg]() [note there are no arguments to this function]. So in order to pass in our caught-up digesters during a resumable download, we need to pass the digester object but don't get to look it up based on the algorithm name. Here we use a lambda to make lookup implicit. Args: digester_object: Input object to be returned by the created function. Returns: A function which when called will return the input object. c>T$rhrb)digester_objectsrY0BotoTranslation._CurryDigester..s?r[rb)rkr8s `rY_CurryDigesterBotoTranslation._CurryDigesters  #"r[Fc UR5n[UUS9 U bSU <SU <3US'OU S:a SU -US'OU S:aSU -US'U (a_[R"U 5n[R"[ R "US 55nURS :Xa [U5 OURXUS 9nU (a3URS :Xa#0nU HnURU U5UU'M O0nU=(d SnU (a[R"U 5S nU(a![[U5[- [5nO[nU[R R"LaUR%UU U UUU UUS 9 O@U[R R&LaUR)UUU UUUS9 O[+SU-5eURS:XaU (a~"SS[05nU HhnU[R R":XaU S:wd"[3USS5(aUUR4;dSU U'MPU"UR4U5U U'Mj ggg![,anUR/UUUUS9 SnANSnAff=f)r)compressed_encodingNzbytes=-rangerz bytes=%s-zbytes=%surlrrrs)rrm num_callbacks hash_algs)progress_callbacknum_progress_callbacksrrCz Unsupported DownloadStrategy: %sr3rc$\rSrSrSrSrSrSrg)6BotoTranslation.GetObjectMedia..HashToDigesterijzWrapper class to expose hash digests. boto creates its own digesters in s3's get_file, returning on-the-fly hashes only by way of key.local_hashes. To propagate the digest back to the caller, this stub class implements the digest() function. cXlgrhhash_val)rkrJs rYrn?BotoTranslation.GetObjectMedia..HashToDigester.__init__rs$Mr[cUR$rhrIrs rYdigest=BotoTranslation.GetObjectMedia..HashToDigester.digestus == r[rIN)rvrwrxryrzrnrMr{rbr[rYHashToDigesterrGjs  % !r[rO local_hashes)rr5jsonloadspicklebinascii a2b_base64rrZr'r;maxintrEr2rDownloadStrategy RESUMABLE_PerformResumableDownloadONE_SHOT_PerformSimpleDownloadrrrobjectr&rP)rkrrdownload_streamrr object_sizer>download_strategyrlend_byterDserialization_data digestersdecryption_tuplerserialization_dictrTrCalgrsrErrOalg_names rYGetObjectMediaBotoTranslation.GetObjectMedias$%%'G!'6IK*4h?gg a$ 3gg a#z2gg ::&89 LL,,-?-FG Hc $ $   [*  McT]]d*i#,,Ys^< #i!J::01,?j" j/G #%; = 6> h77AA A &&'1'/'*/60A5K1: ' <  9 9 B B B ##  /#9 $ ! B 1!23 3 }}  !V !"H H$=$=$G$GGQnd)K)K)1S5E5E)E#'Ih #11A1A(1K"LIh "!  (> &&q3>3>2<'>>s$3I 1I ;I J*JJcpURUUUUUS9 g![a URUUUUS9 gf=f)N)cbnum_cbrrC)rkrlr)get_contents_to_file TypeError)rkr^rTrDrErrCs rYr\&BotoTranslation._PerformSimpleDownloadsW 0 "3&<'.)2 4 0 "3&<'.00s 55c 6[R[[R[R 4n UR RRn [5n Sn Un [X&5nUR5nSU;aURS5 SX#4-US'URUUURUSUS9 UR!5 g![a URUUURUSS9 N:f=f!U anU S:a%UR"R%S ['U55 [)U[5(anUR*[*R,:XaPUR.S :Xa"URUUWRUSS9 SnAOURUUWRUSUS9 SnAOSnAf[0R2R4a}nUR6[0R2R8R::Xa[5UR<5eU S:a&UR"R%S UR<5 SnAOSnAff=fUR?5nX-:aUn Sn OU S- n X:a [5S 5eURA5 O![RBa Of=f[E[FRF"5S U --[I55nU S:aUR"R%SU U5 [JRL"U5 GM)a Downloads bytes from key to fp, resuming as needed. Args: fp: File pointer into which data should be downloaded. start_byte: Start byte of the download. end_byte: End byte of the download. key: Key object from which data is to be downloaded headers: Headers to send when retrieving the file callback: (optional) a callback function that will be called to report progress on the download. The callback should accept two integer parameters. The first integer represents the number of bytes that have been successfully transmitted from the service. The second represents the total number of bytes that need to be transmitted. num_callbacks: (optional) If a callback is specified with the callback parameter, this determines the granularity of the callback by defining the maximum number of times the callback will be called during the file transfer. hash_algs: Dict of hash algorithms to apply to downloaded bytes. Raises: ResumableDownloadException on error. rr@z bytes=%d-%dRange)override_num_retriesrC)rrNrzCaught exception (%s)rzBCaught boto.exception.ResumableDownloadException (%s) - will retryzeToo many resumable download attempts failed without progress. You might try this download again laterzWGot retryable failure (%d progress-less in a row). Sleeping %d seconds before re-trying)'r HTTPExceptionIOErrorsocketerrorgaierrorrRrSrr*recopypopget_filertrnflushrinforeprrerrnoEPIPErrrr dispositionResumableTransferDispositionABORT_CUR_PROCESSmessagetellcloseIncompleteReadminrandomr)timesleep)rkfprlrarTrrmrBrCretryable_exceptionsr num_retriesprogress_less_iterationslast_progress_byte cb_handlerrsleep_time_secss rYrZ)BotoTranslation._PerformResumableDownloads@(55w "OO- JJ ! ! ' 'E/K # 6$1*G ,,. g  ++g (J+AA / ,,r!$,-!*  ,   / ,,r!$,-  / /". A: ++  2DG < a ! !agg&< ]]d " LL #&./  1 LL #&./#,  . ^^ 6 6$ MM NN 7 7 I I J*1995 5 aZ KK   $ $779j  ('#$  A% ! /( @A A   ' '   FMMOq2J/JK,.0o !  '(@   jj!s sb%;C=!C?C='C:7C=9C::C==IB F6F66!IA3IIJJ/.J/c RUn URUUUS9n UR5n [X0R5n 0n [ 5nSn[ R "U 5H#unnSnUcURU5 MUU U'M% URXk5 U(aU RU USU S9 UR(a@[R"UR5nU RUR!5UU S9 U(a>U R#5nUU;a[%SU-5eU R'XJR(U S9 UR+UUUUS 9$![anURUUUUS9 SnANSnAff=f![anURUUUUS9 SnANSnAff=f) rrFTNrr3)key_namerr)rr)_StorageUriForObjectrr?rr$six iteritemsaddr set_metadatarrrr8rrrrr rrr4)rkrrrrrrrrr object_urir meta_headers metadata_plusmetadata_minusmetadata_changedkvrrrs rYPatchObjectMetadata#BotoTranslation.PatchObjectMetadatas A**;+66@+BJ%%'G,X}}ELMUN l+1 1 a , ##M; @ . %(/  1||228<<@h@x0(3'.  0**,k ; &9JFGG%;%;WM  ! !+"--7)/ " 11/*@ ((5@5@4> ) @@*@ ((5@5@4> ) @@s0E!F E=!E88E= F& F!!F&c ,URUUUUUSS9 g)NT)md5policyrkrrewind)set_contents_from_file)rkdst_uri upload_streamrrrDrs rY_PerformSimpleUpload$BotoTranslation._PerformSimpleUpload^s( ""='**4&7+2*. #0r[cUR5R5(aURUUUUS9 g[R"5upg[ US5nUR [5n U (a/URU 5 UR [5n U (aM/SSS5 [ US5n URU UUS9 SSS5 [R"U5 [R"U5 g!,(df  Na=f!,(df  NL=f![R"U5 [R"U5 f=f)N)rrkrwbrb)rr) get_providersupports_chunked_transferset_contents_from_streamtempfilemkstempopenreadr-writerosrunlink) rkrrrrDrtemp_fh temp_pathout_fp stream_bytesin_fps rY_PerformStreamingUpload'BotoTranslation._PerformStreamingUploadls 7799 &&}.8*;/6'8&--/w  )T "f&++,DE, LL &(--.FGL # )T "e  ( (0:18 ) :#  )# " # "  )s= D$A D'D$;D D$ D D$ D!D$$.Ec V[UURUS9n U RUUUUUUS9 g)N) resume_url)rrkr)rrSendFile) rkrTr upload_sizetracker_callbackrrbrDrresumable_uploads rY_PerformResumableUpload'BotoTranslation._PerformResumableUploadsC++;+/;;6HJc+))3!2&- /r[c[U5 UR5nUR[XR55 UR (aQSU;a*US==SUR R S5-- ss'O!SUR R S5-US'UR(aQSU;a*US==SURR S5-- ss'O!SURR S5-US'SU;aUS(dSUS'URX#5 URURUR5nX44$) zShared upload implementation. Args: object_metadata: Object metadata describing destination object. preconditions: Optional gsutil Cloud API preconditions. Returns: Headers dictionary, StorageUri for upload (based on inputs) z x-goog-hashz ,crc32c=%s z crc32c=%sz,md5=%szmd5=%s content-typezapplication/octet-stream) r,rupdater?rcrc32crstripmd5HashrrrRr)rkobject_metadatarrrs rY _UploadSetupBotoTranslation._UploadSetupsKo.%%'G NN,_mmLM ' ! <#2#9#9#@#@#F$G H#."1"8"8"?"?"E#F  ' ! 9#2#:#:#A#A$#G$H I#+"1"9"9"@"@"F#G  )@ :gn##M;''(>(>(7(<(<>G  r[c URX!5 UR5nURURUS9US9$![R R anUR(ar[RURR[55(a;[SR[R"SUR -555eeSnAff=f)aSet ACLs on an uploaded object and return its metadata. Args: dst_uri: Generation-specific StorageUri describing the object. object_metadata: Metadata for the object, including an ACL if applicable. fields: If present, return only these Object metadata fields. Returns: gsutil Cloud API Object metadata. Raises: CommandException if the object was overwritten / deleted concurrently. rrrzUploaded object (%s) was deleted or overwritten immediately after it was uploaded. This can happen if you attempt to upload to the same object multiple times concurrently.N) _SetObjectAclrr(get_keyrrInvalidUriErrorrNON_EXISTENT_OBJECT_REGEXmatchencoder1r jointextwrapwrapuri)rkrrrrrs rY_HandleSuccessfulUpload'BotoTranslation._HandleSuccessfulUploads 2'')g  " "7??7?#C*0#22 >> ) )  066qyy7G7G7MNNtyy MMB      s=AC'BC""C'c*UR5nUR(a?[R"UR5nUR UR 5US9 gUR S:Xa#[U5nU(aUR XSS9 ggg)zCSets the ACL (if present in object_metadata) on an uploaded object.rrN)rrr8rrrrrC)rkrrrrs3_acls rYrBotoTranslation._SetObjectAcls}%%'G22?3F3FGh (//+W= $ ,_=f F4  r[c U (a [S5eURS:XaURUUUUU US9$URUUS9upU(d[ SU-5eUR UR U S9UUUUUUU S9 URUUU S9$![aPn[URUR5nURUURURUS 9 S nAg S nAff=f) rz.XML API does not support gzip-encoded uploads.r)rrrrrz;No tracker callback function set for resumable upload of %sr)rrbrDrrrrnot_found_exceptionN) NotImplementedErrorr UploadObjectrrrnew_keyrrr<rRrr)rkrrrrrrbrrDencryption_tuplerr gzip_encodedrrrrs rYUploadObjectResumable%BotoTranslation.UploadObjectResumablesB  : << }}   }.*4-:&,$( ** ((7D)FG  79@A BBP ""7??7?#C#0#'#3.86H5F+2#4 ) )'*917*99 (PA --//1 &&q3B3I3I3B3G3G;N'PPs3B C-AC((C-c NU (a [S5eURUUS9upURU UUUU S9 URU UUS9$![aPn [ UR UR5n URU URURU S9 Sn A gSn A ff=f)r-XML API does not suport gzip-encoded uploads.r)rrDrrrN) rrrrrr<rrRrr)rkrrrrDrrrrrrrrrs rYUploadObjectStreaming%BotoTranslation.UploadObjectStreaming!s  O PP((7D)FGP ""7#0.85F+2 #4  ) )'*917*99 (PA --//1 &&q3B3I3I3B3G3G;N'PPs#A B$ABB$c U (a [S5eURUUS9upSn UR(a0[UR5URR S5/n UR U UU UUU S9 UR U UU S9$![aPn[URUR5nURUURURUS9 SnAgSnAff=f)rrrNz "')rrrDrrr) rrrr4striprrrr<rrRrr)rkrrrrrrDrrrrrrrrrs rYrBotoTranslation.UploadObjectBs  O PP((7D)FGP c   O33 4  # # ) )' 2   -$'+52C(/  1  ) )'*917*99 (PA --//1 &&q3B3I3I3B3G3G;N'PPsA'B C(AC##C(cUnUR5nURX75 URUUUS9nURSUS9 g![an UR U UUUS9 Sn A gSn A ff=f)rrFrr3N)rrr delete_keyrr) rkrrrrrrrrrs rY DeleteObjectBotoTranslation.DeleteObjectms A%%'G##M;  # #K$//9 $ ;C> nneWn5 '> &&q3>3>2<'>>sA A-A((A-c tU n Ub [S5eURURUR5n SnURS:XaUnSnUR 5nUR [X R55 URX_5 U(aXOU R5R'UR(aSOSnURS:Xa[U5nU(aSnUR=(d SnU RURURUUUUUS9nURUU S9$![ apn[#URURURURURUS9nUR%UURURUS 9 SnAgSnAff=f) rNz*XML API does not suport max_bytes_per_callrTF) preserve_aclrrsrc_version_idsrc_generationr) src_providersrc_bucket_namesrc_object_namerr)rrrRrrrrr?rr acl_headerrrCrcopy_keyr(rr<r)rksrc_obj_metadatadst_obj_metadatarrrrDmax_bytes_per_callrrdrrrrrrrrdst_storage_classrrrs rY CopyObjectBotoTranslation.CopyObjects A%  L MM''(8(?(?(8(=(=?G N }}%nn%%'G NN,-=}}MN##M;3=g""$//0+//4UL }},-=>f  )55=P  !1!8!8!1!6!6.:)0/@0>0> !@g " "76 " :: ' PA --  ! !}}*11*//' ) &&q3C3J3J3C3H3H;N'P Ps8D== F7A&F22F7cUn[U5 URnSUlURn SUlUR5n U R [ X R 55 URX:5 UR(d[UlURU S'URX5n /n UH9n URU U RU RS9nU RU5 M; U RXS9 URU UUS9$![a0nUR!XRUR5 SnAgSnAff=f)rNrrrr)r,rrRrrr?rr contentTyper>rrappendcomposer4rr)rksrc_objs_metadatarrrrrr dst_obj_namedst_bucket_namerrsrc_componentssrc_objsrc_urirs rY ComposeObjectBotoTranslation.ComposeObjectsO A./#((L &--O"%%'G NN,-=}}MN##M;  ' '%9" 0 <  oono6  # #O$0+1$33 (> &&q*A*A'7'<'<>>>s7D E!&E  EcU(a]URS:XaLURb[UR5US'URb[UR5US'gggg)z'Adds preconditions (if any) to headers.rNzx-goog-if-generation-matchzx-goog-if-metageneration-match)r gen_matchrmeta_gen_match)rkrrs rYr*BotoTranslation._AddPreconditionsToHeaderssc$.  ,03M4K4K0L,-  % % 147  ( (5*01 2/}r[cd0nUR(aURUR5 URS:XaURUS'URS:Xa UR(aURUS'[ R R[5nU(aX!['U$)z:Creates base headers used for all API calls in this class.rzx-goog-api-versioncookie) rrrrrrenvironrPr.r/)rk base_headersrequest_reasons rYr"BotoTranslation._CreateBaseHeaderssL $++, }}+/+;+;l'( }}!6!6#44l8ZZ^^$:;N0>,- r[cU(a:[RU5(aURS5R5$gg)zReturns an MD5 from the etag iff the etag is a valid MD5 hash. Args: src_etag: Object etag for which to return the MD5. Returns: MD5 in hex string format, or None. "'N) MD5_REGEXsearchrr)rksrc_etags rY_GetMD5FromETagBotoTranslation._GetMD5FromETag s6I$$X.. ^^E " ( ( **/xr[c|[R"UR<SU<3SURURSS9$)zReturns a boto storage_uri for the given bucket name. Args: bucket: Bucket name (string). Returns: Boto storage_uri for the bucket. ://F)rrrr)rrrrr)rkrRs rYr$BotoTranslation._StorageUriForBuckets9   ]]F+ %!%!>!>jj  r[cUR<SU<SU<3nU(aUSU-- n[R"USURURS9$)aReturns a boto storage_uri for the given object. Args: bucket: Bucket name (string). object_name: Object name (string). generation: Generation or version_id of object. If None, live version of the object is used. Returns: Boto storage_uri for the object. r&/z#%sFr)rrrrr)rkrRrr uri_strings rYr$BotoTranslation._StorageUriForObject)sO"& DJEJ&&j    %!%!>!>jj  r[cURUUUS9nUR5nURUS9nU(d[SURUUUS9eU$![ anUR UUUUS9 SnAgSnAff=f)zGets the boto key for an object. Args: bucket_name: Bucket containing the object. object_name: Object name. generation: Generation or version of the object to retrieve. Returns: Boto key for the object. rr404r3N)rrrr=rrr)rkrrrrrrTrs rYr'BotoTranslation._GetBotoKey>s**;+66@+BJ>'')g   w  /c +E,0MM,7,77A C C j '> &&q3>3>2<'>>s>A A8A33A8c< URUR5n[R"URURS9nUR 5nUR S:XGa U(aSU;a&[ US5(aUR5UlU(aSU;aF[R"URUS95HnURRU5 M U(aS U;a+UR'US9n [(R*"U 5UlU(aS U;aF[R."UR1US95HnUR2RU5 M U(aS U;aTUR5US9R6n U (a3[RR95UlXR:lU(aS U;a+UR?US9n [@RB"U 5Ul"U(aS U;aURGUS9n U (a|SU ;avU Sn SU ;nSU ;nU(dU(aY[RRI5Ul%U(aU SURJl&U(aU SURJl'U(aSU;aURQUS9nU(a|SU;avUSnSU;nSU;nU(dU(aY[RRS5Ul*U(aUSURTl+U(aUSURTl,U(aSU;aUR[US9Ul.U(aSU;a;UR_5Ra5n[bRd"U5Ul3U(aSU;aURqUS9nU(auUR S:Xa3SU;a-USS:Xa$[RRsSS9Ul:U$UR S:Xa"[RRsSS9Ul:U$![a_nURXqRS9nU(a[!U["5(aSnAGNUR%XqRS9 SnAGNSnAff=f![a$nUR%XqRS9 SnAGNSnAff=f![a_nURXqRS9nU(a[!U["5(aSnAGNUR%XqRS9 SnAGNSnAff=f![a$nUR%XqRS9 SnAGNSnAff=f![a$nUR%XqRS9 SnAGNSnAff=f![a$nUR%XqRS9 SnAGN7SnAff=f![a$nUR%XqRS9 SnAGNSnAff=f![hRjRla,nUR S:XaURnS:XdeSnAGNSnAff=f![a$nUR%XqRS9 SnAGNSnAff=f)zConstructs an apitools Bucket from a boto bucket. Args: bucket: Boto bucket. fields: If present, construct the apitools Bucket with only this set of metadata fields. Returns: apitools Bucket. )ridrrget_storage_classrrrNrr encryptionrrLoggingLogObjectPrefix LogBucketrWebsiteConfigurationMainPageSuffix NotFoundPagerrrrr VersioningEnabledT)r);rrapitools_messagesBucketrrhasattrr1rr8BotoBucketAclToMessageget_aclrr rrrrrget_corsr:BotoCorsToMessagerBotoObjectAclToMessage get_def_aclrget_encryption_configdefault_kms_key_nameEncryptionValuer2defaultKmsKeyNameget_lifecycle_configrABotoLifecycleToMessagerget_logging_config LoggingValuerrrget_website_config WebsiteValuerrr get_locationrrget_tagsr@BotoTagsToMessagerrrStorageResponseErrorrrVersioningValuer)rkrRrrcloud_api_bucketrrrr rkeynamer boto_logginglogging_configlog_object_prefix_presentlog_bucket_present boto_websitewebsite_configmain_page_suffix_presentnot_found_page_presentrrs rYr#BotoTranslation._BotoBucketToBucket]s**6;;7J(//V[[39;;@%%'G }} ~/ 6. / /*0*B*B*D  ' u I#::nnWn-/c  ' ' ,/v' G ))'):)"1"C"CI"N  )V3 I#::   13c  - - 4 4S 93|v- G55633  !((88:  ' (,>):)A)A)N)N)P&*"#45!((8#5CK5P ((2yF* G#66w6G, 4 D)*@AN'7>'I $%3~%E "'+A):)A)A)N)N)P&)"#34!((7'">2!((5zV+$.$;$;G$;$L! X'E  ++-668)00;  ! \V+33G3Dj  MMT !lj&@ | $ 1&&66t6D  % ]]d "&&66t6D  % g, I!%!=!=[[">"* "-/DEE   , ,QKK , H I, G  * *1++ * F G, I!%!=!=[[">"* "-/DEE   , ,QKK , H I$, G  * *1++ * F G, G  * *1++ * F G , G  * *1++ * F G", G  * *1++ * F G~~22  --4'AHHO -<  *E (( (DEs'AQ:*R?2AS0AU&*V BV>>BW/9X  R<5R7R77R<? S- S((S-0 U:5U5UU V &VV  V;V66V;> W,W''W,/ X9XX Y*>!Y%Y-%Y**Y-- Z7ZZcSnU(a=SU;d7[UVs/sHoDRS5(dMUPM sn5S:aURU5nSnU(aSU;a [USS5nSnU(aSU;a [USS5nSnU(aS U;a [US S5nUR U5nSn U(aS U;aUR U5n Sn U(aS U;aUR U5n Sn U(aS U;a%[US S5n U (aU RS5n Sn U(aSU;aS[US5(aBSUR;a2[R"URS5RS5n Sn U(aSU;a[US5(aCSUR;a3[R"URS5RS5n O}UR[US S55(a%[URUR55n O7UR S:Xa'UR"R%SURU5 SnU(aSU;a9[&R("[*R,"U[*R.55nSnU(aSU;aUR0=(d SnSnU(aSU;a [USS5n[2R4(aZU (a&[7U [85(aU R;S5n U (a&[7U [85(aU R;S5n [<R>"S$0SUR@RB_SURB_SU_SURD_SURF_S URH_SU_S U_S U _SU _SU _S!U_S U _SU_S U _SU_SU_SU_6nURKUU5 U(aS"U;a0[M[OUR 5U5nURQUUUS#9 U$s snf)%zConstructs an apitools Object from a boto key. Args: key: Boto key to construct Object from. fields: If present, construct the apitools Object with only this set of metadata fields. Returns: apitools Object corresponding to key. Nrz metadata/r cacheControl cache_controlcomponentCountcomponent_countcontentDispositioncontent_dispositionr timeCreatedrrr cloud_hashes rrrzMNon-MD5 etag (%s) present for key %s, data integrity checks are not possible. mediaLinkrrr_storage_classasciirRrcontentEncodingcontentLanguager rrrrb))lenr_TranslateBotoKeyCustomMetadatar&_TranslateBotoKeyGeneration_TranslateBotoKeyMetageneration_TranslateBotoKeyTimestamprr=rfbase64 b64encoderr#r3rrrwarnrT b2a_base64rSdumpsHIGHEST_PROTOCOLrrPY3rbytesdecoder;ObjectrRrcontent_encodingcontent_language content_type_TranslateDeleteMarkerr$r%_TranslateBotoKeyAcl)rkrTrcustom_metadatarr`rbrdrr time_createdrrmd5_hash media_linkrrcloud_api_objectgeneration_strs rYr( BotoTranslation._BotoKeyToObjectsO Z6)S"DF5&6&6{&CFD.FIJ.K<E11#6JN %/;;C@nL ]f,44S9l D Vv% S&$ 'd zz%  F X' n % %(c6F6F*F!!#"2"28"<=DDUKH Y&( n % %%33C3C*C##C$4$4U$;<CCEJ   VT : ; ;#D$8$8$BC ==D    XXs , J [F*&& ,,sF33 46j D Vv% XX]dM ^v- c#3T:m ww Jvu--w' j511??7+(//$zz$ XX$$,, $ ,, $ $$ $#$/$$$$$&$'$!$ !!$"#$$#%$* %56 Uf_1 t}} -z;n  0+9 ; C Es QQchSn[USS5(a[RR/S9n[R "UR 5H\up4UR5S:XaMURR[RRRUUS95 M^ U$)zCPopulates an apitools message from custom metadata in the boto key.Nr)additionalPropertieszcontent-languagerTr) r&r;r{ MetadataValuerrrrrr AdditionalProperty)rkrTrrrs rYrn/BotoTranslation._TranslateBotoKeyCustomMetadata[sOsJ%%)00>>!?#o-- -$! 779* * ,,33  $ $ 2 2 E E!LM F O P . r[cSnURS:Xa)[USS5(a[UR5nU$URS:Xa'[USS5(a[ UR 5nU$)zFReturns the generation/version_id number from the boto key if present.Nrrrr)rr&longrr7r)rkrTrs rYro+BotoTranslation._TranslateBotoKeyGenerationjsiJ }} lD ) )#..)   $  lD ) )'7 r[cxSnURS:Xa'[USS5(a[UR5nU$)z?Returns the metageneration number from the boto key if present.Nrr)rr&rr)rkrTrs rYrp/BotoTranslation._TranslateBotoKeyMetagenerationus9N }} & - -c001 r[cUR(aoSUR;aURRS5S-nOURRS5S-nSn[RRX#5$g![aA Sn[RRURU5s$![a gf=ff=f)zParses the timestamp from the boto key into an datetime object. This avoids a dependency on dateutil. Args: key: Boto key to get timestamp from. Returns: datetime object if string is parsed successfully, None otherwise. .Z000Zz.000000Zz%Y-%m-%dT%H:%M:%S.%fZz%a, %d %b %Y %H:%M:%S %ZN) last_modifiedrdatetimestrptime ValueError)rkrTkey_us_timestampfmts rYrq*BotoTranslation._TranslateBotoKeyTimestamp}s  !! !,,33C86A,,33C8:E #c   ))*:@@ *#""++C,=,=sC C   s0"B C  +B;8C ; C C C  C cX[U[5(aUR(d4[RR 5Ul/URlURR R[RR R[SS95 gg)zCMarks deleted objects with a metadata value (for S3 compatibility).TrN) rrrr;r{rrr rr0)rkrTrs rYr&BotoTranslation._TranslateDeleteMarkers#|$$  & &$5$<$<$J$J$L!9;!!644;;  " " 0 0 C C't D 56 %r[cURURRURUS9nUR5nURS:XaGUR US9n[ R"U5HnURRU5 M URS:XaURUS9n[X&5 gg![RRanURS:XaSnAgeSnAff=f)z8Updates cloud_api_object with the ACL from the boto key.rrrrN)rrRrrrr?r8rBrr  get_xml_aclr9rrrr) rkrTrrstorage_uri_for_keyrkey_aclrrs rYr$BotoTranslation._TranslateBotoKeyAcls33CJJOO47HH?I4K%%'G $ %--g->"88AC    % %c *B $ //'/2 ''7A  >> ) ) S  sBCC="C87C88C=c<URUUUUUS9nU(aUee)aTranslates a Boto exception and raises the translated or original value. Args: e: Any Exception. bucket_name: Optional bucket name in request that caused the exception. object_name: Optional object name in request that caused the exception. generation: Optional generation in request that caused the exception. not_found_exception: Optional exception to raise in the not-found case. Raises: Translated CloudApi exception, or the original exception if it was not translatable. )rrrr)r)rkrrrrrr s rYr+BotoTranslation._TranslateExceptionAndRaises7& 77 / 81    r[cf[U[RR5(GaURS:Xa)[ UR URURS9$URS:XdURS:Xa)[UR URURS9$URS:XaU(a[USUR5 U$U(aIU(a![URURUUUS9$[URURU5$[URURURS9$URS:XaCUR (a2S UR ;a"[S U-URURS9$URS :Xa[!UR5$URS :Xa)[#UR URURS9$[U[RR$5(a['S URURS9$[U[RR(5(a)['URURURS9$[U[RR*5(a^UR(a8[,R/UR5(a[URSS9$[1UR5$[U[RR25(aUR4[RR6R8:Xa[;UR5$UR4[RR6R<:Xa[!UR5$[3UR5$[U[RR>5(a[?UR5$g)a,Translates boto exceptions into their gsutil Cloud API equivalents. Args: e: Any exception in TRANSLATABLE_BOTO_EXCEPTIONS. bucket_name: Optional bucket name in request that caused the exception. object_name: Optional object name in request that caused the exception. generation: Optional generation in request that caused the exception. not_found_exception: Optional exception to raise in the not-found case. Returns: ServiceException for translatable exceptions, None otherwise. Because we're using isinstance, check for subtypes first. i)rbodyirrrrirriizBucket already exists.rN) rrrrQrrcoderrrQr=rr;rrrrrStorageCreateErrorrBotoServerErrorrrrr!rrrABORTr START_OVERr)rkrrrrrs rYr'BotoTranslation._TranslateBotoExceptions*!T^^8899 S"166!((HH 88s?ahh#o$QVVAHH166JJ 88s?  %x :$ $  0151<1<>?? ' 22 r[c [R"URSURURS9nU(aUR 5$UR 5$![anURU5 SnAgSnAff=f5See CloudApiDelegator class for function doc strings.FrN) rr url_stringrrrCr?rr)rk storage_url def_obj_aclrrs rYXmlPassThroughGetAcl$BotoTranslation.XmlPassThroughGetAcl/sr *     "'#'#@#@  c   {{} '* &&q))*sA AA B(A>>BclUR5n[R"URSURUR S9nU(aU(a>UR 5nX;a[SU-5eURXRUS9 gUR 5nX;a[SU-5eURXRUS9 gU(aURXRUS9 gURXRUS9 g![anURU5 SnAgSnAff=f)rFrrrN)rrrrrrrr rrrrrrr) rkacl_textrcannedrrrrrs rYXmlPassThroughSetAcl$BotoTranslation.XmlPassThroughSetAcl>s %%'G*     "'#'#@#@  c  )+  ("#=#HI I //(OOW/ E)+  ("#=#HI I ++h+ A   h  I //(OOW/ E '* &&q))*s*BD=D!D3D D3D..D3c tUR5nURS:Xa [5nO [5n[R "US5n[ RRX5 [R "UR"SUR$UR&S9nUR)USUS9 g![RaFn[SUR5<SUR5<SUR5<35eSnAff=f![*anUR-U5 SnAgSnAff=f) rrNzRequested CORS is invalid: at line , column Frr)rrS3Corsr r XmlHandlerxmlsaxr SaxExceptionsSAXParseExceptionr getMessage getLineNumbergetColumnNumberrrrrrrrr)rk cors_textrrcors_objhrrs rYXmlPassThroughSetCors%BotoTranslation.XmlPassThroughSetCors_s %%'GT!hh8T*AD gg)'*     "'#'#@#@  c  ll8UGl4  * *D  <<>1??,a.?.?.A C DDD (* &&q))*2B5.AD5D AD  D D7D22D7cUR5n[R"URSURUR S9nUR SUS9n[RRRWR5R[55nUR!SS9$![anURU5 SnANySnAff=frFrrNz )indent)rrrrrrr@rrrdomminidomrrrr1 toprettyxml)rkrrrrr parsed_xmls rYXmlPassThroughGetCors%BotoTranslation.XmlPassThroughGetCorszs%%'G    %!%!>!>jj  C * \\%\ 1d,,T[[]-A-A$-GHJ  ! ! ! 00 (* &&q))*sB00 C:CCcUR5n[R"URSURUR S9nUR SUS9n[RRRWR5R[55nUR!SS9$![anURU5 SnANySnAff=fr)rrrrrrrHrrrrrrrrr1r)rkrrrrrrs rYXmlPassThroughGetLifecycle*BotoTranslation.XmlPassThroughGetLifecycles%%'G*     "'#'#@#@  c **5'*Bi,,Y-=-=-?-F-Ft-LMJ  ! ! ! 00 (* &&q))*sAB00 C:CCc tUR5nURS:Xa [5nO [5n[R "US5n[ RRX5 [R "UR"SUR$UR&S9nUR)USUS9 g![RaFn[SUR5<SUR5<SUR5<35eSnAff=f![*anUR-U5 SnAgSnAff=f) rrNz'Requested lifecycle config is invalid: rrFrr)rr S3Lifecycler r rrrrrrr rrrrrrrrrrr)rklifecycle_textrr lifecycle_objrrrs rYXmlPassThroughSetLifecycle*BotoTranslation.XmlPassThroughSetLifecycles %%'GT!!mm%'m=$/AD gg., *     "'#'#@#@  c  mUGD  * *D  <<>1??,a.?.?.A C DDD (* &&q))*rc@UR5n[R"URSURUR S9n[ URUS95n[W5R5$![anURU5 SnAN9SnAff=frFrrN) rrrrrrrDrJrrXmlParseStringr)rkrrrlogging_config_xmlrs rYXmlPassThroughGetLogging(BotoTranslation.XmlPassThroughGetLoggings%%'G *     "'#'#@#@  c *  13 , - 9 9 ;; (* &&q))*A A88 BBBcLUR5n[R"URSURUR S9nUR 5R5n[W5R5$![anURU5 SnAN9SnAff=fr) rrrrrrr get_xml_tagsrrrr)rkrrrtagging_config_xmlrs rYXmlPassThroughGetTagging(BotoTranslation.XmlPassThroughGetTaggings%%'G *     "'#'#@#@  c>>+88: , - 9 9 ;; (* &&q))*sAA>> B#BB#c VUR5n[5n[R"US5n[R R X5 [R"URSUR UR"S9nUR%5R'XCS9 g![RaFn[SUR5<SUR5<SUR5<35eSnAff=f![(anUR+U5 SnAgSnAff=f)rNz,Requested labels/tagging config is invalid: rrFrr)rrr rrrrrrr rrrrrrrrrrrr)rk tagging_textrrtags_objrrrs rYXmlPassThroughSetTagging(BotoTranslation.XmlPassThroughSetTaggings%%'GvH8T*AK gg,* *     "'#'#@#@  c nn:  * *K ,,.!//"3Q5F5F5H J KKK (* &&q))*s1B&AD&D:AC;;D D( D##D(c@UR5n[R"URSURUR S9n[ URUS95n[W5R5$![anURU5 SnAN9SnAff=fr) rrrrrrrDrLrrrr)rkrrrweb_config_xmlrs rYXmlPassThroughGetWebsite(BotoTranslation.XmlPassThroughGetWebsites%%'G*     "'#'#@#@  c &c&<&&#*# $!%).'/'@'@'I'I !"'+(,#&*qMl044J%)'+ 00)-)-.D*.B"P&*%)(,#'!%>1F $&*-1#' 0"*.04&* D*.1504&*/&%NB 5(,*.!%/3-1.2-1%)#').0Pj(,.2*.-1%)#').PH#!%%)$(  %)P\"&" >2!% ##'$("&"&DPR#'%)! )>V* + *>>L\n`  86:/3.2-16:  @+/*.)-26 Pf *$#'', *B*61"1"*4< <"*0 8 8r[r})rz __future__rrrrrrrTrrrQrrSrrervrr threadingrrxml.dom.minidomrrxml.saxrrr six.movesr rr r boto.gs.corsr boto.gs.lifecycler boto.s3.corsrrboto.s3.deletemarkerrboto.s3.lifecyclerrboto.s3.prefixrboto.s3.taggingrboto.exception boto.utilsgslib.boto_resumable_uploadrgslib.cloud_apirrrrrrrrrrrrgslib.devshell_auth_plugingslibgslib.exceptionr r!gslib.project_idr"r#gslib.storage_urlr$r%"gslib.third_party.storage_apitoolsr&r; gslib.utilsr'gslib.utils.boto_utilr(r)r*gslib.utils.cloud_api_helperr+r,gslib.utils.constantsr-r.r/r0r1r2gslib.utils.hashing_helperr3r4gslib.utils.metadata_utilr5&gslib.utils.parallelism_framework_utilr6gslib.utils.text_utilr7gslib.utils.translation_helperr8r9r:r;r<r=r>r?r@rArBrCrDgslib.utils.unit_utilrErxrWrrrrrrQrLockr_racompileDOTALLrr rZrcr]rer}rbr[rYrsF&%'   90 ! -4-6! ;1-/$--1694=,!,+-.82W2;2/8B:8;7&876CJ49I:HPH?D;?=H9)77 $ $ > > $ > > $ I I $ G G $ A A $ C C  E'^^-JJ'D-/YY8 JJ/ 0  H @F6F$N8hN8r[