-pj?"SrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK J r SSK J r SSKJrJrJr SSKJrJrJrJr SSKrSSKrSSKrSSKrSSKJr SSKJr SS KJr SS KJ r SS K!J"r" SS K!J#r# SS K!J$r$ SSK%J&r& SSK%J'r' SSK%J(r( SSK%J)r) SSK%J*r* SSK+J,r, SSK-J.r. SSK-J/r/ SSK-J0r0 SSK1J2r2 SSKJ3r3 SSK4J5r6 \Rn"\85r9Sr:Sr;Sr"SS \ 5r?"S!S"\@5rA"S#S$\@5rBg)%z. This module provides a client class for BOS. N)str)bytes) iteritemsiterkeys itervalues)ThreadPoolExecutorwait ALL_COMPLETEDFIRST_COMPLETED)bce_client_configuration)utils) bce_v1_signer) BceBaseClient)BceClientError)BceServerError)BceHttpClientError)bce_http_client)handler)http_content_types) http_headers) http_methods)bos) bos_handler)common) storage_class)required)compatssyncsasyncAES256shttpc*\rSrSrSrSrSrSrSrg)UploadTaskHandleAz7 handle to control multi upload file with multi-thread cFSUl[R"5UlgNF) cancel_flag threadingLock cancel_lockselfs \/var/www/html/pdf-tiff/venv/lib/python3.13/site-packages/baidubce/services/bos/bos_client.py__init__UploadTaskHandle.__init__Es $>>+czURR5 SUlURR5 g)z9 cancel putting super object from file with multi-thread TNr'acquirer$releaser(s r*cancelUploadTaskHandle.cancelIs0   "   "r-cURR5 URnURR5 U$)z get cancel flag r/)r)results r* is_cancelUploadTaskHandle.is_cancelQs8   "!!   " r-)r$r'N) __name__ __module__ __qualname____firstlineno____doc__r+r2r6__static_attributes__r-r*r r As,#r-r c ~\rSrSrSrSSjrSSjr\"\\ 4S9SSj5r \"\\ 4S9SSj5r \"\\ 4S9SS j5r \"\\ 4S9SS j5r \S 5r\"\\ 4\\4S 9SS j5r\"\\ 4\4S9SSj5r\"\\ 4\\ 4S9SSj5r\"\\ 4S9SSj5r\"\\ 4S9SSj5r\"\\ 4S9SSj5r\"\\ 4S9SSj5r\"\\ 4S9SSj5r\"\\ 4S9\S4Sj5r\"\\ 4S9SSj5r\"\\ 4S9SSj5r\"\\ 4\4S9SSj5r\"\\ 4S9SSj5r\"\\ 4S9SSj5r \"\\ 4\4S9SSj5r!\"\\ 4S9SS j5r"\"\\ 4S9SS!j5r#\"\\ 4S9SS"j5r$\"\\ 4S9SS#j5r%\"\\ 4\4S$9SS%j5r&\"\\ 4\\ 4S&9SS'j5r'\"\\ 4\\ 4S&9SS(j5r(\"\\ 4S9SS)j5r)\"\\ 4S9SS*j5r*\"\\ 4S9SS+j5r+\"\\ 4S9SS,j5r,\"\\ 4\\ 4S-9S.S/SSSSS\-R\4S0j5r/\"\\ 4\\4S19SS2j5r0\"\\ 4S9SS3j5r1\"\\ 4S9SS4j5r2\"\\ 4\4S59SS6j5r3\"\\ 4S9SS7j5r4\"\\ 4S9SS8j5r5\"\\ 4S9SS9j5r6\"\\ 4S9SS:j5r7\S;5r8\S<5r9\"\\ 4\\ 4S-9SS=j5r:\"\\ 4\\ 4S-9SS>j5r;\SS?j5r<\S@5r=\"\\ 4\\ 4S-9SSAj5r>\"\\ 4\\ 4\\ 4SB9SSCj5r?\"\\ 4\\ 4S-9SSDj5r@\"\\ 4\\ 4\A4\BR4SE9SSFj5rD\"\\ 4\\ 4\\ 4SG9SSHj5rE\"\\ 4\\ 4\A4\BR4SE9SSIj5rF\"\\ 4\\ 4\\ 4SJ9SSKj5rG\"\\ 4\\ 4\\ 4SL9SSMj5rH\"\\ 4\\ 4\\ 4\\ 4SN9SSOj5rI\"\\ 4\\ 4S-9SSPj5rJ\"\\ 4\4SQ9SSRj5rK\"\\ 4\\ 4\\ 4SS9SSTj5rL\"\\ 4S9SSUj5rM\"\\ 4S9SSVj5rN\"\\ 4\\ 4S-9SSWj5rO\"\\ 4\\ 4\\ 4\P4\BR4\A4SX9SSYj5rQ\"\\ 4\\ 4\\ 4\\ 4\\ 4\P4\BR4\BR4SZ9SS[j5rR\"\\ 4\\ 4\\ 4\P4\BR4\\ 4\BR4S\9SS]j5rS\"\\ 4\\ 4\\ 4\4S^9SS_j5rT\"\\ 4\\ 4\\ 4S`9SSaj5rU\"\\ 4\\ 4\\ 4S`9SSbj5rV\"\\ 4\\ 4\\ 4S`9SScj5rW\"\\ 4S9SSdj5rX\"\\ 4S9SSej5rYSSfjrZ\"\\ 4\\ 4\\ 4SB9SSgj5r[\"\\ 4\\ 4\\4Sh9SSij5r\\"\\ 4\\ 4S-9SSjj5r]\"\\ 4\\ 4S-9SSkj5r^\"\\ 4\\ 4S-9SSlj5r_\"\\ 4\\ 4\\ 4Sm9SSnj5r`\"\\ 4\\ 4\\ 4\a4So9SSpj5rb\"\\ 4\\ 4Sq9SSrj5rc\"\\ 4\\ 4\Ss9SStj5rdSSujre\"\P\P4Sv9SSwj5rfSSxjrg\"\\ 4S9SSyj5rh\"\\ 4\4Sz9SS{j5ri\"\\ 4S9SS|j5rj\"\\ 4\4S}9SS~j5rk\"\\ 4S9SSj5rl\"\\ 4S9SSj5rm\"\\ 4\\ 4\4S9SSj5rnSSjro\"\\ 4\\ 4S-9SSj5rp\"\\ 4\\ 4S-9SSj5rq\"\\ 4\\ 4S9SSj5rr\"\\ 4S9SSj5rs\"\\ 4S9SSj5rt\"\\ 4\P4S9SSj5ru\"\\ 4S9SSj5rv\"\\ 4S9SSj5rw\"\\ 4S9SSj5rx\"\\ 4\P4S9SSj5ry\"\\ 4S9SSj5rz\"\\ 4\4S9SSj5r{\"\\ 4S9SSj5r|\"\\ 4S9SSj5r}\"\\ 4\4S9SSj5r~\"\\ 4S9SSj5r\SSj5r\S5r\SSj5rSr\SSj5rSrSr\S5r\S5rSSjrSrg) BosClient[z sdk client Nc0[R"X5 gN)rr+r)configs r*r+BosClient.__init___st,r-c>UR[RUS9$)z List buckets of user :param config: None :type config: BceClientConfiguration :returns: all buckets owned by the user. :rtype: baidubce.bce_response.BceResponse rE _send_requestrGETrDs r* list_bucketsBosClient.list_bucketsbs !!,"2"26!BBr-) bucket_namec`SS0nUR[RXUS9nUR$)z Get the region which the bucket located in. :param bucket_name: the name of bucket :type bucket_name: string or unicode :param config: None :type config: BceClientConfiguration :return: region of the bucket :rtype: str slocationr-paramsrE)rJrrKlocation_constraint)r)rNrErQresponses r*get_bucket_locationBosClient.get_bucket_locationms8s#%%l&6&6 [a%b+++r-c0nUbX%[R'U(a:[RU[R'[ R "SS05nOSnUR[RUUUUS9$)z Create bucket with specific name :param bucket_name: the name of bucket :type bucket_name: string or unicode :param config: None :type config: BceClientConfiguration :returns: :rtype: baidubce.bce_response.BceResponse N enableMultiAzT)headersbodyrE) r BOS_TAG_LISTrJSON CONTENT_TYPEjsondumpsrJrPUT)r)rNtag_list enable_mazrErXrYs r* create_bucketBosClient.create_bucket~s{  19L-- . 1C1H1HGL-- .::56DD!!     "  r-cUR[RXS9 g![an[ UR [ 5(anUR R[RR:XaSnAgUR R[RR:XaSnAgUeSnAff=f)z Check whether there is a bucket with specific name :param bucket_name: None :type bucket_name: str :return:True or False :rtype: bool rHTNF) rJrHEADr isinstance last_errorr status_codehttpclient FORBIDDEN NOT_FOUND)r)rNrEes r*does_bucket_existBosClient.does_bucket_exists    |00+  M! !,,77<<++t{{/D/DD<<++t{{/D/DD G  s!! B?AB:2B:8B::B?cFUR[RUSS0US9$)zp Get Access Control Level of bucket :type bucket: string :param bucket: None :return: **json text of acl** aclr-rPrIr)rNrEs r*get_bucket_aclBosClient.get_bucket_acls2!!  } " r-c~0n[UR5H!up#URS5(aMX1U'M# U$)N_)r__dict__ startswith)aclr5kvs r*_dump_acl_objectBosClient._dump_acl_objects9cll+DA<<$$q , r-)rNryc UR[RU[R"SU0[ R S9[R[R0SS0US9$)z Set Access Control Level of bucket :type bucket: string :param bucket: None :type grant_list: list of grant :param grant_list: None :return: **HttpResponse Class** accessControlListdefaultrqr-rYrXrQrE rJrr_r]r^r@r|rr\rr[)r)rNryrEs r*set_bucket_aclBosClient.set_bucket_aclsd!!,"2"2& $ ,?+E3<3M3M!O$0$=$=?Q?V?V#W#)3-"( "* *r-)rN canned_aclchUR[RU[RU0SS0US9$)zA :param bucket_name: :param canned_acl: :param config: :return: rqr-rXrQrE)rJrr_rBCE_ACL)r)rNrrEs r*set_bucket_canned_aclBosClient.set_bucket_canned_acls?!!,"2"2&$0$8$8*#E#)3-"( "* *r-)rNrc [R"U5nUR[RU[ R "SU0[RS9[R[R0SS0US9$). :param bucket_name: :param config: :return: storageClassr storageClassr-r rconvert_to_stringrJrr_r]r^r@r|rr\rr[)r)rNrrEs r*set_bucket_storage_class"BosClient.set_bucket_storage_classst00? !!,"2"2& $ NM+J3<3M3M!O$0$=$=?Q?V?V#W#2C"8"( "* *r-cFUR[RUSS0US9$)rrr-rPrIrrs r*get_bucket_storage_class"BosClient.get_bucket_storage_classs2!!,"2"2C"8"("* *r-c>UR[RXS9$)z Delete a Bucket(Must Delete all the Object in Bucket before) :type bucket: string :param bucket: None :return: **HttpResponse Class** rHrJrDELETErrs r* delete_bucketBosClient.delete_bucket s !!,"5"5{!RRr-c 0nUbX%S'UbX5S'UR[RU[R"U[ R S9[R[R0SS0US9$)ac Set index page and not_found 404 page for static website trusteeship :type bucket_name: string :param bucket_name: None :type index:string :param index:object name of index page for static website trusteeship :type not_found:string :param not_found:object name of not_found 404 page for static website trusteeship :return: **HttpResponse Class** indexnotFoundrwebsiter-rr)r)rNr not_foundrErYs r*put_bucket_static_website#BosClient.put_bucket_static_websites"  !M  ( !!,"2"2& $ 43<3M3M!O$0$=$=?Q?V?V#W#-s"3"( "* *r-cFUR[RUSS0US9$)z~ Get Information of static website trusteeship :type bucket: string :param bucket: None :return: **HttpResponse Class** rr-rPrIrrs r*get_bucket_static_website#BosClient.get_bucket_static_website7s2!!,"2"2&#-s"3"("* *r-cFUR[RUSS0US9$)z Delete Information of static website trusteeship to be closed :type bucket: string :param bucket: None :return: **HttpResponse Class** rr-rPrrrs r*delete_bucket_static_website&BosClient.delete_bucket_static_websiteHs2!!,"5"5&#-s"3"("* *r-c [R"U5nUR[RU[ R "SU0[RS9[R[R0SS0US9$)a Set server encryption for bucket :type bucket: string :param bucket: None :type encryption_algorithm: string :param grant_list: server encryption algorithm for bucekt.Now the value of encryption_algorithm only is 'AES256' :return: **HttpResponse Class** encryptionAlgorithmr encryptionr-rr)r)rNencryption_algorithmrEs r*put_bucket_encryptionBosClient.put_bucket_encryptionYsx &778LM!!,"2"2& $ ,ABV+W3<3M3M!O$0$=$=?Q?V?V#W#0#"6"( "* *r-cFUR[RUSS0US9$)zp Get status of server encryption :type bucket: string :param bucket: None :return: **HttpResponse Class** rr-rPrIrrs r*get_bucket_encryptionBosClient.get_bucket_encryptionqs2!!,"2"2�#"6"("* *r-cFUR[RUSS0US9$)zh Close server encryption :type bucket: string :param bucket: None :return: **HttpResponse Class** rr-rPrrrs r*delete_bucket_encryption"BosClient.delete_bucket_encryptions2!!,"5"5�#"6"("* *r-)rNresourcec UR[RU[R"SU0[ R S9[R[R0SS0US9$)z Open image copyright protection and set resource :type bucket: string :param bucket: None :type resource: list of string :param grant_list: resource range to be protected :return: **HttpResponse Class** rrcopyrightProtectionr-rr)r)rNrrEs r*put_bucket_copyright_protection)BosClient.put_bucket_copyright_protectionsd!!,"2"2& $ J+A3<3M3M!O$0$=$=?Q?V?V#W#93"?"( "* *r-cFUR[RUSS0US9$)z Get configuration of image copyright protection :type bucket: string :param grant_list: None :return: **HttpResponse Class** rr-rPrIrrs r*get_bucket_copyright_protection)BosClient.get_bucket_copyright_protections2!!,"2"2]"?"("* *r-cFUR[RUSS0US9$)zq Close image copyright protection :type bucket: string :param bucket: None :return: **HttpResponse Class** rr-rPrrrs r*"delete_bucket_copyright_protection,BosClient.delete_bucket_copyright_protections2!!,"5"5]"?"("* *r-)rN replicationc SS0nSU;a[R"US5US'UR[RU[ R "U[RS9[R[R0UUS9$)z Open cross-region replication :type bucket: string :param bucket: None :type replication: dict :type replication: configuration for cross-region replication :return: **HttpResponse Class** replicationr-ididrr rconvert_to_bytesrJrr_r]r^r@r|rr\rr[)r)rNrrErQs r*put_bucket_replication BosClient.put_bucket_replications$ ; "33K4EFF5M!!,"2"2& $ ;3<3M3M!O$0$=$=?Q?V?V#W"("( "* *r-cSS0nUb[R"U5US'UR[RUUUS9$)z Get configuration of cross-region replication :type bucket: string :param bucket: None :type id: string :param id: replication rule id :return: **HttpResponse Class** rr-rrPrrrJrrKr)rNrrErQs r*get_bucket_replication BosClient.get_bucket_replicationsP$ >"33B7F5M!!,"2"2&"("("* *r-cSS0nUb[R"U5US'UR[RUUUS9$)z Delete configuration of cross-region replication and close it :type bucket: string :param bucket: None :type id: string :param id: replication rule id :return: **HttpResponse Class** rr-rrPrrrJrrrs r*delete_bucket_replication#BosClient.delete_bucket_replicationsP$ >"33B7F5M!!,"5"5&"("("* *r-cSS0nUb[R"U5US'UR[RUUUS9$)z Get status of cross-region replication,for exapmle 'historyReplicationPercent', 'latestReplicationTime' :type bucket: string :param bucket: None :type id: string :param id: replication rule id :return: **HttpResponse Class** sreplicationProgressr-rrPrrs r*get_bucket_replication_progress)BosClient.get_bucket_replication_progresssP', >"33B7F5M!!,"2"2&"("("* *r-cHUR[RUSSS.US9$)z list configuration of cross-region replication rule :type bucket: string :param bucket: None :return: **HttpResponse Class** r-)rslistrPrIrrs r*list_bucket_replication!BosClient.list_bucket_replication*s2!!,"2"2&36"E"("* *r-)rN inventoryc [R"US5nUR[RU[ R "U[RS9[R[R0SUS.US9$)z set bucket inventoru :type bucket: string :param bucket: None :type inventory: dict :param inventory: configuration for bucket inventory :return: **HttpResponse Class** rrr- inventoryrrr)r)rNrrEconf_ids r*put_bucket_inventoryBosClient.put_bucket_inventory:ss)))D/:!!,"2"2& $ 93<3M3M!O$0$=$=?Q?V?V#W14W"E"( "* *r-)rNinventory_conf_idcpUR[RUS[R"U5S.US9$)zv Get configuration of bucket inventory :type bucket: string :param bucket: None :return: **HttpResponse Class** r-rrP)rJrrKrrr)rNrrEs r*get_bucket_inventoryBosClient.get_bucket_inventoryQs>!!,"2"2&14V=T=TUf=g"h"("* *r-cpUR[RUS[R"U5S.US9$)zy Delete configuration of bucket inventory :type bucket: string :param bucket: None :return: **HttpResponse Class** r-rrP)rJrrrrrs r*delete_bucket_inventory!BosClient.delete_bucket_inventoryas>!!,"5"5&14V=T=TUf=g"h"("* *r-cFUR[RUSS0US9$)zw list configuration of bucket inventory :type bucket: string :param bucket: None :return: **HttpResponse Class** rr-rPrIrrs r*list_bucket_inventoryBosClient.list_bucket_inventoryqs2!!,"2"2&#/"5"("* *r-c Ub[R"U5nUR[RU[ R "SU0[RS9[R[R0SS0US9$)z Open bucket trash function :type bucket: string :param bucket: None :type trash_dir: string :param trash_dir: directory of trash,optional :return: **HttpResponse Class** trashDirrtrashr-rr)r)rN trash_dirrEs r*put_bucket_trashBosClient.put_bucket_trashsy  00;I!!,"2"2& $ J +B3<3M3M!O$0$=$=?Q?V?V#W#+S/"( "* *r-cFUR[RUSS0US9$)zo Get status of bucket trash :type bucket: string :param grant_list: None :return: **HttpResponse Class** rr-rPrIrrs r*get_bucket_trashBosClient.get_bucket_trashs1!!,"2"2&#+S/"("* *r-cFUR[RUSS0US9$)zc Close bucket trash :type bucket: string :param bucket: None :return: **HttpResponse Class** rr-rPrrrs r*delete_bucket_trashBosClient.delete_bucket_trashs1!!,"5"5&#+S/"("* *r-)rNkeyric 8[R"U5nU=(d SRS5n[R"U5 [R "U5 [R "U5nUS:Xa [S5eURX5n U(a [U5O0nU(a [U5O0nUR[RR5S5 UR[RS5 Ubq[U[5(aVUR5n U S:Xa[ R"U lO0U S:Xa[ R&U lO[SU-5eXl[(R*"U R,U R$5upnU nXR.:waUS [R "U5-- nX[R0'U R2S La![4R6U[R8'UR;XU5nU [<R>:wa U [<R@:wa [CS /5nU RDb+U RDU[RFR5'[HRJ"U RLU UUUUUU5U[RR5'S [R "U RN5UU[(RP"US 54-$)a Get an authorization url with expire time. specified protocol in endpoint > protocal > default protocol in config. :type timestamp: int :param timestamp: None :type expiration_in_seconds: int :param expiration_in_seconds: None :type options: dict :param options: None :param is_official_domain: default use not official domain,example: bucket.bj.bcebos.com :return: **URL string** /sv1z!generate url the key param error!NrihttpszInvalid protocol: %s:Tshosts %s://%s%s?%sF))rrstriprvalidate_bucket_namevalidate_object_keyr ValueError _merge_configdictpopr AUTHORIZATIONlowerrfrProtocolHTTPprotocolHTTPSr parse_host_portendpoint default_portHOST request_payerrREQUEST_PAYER_REQUESTERBOS_REQUEST_PAYER _get_pathrrKresetsecurity_tokenSTS_SECURITY_TOKENrsign credentialsnameget_canonical_querystring)r)rNr timestampexpiration_in_secondsrXrQheaders_to_signrrE httpmethodpendpoint_protocol endpoint_host endpoint_port full_hostpaths r*generate_pre_signed_url!BosClient.generate_pre_signed_urls<&&s+yb$((5'',%%c* %<@A A##F8#*$w-!'fR <--335t< <--t4  (C((NN$;&.mmFO'\&.nnFO$%;h%FGG"*  ! !&//6?? C 8-" :: :  7 7 FF FI%. !!"   4 '5;5S5SF<11 2~~f37 )) )jLD>S>SF<2288: ;5B5G5G         ! 6|))//12&"9"9:K:P:P"Q!*!%!&!@!@!O"QQ Qr-)rNrulesc tUR[RUSS0[R"SU05US9$)z Put Bucket Lifecycle :type bucket: string :param bucket: None :type rules: list :param rules: None :return:**Http Response** lifecycler-rulerQrYrErJrr_r]r^)r)rNr$rEs r*put_bucket_lifecycleBosClient.put_bucket_lifecyclesB !!,"2"2"-*6)<'+zz65/'B)/ "1 1r-cFUR[RUSS0US9$)z[ Get Bucket Lifecycle :type bucket: string :param bucket: None :return:**Http Response** r&r-rPrIrrs r*get_bucket_lifecycleBosClient.get_bucket_lifecycle*s2!!,"2"2"-*6)<)/"1 1r-cFUR[RUSS0US9$)z^ Delete Bucket Lifecycle :type bucket: string :param bucket: None :return:**Http Response** r&r-rPrrrs r*delete_bucket_lifecycle!BosClient.delete_bucket_lifecycle9s2!!,"5"5"-*6)<)/"1 1r-)rNcors_configurationc tUR[RUSS0[R"SU05US9$)z Put Bucket Cors :type bucket: string :param bucket: None :type cors_configuration: list :param cors_configuration: None :return:**Http Response** corsr-corsConfigurationr(r))r)rNr2rEs r*put_bucket_corsBosClient.put_bucket_corsHsD!!,"2"2"-*13'+zz3FHZ2['\)/ "1 1r-cFUR[RUSS0US9$)zV Get Bucket Cors :type bucket: string :param bucket: None :return:**Http Response** r4r-rPrIrrs r*get_bucket_corsBosClient.get_bucket_cors]s1!!,"2"2"-*13)/"1 1r-cFUR[RUSS0US9$)zY Delete Bucket Cors :type bucket: string :param bucket: None :return:**Http Response** r4r-rPrrrs r*delete_bucket_corsBosClient.delete_bucket_corsls1!!,"5"5"-*13)/"1 1r-c|0nUbX'S'UbX7S'UbXGS'UbXWS'UR[RXUS9$)1 Get Object Information of bucket :type bucket: string :param bucket: None :type delimiter: string :param delimiter: None :type marker: string :param marker: None :type max_keys: int :param max_keys: value <= 1000 :type prefix: string :param prefix: None :return: **_ListObjectsResponse Class** maxKeysprefixmarker delimiterrPrI)r)rNmax_keysprefixmarker delimiterrErQs r* list_objectsBosClient.list_objects{s`2  !):    &9    &9   #,< !!,"2"2KW]!^^r-c## SnURXX#US9nURHnUv M UR(a URnOgMI7f)O :param bucket_name: :param prefix: :param delimiter: :param config: :return: N)rFrErGrE)rHcontents is_truncated next_marker)r)rNrErGrErFrSitems r*list_all_objectsBosClient.list_all_objectss^((6W])_H )) *$$!--sA AcUcg[U[[45(d [S5e[ U5S:wa [ S5e[ RS[U5-0$)Nz!range should be a list or a tuplezrange should have length of 2 bytes=%d-%d)rflisttuple TypeErrorlenrrRANGE)ranges r*_get_range_header_dict BosClient._get_range_header_dictsX =%$//?@ @ u:?<= =""NU5\$ABBr-c0nUR5n[R(a1/nUH'upVUR5nUR XV45 M) Un[R "[ R5nUHXupVURU5(dMU[U5Sn[R"U5U[R"U5'MZ X!Rl Xl g)aSets response.body to http_response and response.user_metadata to a dict consists of all http headers starts with 'x-bce-meta-'. :param http_response: the http_response object returned by HTTPConnection.getresponse() :type http_response: httplib.HTTPResponse :param response: general response object which will be returned to the caller :type response: baidubce.BceResponse :return: always true :rtype bool NT) getheadersrPY3rappendrrBCE_USER_METADATA_PREFIXrxrXconvert_to_unicodemetadata user_metadatadata) http_responserSrd headers_list temp_headsrzr{rEs r*_parse_bos_objectBosClient._parse_bos_objects $//1 ::J$GGI!!1&)%&L))55 !DA||F##c&klO--a0f77:;! +8'% r-c 0nUb[R"U5nSU0n[R"U5n[U5S:XdURS5(a [ S5e[ R U5n UbU c0n XI[R'Ub%U c0n UR[RX5n UR[RUUU UU[ RS9$)z :param bucket_name: :param key: :param range: :param traffic_limit: :param version_id: :param cond_read_write: :param config: :return: versionIdr/(Key can not be empty or start with '/' .rXrQrE body_parser)rrrXrxrr@r[rBOS_TRAFFIC_LIMIT_get_cond_read_write_headersrrKrJri) r)rNrrZ traffic_limit version_idcond_read_writerE query_params range_headers r* get_objectBosClient.get_objects  !00  $#! ;H77 8  &#! <<\=M=M|mL!!      !33"5 5r-c [R"U5n0nUbX6[R'Ub[ U[ 5(aUO0[ U[ 5(aURS5O [ U5nUS;a[SRU55e[R"U5U[R'O [S5eUR[RUUUSS0U[R S9$)z: :param bucket_name: :param key: :param config: :return: zutf-8)Standard ExpeditedLowCostz}invalid tier:{} for restore_object.The valid value is "Standard" or "Expedited" or "LowCost"z(tier can not be None for restore_object.srestorer-ro)rrrBOS_RESTORE_DAYSrfrrdecoderformatBOS_RESTORE_TIERrrJrPOSTr@ri)r)rNrdaystierrErXtier_strs r*restore_objectBosClient.restore_objects%%c*  59L11 2  )$44tR\]achRiRi$++g:NorswoxHCC ";;A6$<JJ5;5L5LT5RGL11 2 !KL L!!     $!33"5 5r-c6[US5nU(a7[URR5n[R "XU5nOUn[ R"XuU5 UR5 UR5 g!UR5 f=f)NwbT) openintrccontent_lengthr make_progress_adaptershutil copyfileobjclose)rfrS file_namebuf_sizeprogress_callbackf file_sizestreams r*_save_body_to_fileBosClient._save_body_to_file,sy D !   1 1 @ @A 44]W`a&   v( 3    ! GGI GGIs A'BBc&URX5 g)NT)init_from_http_responserfrSselect_responses r*_parse_select_messageBosClient._parse_select_message=s// Hr-c [R"U5nURXX4XVS9nURR 5nURR 5 U$)zH :param bucket_name: :param key: :param range: :param config: :return: )rZrtrurE)rrrxrereadr) r)rNrrZrtrurErSss r*get_object_as_stringBosClient.get_object_as_stringBsV%%c*??;55D#U MM    r-)rNrrc ^^^^0n U b[R"U 5n SU 0n [R"U5n[U5S:XdURS5(a [ S5e[R"T5m[ R U5n UbU c0n X{[R'Ub%U c0n TR[RX5n TR[RUUU U TUUUU4SjS9$)a; Get Content of Object and Put Content to File :type bucket: string :param bucket: None :type key: string :param key: None :type file_name: string :param file_name: None :type range: tuple :param range: (0,9) represent get object contents of 0-9 in bytes. 10 bytes date in total. :return: **HTTP Response** rlrrmrnc R>[RUUTTRTS5TS9$)N recv_buf_size)r)r@r_get_config_parameter)rfrSrErrr)s r*.BosClient.get_object_to_file..s2 8T8T**6?C"3 9U95r-ro) rrrXrxrr@r[rrqrrrrKrJ) r)rNrrrZrErrsrurtrvrws ` ` `` r*get_object_to_fileBosClient.get_object_to_fileSs(  !00  $#! ;H77 8  &#! <<\=M=M|mL!!      5" 6 6r-c 0nUb[R"U5nSU0n0nUb UR[RXt5n[R"U5nUR [RXXvUS9$)z Get head of object :type bucket: string :param bucket: None :type key: string :param key: None :return: **_GetObjectMetaDataResponse Class** rlr)rrrrrrerJ)r)rNrrtrurErvrXs r*get_object_meta_dataBosClient.get_object_meta_datas  !00#9m>S#1#9>O>WK$[1  -$)$;$;D9=9S9STZ\k9l%nM 2  11+>K #44^DN "33MBM #44^DN  *"("9"9:M"N   & 7 78I J ..)#%)') 3/''%')/ + C88 8>@C@\@\]^ ^S!   &F9  ..t5FGD!!     " _!-"[1_4(`&1Ao{CFL  &VXcehijekl(, -s%F"" H,-H  "H  H)rNrrec[R"U5n[U[5(aUR [ R 5nSn[R"U5nU c%[R"UURUS5S9n URUUUU[U5UUUUU U U U U UUUUS9UbUR5 $$!UbUR5 ff=f)zv Create an appendable object and put content of string to the object or add content of string to an appendable object Nrr)rNrrerrrrrdrrrrrrrrrsrE)rrrfrencodebaidubceDEFAULT_ENCODINGioBytesIOr rrrrXr)r)rNrrerrrrdrrrrrrrrrsrEfps r*append_object_from_string#BosClient.append_object_from_strings,%%c* dC ;;x889D  D!B$ % 7 7!;!;FO!T!V %%+*-+-2=58Y-33?4A5C4A5C:M8I4A3?8I4A-3#&5&~ r~ s A&C CcV[R"U5nUcFUcCUc@U c=U c:Sn[U5H)n[R"X4UR US5S9n O U(a[R"U5nU(a[R"U5nU(a[R"U5nU (a[R"U 5n U b[R"U 5n U (a[R"U 5n URUUUUUU U U U U UUUUUUS9nUb!UR[RUU5nU[R :a[#S [R -5eU(a[R$"UU5nUR'[RUUUUUS 9$![ abnUUS- :a+[RSUS-U[U55 SnAGM[RSU[U55 SnSnAGMSnAff=f) a Put object and put content of file to the object :type bucket: string :param bucket: None :type key: string :param key: None :type fp: FILE :param fp: None :type file_size: long :type offset: long :type content_length: long :return: **HTTP Response** Nrrrrrr)rrrrrrrrrdrr encryption customer_keycustomer_key_md5rsrr)rYrXrE)rrrZr rrrrrrrrrrrr_rMAX_PUT_OBJECT_LENGTHrrrJ)r)rNrrerrrrrrrrrdrrrrrrrsrrurErrrmrXs r* put_objectBosClient.put_object>s-T%%c*  >#9m>S#1#9>O>WK$[1  -$)$;$;D9=9S9STZ\k9l%nM 2  11+>K #44^DN "33MBM #44^DN  *"("9"9:M"N   & 7 78I J ..)#%)') 3/''%!%-')!/,$  &77 8H8H'SbcG C55 5>@C@Y@YZ[ [ ..t5FGD!!      " c!-"[1_4(`&1Ao{CFL  &VXcehijekl(, -s%F<< H(-H#:"H##H()bucketrrec[R"U5n[U[5(aUR [ R 5nSn[R"U5nUc%[R"UURUS5S9nURXU[U5UUUUUU U U U U UUUUUUUUS9UbUR5 $$!UbUR5 ff=f)a Create object and put content of string to the object :type bucket: string :param bucket: None :type key: string :param key: None :type input_content: string :param input_content: None :type options: dict :param options: None :return: **HTTP Response** NrrrrrrrrrrrdrrrrrrrsrrurE)rrrfrrrrrrr rrrrXr)r)rrrerrrrrrrrdrrrrrrrsrrurErs r*put_object_from_string BosClient.put_object_from_stringsJ%%c* dC ;;x889D  D!B$ % 7 7!;!;FO!T!V ??625d)/:0<2@1>2@7J5F1>1>0<.80<4D7H1>2@3B*0'#2*~ r~ s A)C C")rrrc[R"U5n[US5nUcAURS[R 5 UR 5nURS5 Uc(URUS5n[R"UUUS9nUc[R"U5nURXUUUUUUU U U U U UUUUUUUUUS9UR5 $!UR5 f=f)z Put object and put content of file to the object :type bucket: string :param bucket: None :type key: string :param key: None :type file_name: string :param file_name: None :type options: dict :param options: None :return: **HttpResponse Class** rbrrrr) rrrseekosSEEK_ENDtellrr rguess_content_type_by_file_namerr)r)rrrrrrrrrrrrdrrrrrrrsrrurErrs r*put_object_from_fileBosClient.put_object_from_filesP%%c* )T " %2;;'!# $ $ : :6? S % 7 7>=J!L #$DDYO ??62@/:0<2@1>2@7J5F1>1>0<.80<4D5F1>2@3B*0'#2* HHJBHHJs B*CC1)source_bucket_name source_keytarget_bucket_name target_keyc [R"U5n[R"U5n[R"U5 UR UUUU U U S9n[ R "S[R"U5U4-S5nU bUS[R"U 5--nUU[R'UbX_[R'UcUbSU[R'OSU[R'U b[RXS5nUR[R UUUU[R"S 9$![anUeSnAff=f) a Copy one object to another object :type source_bucket: string :param source_bucket: None :type source_key: string :param source_key: None :type target_bucket: string :param target_bucket: None :type target_key: string :param target_key: None :return: **HttpResponse Class** )rrdrrrsr/%s/%sFNs ?versionId=%ssreplacescopyT)rXrErp)rrrrrr normalize_stringrBCE_COPY_SOURCEBCE_COPY_SOURCE_IF_MATCHBCE_COPY_METADATA_DIRECTIVEr@_get_user_headerrrJrr_parse_copy_object_response)r)rrrretagrrdrrcopy_object_user_headersrsrsource_version_idrErXmerge_source_keyrms r* copy_objectBosClient.copy_object=srD,,Z8 ,,Z8 '' 3..%''%') /+!11 ''(:; "$  (/2BVE\E\]nEo2oo 0@ ,,-  =AL99 :  $ (@@JGL<< =@GGL<< = # / #44WX\]!!     #>> "@ @  s?E EEEc0nUb[R"U5nSU0n[R"U5nUR[RXXTS9$)z Delete Object :type bucket: string :param bucket: None :type key: string :param key: None :return: **HttpResponse Class** rlrPr)r)rNrrtrErvs r* delete_objectBosClient.delete_objects^  !00B88 C CC )rNr upload_id part_number part_sizepart_fpc [R"U5nU[R:dU[R:a-[ SU[R[R4-5eU[R :a[ S[R -5eUcFUcCU c@U c=U c:Sn[U5H)n[R"XeURUS5S9n O U(a[R"U5nU (a[R"U 5n U(a[R"U5nU (a[R"U 5n U (a[R"U 5n U (a[R"U 5n UR!UUU UU U U US 9nU (a[R""XmU5nUR%[&R(UUUUXCS .US 9$![abnUUS- :a+[RSUS-U[U55 SnAGMr[RS U[U55 SnSnAGMSnAff=f) a Upload a part. :type bucket: string :param bucket: None :type key: string :param key: None :type upload_id: string :param upload_id: None :type part_number: int :param part_number: None :type part_size: int or long :param part_size: None :type part_fp: file pointer :param part_fp: not None :type part_md5: str :param part_md5: None :type config: dict :param config: None :return: **HttpResponse** z9Invalid part_number %d. The valid range is from %d to %d.z+Single part length should be less than %d. Nrrrrrr)rrrrrrrrss partNumberuploadIdr)rrrMIN_PART_NUMBERMAX_PART_NUMBERrrrZr rrrrrrrrrrJrr_)r)rNrrrrr part_md5 part_crc32 part_sha256 part_crc32cpart_crc32c_flagpart_crc64ecmarrsrErrrmrXs r* upload_partBosClient.upload_parts=N%%c* ,, , c>Q>Q0QXS00#2E2E\GGH H s00 0J"889: :   2{7J + 38NK$[1  *!&!8!8BFB\B\]cetBu"wJ 2 ..x8H  11+>K 00K %667GH  #44^DN..$ &$& 0,'/  11'iXG!!     #.G" G!*"[1_4(`&1Ao{CFL  &VXcehijekl%) *s<%G,, I6-I*"II)rrrrrrrrc [R"U5n[R"U5n[R"U5 UR U U U S9n[ R "S[R"U5U4-S5U[R'SXU-S- 4-nX[R'U bX[R'UR[RUUUXeS.U S9$)aC Copy part. :type source_bucket_name: string :param source_bucket_name: None :type source_key: string :param source_key: None :type target_bucket_name: string :param target_bucket_name: None :type target_key: string :param target_key: None :type upload_id: string :param upload_id: None :return: **HttpResponse** )rrdrsrFrTrr"r)rrrrrr rrrBCE_COPY_SOURCE_RANGErrJrr_)r)rrrrrrrrrrrdrsrErXrZs r*upload_part_copyBosClient.upload_part_copyysL,,Z8 ,,Z8 '' 3..&2'4'4/6160F0F"f&=&=>P&Q#&%%&+1- ,,-#fy.@1.D%EE6; 223  =AL99 :!!     #.G " r-)rNrrrrrrc[R"U5n[US5nURU5 UR XX4UUXXXXUS9UR 5 $!UR 5 f=f)z :param bucket_name: :param key: :param upload_id: :param part_number: :param part_size: :param file_name: :param offset: :param part_md5: :param config: :return: r) r&r'r(r)r*r+rrsrE)rrrrr,r)r)rNrrrrrrr&r'r(r)r*r+rrsrErs r*upload_part_from_fileBosClient.upload_part_from_filesp2%%c* D !  FF6N##KiiYZ-50;5E6G+1 $3 GGIAGGIs 'AA.)rNrr part_listc 0[R"U5nUR[RUUUUU U S9n U b UR [ RX5n UR[ RUU[R"SU05U SU0U S9$)a After finish all the task, complete multi_upload_file. :type bucket: string :param bucket: None :type key: string :param key: None :type upload_id: string :param upload_id: None :type part_list: list :param part_list: None :return: **HttpResponse** )rrdrrrrrpartsr#r) rrrrr[rrrrrJr]r^)r)rNrrr5rrdrrrrrurErXs r*complete_multipart_upload#BosClient.complete_multipart_uploads@%%c*..+00'%') 3//1  &77 8I8I7dG!!     Wi01+" r-)rNrrcr[R"U5nUR[RXSU0US9$)z Abort upload a part which is being uploading. :type bucket: string :param bucket: None :type key: string :param key: None :type upload_id: string :param upload_id: None :return: **HttpResponse** r#rPr)r)rNrrrEs r*abort_multipart_upload BosClient.abort_multipart_uploadsA %%c*!!,"5"5{*5y)A)/"1 1r-c[R"U5nSU0nUbXGS'UbXWS'UR[RXXvS9$)aJ List all the parts that have been upload success. :type bucket: string :param bucket: None :type key: string :param key: None :type upload_id: string :param upload_id: None :type max_parts: int :param max_parts: None :type part_number_marker: string :param part_number_marker: None :return: **_ListPartsResponse Class** r#smaxPartsspartNumberMarkerrPr)r)rNrr max_partspart_number_markerrErQs r* list_partsBosClient.list_parts'sY0%%c*y)  "+;   )*<& '!!,"2"2KV!ccr-c## [R"U5nSnURXUXTS9nURHnUv M UR(dgUR nMH7f)zL :param bucket_name: :param key: :param upload_id: :param config: :return: N)r?rE)rrr@r7rMnext_part_number_marker)r)rNrrrEr?rSrOs r*list_all_partsBosClient.list_all_partsHsk%%c*!{9K'\H  '((!)!A!A sA"A$cSS0nUbXWS'UbX'S'UbX7S'UbXGS'UR[RXUS9$)a List all Multipart upload task which haven't been ended.(Completed Init_MultiPartUpload but not completed Complete_MultiPartUpload or Abort_MultiPartUpload) :type bucket: string :param bucket: None :type delimiter: string :param delimiter: None :type max_uploads: int :param max_uploads: <=1000 :type key_marker: string :param key_marker: None :type prefix: string :param prefix: None :type upload_id_marker: string :param upload_id_marker: :return: **_ListMultipartUploadResponse Class** rr-rCs maxUploadss keyMarkerrArPrI)r)rN max_uploads key_markerrErGrErQs r*list_multipart_uploads BosClient.list_multipart_uploads]se8c"  #,<  "$/= !  !#-<   &9 !!,"2"2KW]!^^r-c#(# SnURUUUUUS9nURHnUv M UR(dgURb URnO4[ UR5S:waURSR nOgM7f)rKN)rHrErGrEr)rIuploadsrMnext_key_markerrXr)r)rNrErGrErHrSrOs r*list_all_multipart_uploads$BosClient.list_all_multipart_uploadss 22;>H:@=F:@ 3BH !(( )((''3%55 X%%&!+%--b155 sBBcU R5(a%[RSRU55 gUR XUXEXgU XU XS9 nUR UUR RS.5 [RSRU55 g![a+n[RSRU55 UeSnAff=f)Nz(upload task canceled with partNumber={}!)r'r)r*r+rrs) partNumbereTagz'upload task success with partNumber={}!z&upload task failed with partNumber={}!) r6rdebugrr3r`rcrr)r)rN object_keyrrrrrr5uploadTaskHandler'r)r*r+rrsrSrms r* _upload_taskBosClient._upload_tasks  % % ' ' MMDKKKX Y  11+9 j'[i"32RH   ) ))..  MMCJJ;W X  MMBII+V WG sA"B C)&CCc [RRU5nUS:a [S5eUc#Sn[R "US- 5nUU:aUnUS:dUS::a [S5eUbUS ::a[ R"5nUS -S -nUU-nUU-S:waUS - nUc [5nURXUUU S 9Rn[U5n/nSnS n/n/n[US 5nUS:aUnUU:aUn[R"UUU5nURUU45 UR!UR"XUUUUUUUUSSSX5n URU 5 UU-nUU- nUS - nUS:aMSSS5 [%U[&S 9 UR)5(a&[*R-S5 UR/XUS9 g[1U5U:wa&[*R-S5 UR/XUS9 gUR3SS9 U(aNUSSn![5S [1U55H#n"UU"un#n$[R6"U!U#U$5n!M% U!S-n!U cU!n UR9XUUU XU US9 g!,(df  GN=f)a Multipart Upload file to bos param chunk_size: part size in MB, default will be auto-calculated based on file size. Minimum is 5MB, maximum is 5120MB (5GB). Maximum 10000 parts allowed. Maximum file size supported is 48.8TB. lPCz'File size must not be more than 48.8TB!Nlb irzGchunk size is invalid, it should be more than 0 and not more than 5120!ri)rrrr) return_whenz!putting super object is canceled!)rFzputting super object failed!c US$)NrRr>)xs r*r6BosClient.put_super_object_from_file.. sQ|_r-)rl)rrrrruT)rr!getsizermathceilmultiprocessing cpu_countr rrrrr rr`submitrWr r r6rrTr;rXsortrZ crc32_combiner8)%r)rNrr chunk_size thread_numrVrrrrrrrrrsrurE left_sizemin_chunk_size_mbr total_partrexecutor all_tasksrrr5 part_crc_listrcurrent_part_sizepart_crc temp_task final_crc32icrcrs% r*put_super_object_from_file$BosClient.put_super_object_from_files,GGOOI. 1 1 IJ J  J $ )7J*K L  :-.   J!O ij j  q'113:%, )+ y A % !OJ  #/1 22;)+)3+,59  &j1    )T "ba-$-!y((1% 222v?PQ$$h0A%BC$OOD,=,={QZ\g,=y&R[]m,4dD$HYj   +.. ++q a-#" YM2  % % ' ' MM= >  ' ' I ' N ^z ) MM8 9  ' ' I ' N45 '*1-K1c-01+A. V#11+sFK 2 : %K$ +  &&{I]j6D9J\k ' mU# "s 1B I>> J )rNrryc [R"U5nUR[RUU[ R "SU0[RS9[R[R0SS0US9$)z Set Access Control Level of object :type bucket: string :param bucket: None :type acl: list of grant :param acl: None :return: **HttpResponse Class** rrrqr-rr)r)rNrryrEs r*set_object_aclBosClient.set_object_acl sw%%c*!!,"2"2& $ ,?+E3<3M3M!O$0$=$=?Q?V?V#W#)3-"("* *r-c [R"U5nSnSnUb+[R[R"U50nUS- nUb+[R[R"U50nUS- nUb+[R [R"U50nUS- nUS:Xa [ S5eUS:a [ S5eUR[RUUUSS0US 9$) aW :type bucket_name: string :param bucket_name: None :type key: string :param key: None :type canned_acl: string :param canned_acl: for header 'x-bce-acl', it's value only is canned_acl.PRIVATE or canned_acl.PRIVATE_READ :type grant_read: string :param grant_read: Object id of getting READ right permission. for exapmle,grant_read = 'id="6c47...4c94",id="8c42...4c94"' :type grant_full_control: string :param grant_full_control: Object id of getting READ right permission. for exapmle,grant_full_control = 'id="6c47...4c94",id="8c42...4c94"' :param config: :return: **HttpResponse Class** Nrrz,donn't give any object canned acl arguments!rSz5cann't get more than one object canned acl arguments!rqr-r) rrrrBOS_GRANT_READBOS_GRANT_FULL_CONTROLrrJrr_) r)rNrr grant_readgrant_full_controlrErXnum_argss r*set_object_canned_aclBosClient.set_object_canned_acl4 s<%%c*  !$,,f.E.Ej.QRG MH  !#22F4K4KJ4WXG MH  )#::F //0  '=D 99:=E 99:  $7=7N7N}7]GL33 4!!,"2"2&"#*#-s"3"( "* *r-)rNrct[R"U5nUR[RUUSS0US9$)z Get symlink info :type bucket: string :param bucket: None :type symlink: string :param symlink: symlink :return: **HttpResponse Class** rr-rPr)r)rNrrErs r*get_object_symlinkBosClient.get_object_symlink sF%%g.!!  "C( " r-)rNrselect_object_argsc F^[R"U5nU=(d 0nSU;a SUS;aSnOSU;a SUS;aSnOSn[5mUR[R UU[ R"SU0[RS9US US .UU4S jS 9 T$) z :type bucket_name: string :param bucket_name: bucket name :type key: string :param key: object name :type select_object_args: dict :param select_object_args: requesta parameters for select object api :param config: :return: inputSerializationr]sjsoncsvscsvsparquet selectRequestrr-)sselectstypec0>[RXT5$rC)r@rrs r*r)BosClient.select_object.. s 8W8W9:r-)rYrXrQrErp) rrSelectResponserJrrr]r^r@r|)r)rNrrrXrE select_typers @r* select_objectBosClient.select_object s %%c*-R #5 5&DVWkDl:l!K !%7 7EEWXlEm'U b[@RCUU S5nUbUU[RF'Ub'[R"U5U[RH'U$![DanUeSnAff=f)Nrz&content_length should not be negative.s"%s"z%user_metadata should be of type dict.z,Metadata size should not be greater than %d.z%user_metadata has duplicate elements.F)%rrrrCONTENT_LENGTHr r CONTENT_MD5r\rrBCE_CONTENT_SHA256BCE_CONTENT_CRC32BCE_CONTENT_CRC32CBCE_CONTENT_CRC32C_FLAGBCE_CONTENT_CRC64ECMAETAGrrfrrWraddrrarXrMAX_USER_METADATA_SIZErBOS_SERVER_SIDE_ENCRYPTION'BOS_SERVER_SIDE_ENCRYPTION_CUSTOMER_KEY+BOS_SERVER_SIDE_ENCRYPTION_CUSTOMER_KEY_MD5r@rrrqr)rrrrrrrrrrdrrrrrrsrrX meta_size meta_data_setrzr{normalized_keyrms r*r!BosClient._prepare_object_headers sX&  %.1"4 !IJJ393J3J>3ZGL// 0  "050P0PQ\0]GL,, -  #161Q1QR^1_GL-- .1C1P1PGL-- .  %7<7W7WXf7gGL33 4  $6;6V6VWd6eGL22 3  %7<7W7WXf7gGL33 4  * LHH I  '001AB LLL M  # #44WlER  $6CGL22 3  %060G0G0WGL,, -  s)O O OOc[RnU[R:XdU[R:XaVUR [ [R[R[R[R/55n[U5H6upE[R"U5nXC;aXQU'M&[U<SU<35e U$)z get if condition headers :type http_method: string :param http_method: GET, HEAD, PUT, POST :type cond_read_write: string :param cond_read_write: put_object, complete_multipart_upload, get_object, get_object_meta_data :return: headers z is not valid in )rBOS_COND_READ_WRITE_HEADERSrrKreunionrBOS_IF_MODIFIED_SINCEBOS_IF_UNMODIFIED_SINCE BOS_IF_MATCHBOS_IF_NONE_MATCHrr rr) http_methodrXrucond_read_write_setrzr{s r*rr&BosClient._get_cond_read_write_headers} s+FF ,** *k\=N=N.N"5";";C3355**//1=2#3  o.DA003A'  A{!KLL / r-c [U[5(d [S5e[RnU(dfUR [ [R[R[R[R[R/55nOGUR [ [R[R[R/55n[U5HPupV[ R""U5nU[R$:wa[ R""U5nXT;dMLX`U'MR U$)Nz$user_headers should be of type dict.)rfrrWrBOS_BASE_ALLOW_HEADERSr,r CACHE_CONTROLCONTENT_ENCODINGCONTENT_DISPOSITIONEXPIRES BOS_PROCESSBCE_COPY_SOURCE_IF_NONE_MATCH#BCE_COPY_SOURCE_IF_UNMODIFIED_SINCE!BCE_COPY_SOURCE_IF_MODIFIED_SINCErr rBOS_OBJECT_EXPIRES)rXris_copy bos_headersuser_headers_setrzr{s r*rBosClient._get_user_header s,--BC C"99 *00l6P6P$0$A$A$0$D$D$0$8$8$0$<$< 6>2? @  +00l6`6`$0$T$T$0$R$R6T2U V l+DA003AL33344Q7$ , r-cXSnUb [X5nUbU$[URU5$rC)getattrrE)r)rEattrr5s r*rBosClient._get_config_parameter s3  V*F  Mt{{D))r-cURnU(a URn[R"X@R5upVnUR (d6[R "U5(d[R"Xa5(a%[R"[RU5$[R"[RX5$rC) r backup_endpointr r r cname_enabledis_cname_like_hostis_custom_host append_urir URL_PREFIX)rErNruse_backup_endpointhostr host_namers r*rBosClient._get_path s ))D  ! !$ 8 4m   5#;#;I#F#F%J^J^_hJvJv##CNNC8 8 AAr-c[R"UR5nUbURU5 URX25nXClU$rC)copyrEmerge_non_none_values_change_user_endpointr )r)rErN new_configr s r*rBosClient._merge_config sDYYt{{+    , ,V 4--jF&r-c:[R"URUR5up4n[R "U5R S5nURn[R"U5=(a [U5S:Hn[R"U5(a UR$UR(a UR$UR(d"U5(aU(a [S5eUR$UbU(aUR[5(ajUR S5n [U 5S:a UR$U SS-[R "U5-S-U S-n [R "U 5$[R "U5S-[R "U5-$[U5S:Xa+Ub(US[R "U5:wa [S 5eUR$) N.rz??&3&9&9%&@O?+a/%.&5a&85&@6CZCZ[fCg&g'.q1'2O!22?CC!22;?D// >?? " #q ([-D#A&&*A*A+*NN !deer-c[U[5(dgUR[RR :Xa[ RS5 gg)NFz*BOS retry condition matched: 403 ForbiddenT)rfrrhrirjrkrrT)rErs r*_need_retry_for_bosBosClient._need_retry_for_bos sA%00    5 5 5 MMF Gr-c[U[5(ag[U[5(aUR[R R :XagUR[R R:XagUR[R:XagUR[R R:Xagg)NTF) rfIOErrorrrhrirjINTERNAL_SERVER_ERRORSERVICE_UNAVAILABLEcodeREQUEST_EXPIREDrk)rs r*_need_retry_backup_endpoint%BosClient._need_retry_backup_endpoint s eW % % e^ , ,  DKK$E$EE  DKK$C$CCzz^;;;  DKK$9$99r-c [R"U5 Ub[R"U5 URXr5n[R XrU5n Uc[ RnURb(U=(d 0nURU[R'URSLa,U=(d 0n[RU[R'Sn Sn Sn [US5(a![US5(aUR!5n ["R$"U[&R([ R*U/XXEU5$![,an U n U n Sn A OSn A ff=fU nU bUR.b[R1U R25(aU bUR5U 5 [6R9SU R:5 [R XrUS5n ["R$"U[&R([ R*U/XXEUS5 $![,an U n U n Sn A OSn A ff=fU b[R=X{R25(aU bUR5U 5 [6R9SU R:5 ["R$"U[&R([ R*U/XXEU5$![,an U n U n Sn A OSn A ff=fU ceU e)NTrrs)Retry for backup endpoint error code: %s.sRetry for BOS error code: %s.)rrrrr@rr parse_jsonrrrr rrrhasattrrr send_requestrr parse_errorrrHrprgrrrTrhrh)r)r1rNrrYrXrQrErpr!last_exceptionrmbody_initial_offsetex original_paths r*rJBosClient._send_request s ((5 ?  + +C 0##F8""6<  !,,K  ,mG7=7L7LGL33 4   4 'mG6<6T6TGL22 3  # 4 WT6%:%:"&))+  "// **W-@-@+,N4&: :" NA  =V33?&BB1<<PP &2II12 JAMMZ **6TJ&33M..1D1Dk0RtfdDD& !#  =Y::6<<PP &2II12 > N&33M..1D1Dk0RvGG& !#   ! sJ8E E$EE$BH## H;-H66H;&A,K K+K&&K+r>rC)NFN)NNN)NN)NNNN)NNNNN)Nr{N)i@N)NNNN)NNNNNN)NNNNNNNNNNNNNNN)NNNNNNNNNNNNNN)NNNNNNNNNNNNNNNNNN)NNNNNNNNNNNNNNNNNNN) NNNNNNNNNN) NNNNNNNNN)NNNNNNNN)r|NNNNN)NNNNNNNNNNNNNNNNN)F)NNF)NNNNNNN)r8r9r:r;r<r+rLrrrrTrbrnrs staticmethodr|rUrrrrrrrrrENCRYPTION_ALGORITHMrrrrrrrrrrrrrrrrrrrrKr"r*r-r0r6r9r<rHrPr[rirxrrrrrrobjectr integer_typesrrrrrrrrrrrrrr,r0r3r8r;r@rDrIrOrWrurxrrrrboolrrrrrrrrrrrrrrrrrrrrrrrrrr r rrrrrrrrrrrUrhrprJr=r>r-r*r@r@[sa- C5#,',(, 5#,' ( :5#,'((5#,' ( 5#,T4L9*:*(5#,E9= *> *5#,uclC*D*"5#,' *( *5#,' S( S5#,'*(*:5#,' *( * 5#,' *( * 5#,'FZcg*(*.5#,' *( * 5#,' *( *"5#,$:*;**5#,' *( * 5#,' *( * 5#,TH=*>*05#,'*(*,5#,'*(*,5#,'*(*,5#,' *( *5#,4(;*<*,5#,5#,G *H *5#,5#,G *H *5#,' *( *5#,'*(*.5#,' *( * 5#,' *( *5#,UCL9+,6:(,'+04)-'++7+;+;WQ:WQr5#,tTl;%)1<1*5#,' 1( 15#,' 1( 15#,D8D $1E1(5#,' 1( 15#,' 1( 15#,'HL "_("_H5#,'((CC  D5#,UCL9VZ04'5:'5T5#,UCL95:5: 5#,UCL9: 5#,UCLUCLQQUim26R26j5#,UCL9W:W25#,#,:$2257 "& "&#'$(#'$()-'+#'"&'+#'$( !^ 7^@5#, %s|!& ./3)-/3041504156:4804/34804)-2.2h5#,#,:$2257 $ $"&!%"&'+%)!%!% $" $$(%)!%"&#''f 7fPeS\s|5#,G+/,0.2-1.23715-1-1,0*.,00415-1.2/3&*%DHDLeS\s|s|L,0)-*.,0+/,015/3+/+/*.(,*..2/3+/,0-1$('IMIV%"''!%"&"&!%-1"&#'&*C@ 'C@J5#,UCL90:0(5#,$:1;1&UCL"CL"CL* )-!% 1*145#,' 1( 15#,' 1( 15#,UCL90404/3)- (:(T5#,#, '--0j " bfZ^\`\ " \|%"' '--0**-/#&*'+'+ $3/3j5#,#, '--0 **- /SWMQDHQU />5#,#, " 040404156:4826)-0 "0d5#,UCLUCLQ1R1(5#,UCLUCLQ6:dRd@5#,UCLUCLQBRB(5#,'OS6:&*%_(%_N5#,'(:RV.2*5#,UCLUCLQQU! $"" dRdL5#,UCLtTlK*L*,5#,UCL9# 4*:4*l5#,UCL9:*5#,UCL9:*5#,UCLuclK$L$L5#,E3<%QTimhpqTXbf%*r%*P5#, =>*5#,UCLdT#U#JJsgF7G7&L5#,' ;( ;5#,th?;@;$5#,' ( 5#,TH=>$5#,'(5#,'( 5#,UCLxPQ.25#,UCL9:(5#,UCL9:&5#,s|<=(5#,' ( 5#,'MQ,0$_($_L5#,w? $1@1(5#,' 1( 15#,' 1( 15#,' $1(1$5#,C7C $1D1(5#,' $ 1( 15#,D8< $1=1(5#,' $ 1( 15#,' $ 1( 15#,$: $1;1(5#,' $ 1( 1 $"!#\\~:2* B B*X  $6:,0%)Er-r@c0\rSrSrSrSrSrSrSrSr g) SelectMessageig z) returned message from select object api c6SUlXlX lX0lg)z Initialize for record message RecordsN)typerXpayloadrt)r)rXrrts r*set_record_message SelectMessage.set_record_messagek s   r-cBSUlXlX lX0lX@lg)z! Initialize for continue message ContN)rrX bytes_scannedbytes_returnedrt)r)rXrrrts r*set_cont_messageSelectMessage.set_cont_messaget s!  *,r-c*SUlXlX lg)z Initialize for end message EndN)rrXrt)r)rXrts r*set_end_messageSelectMessage.set_end_message~ s  r-c&URS:Xa&SRURUR5$URS:Xa1SRURURUR 5$SRUR5$)Nrz{} {}rz%{} bytes_scanned/bytes_returned={}/{}z{})rrrXrrrr(s r*__str__SelectMessage.__str__ su 99 !??4<<> > YY& ;BB4<r-r*rrg s-r-rc:\rSrSrSrSrSrSr\S5r Sr g) ri z( deal with message of select object api cSUlgr#)finishr(s r*r+SelectResponse.__init__ s  r-cXlX lg)z" get HttpResponse and BceResponse N)rfrS)r)rfrSs r*r&SelectResponse.init_from_http_response s+ r-c#&# URnUR(Gd4URS5nU(d[e[R "SUSS5Sn[R "SUSS5SnURU5nUR U5n[5nUSS:XanX4- S- nURU5n [R "SURS55Sn URU[R"U 5U 5 Uv GO%USS:XaURS5n URS5n [R "SURS55Sn [R "S U 5Sn [R "S U 5Sn URXkX5 Uv OUSS :Xa}[R "SURS55Sn US S :wa/[US US URRRS9eUR!Xj5 SUlUv UR(dGM4URR#5 g!URR#5 f=f7f)z generator for SelectMessage z>IrrZz message-typer rz>Qrz error-codesuccessz error-message)rn request_idTN)rfrr StopIterationstructunpack_parse_select_headersrrrrrrrSrcbce_request_idrr) r)rprelude total_len headers_lenrX headers_mapmsg payload_lenrrtrrs r*r5SelectResponse.result s4  " 'kkk&&)''"MM$! =a@ $mmD'!A,?B &&-"88A #o~.);"+"9B">Kff[1G --affQi8;C**;8P8PQX8Y[^_I 0F:$%FF1IM%&VVAYN --affQi8;C$*MM$ $Fq$IM%+]]4%H%KN((^YI 0E9 --affQi8;C"<0I=,[-IP[\hPi+/==+A+A+P+PRR'' 9"&DKI=kkk>     $ $ &D   $ $ &s JII2J2JJc`0nSnU[U5:a[R"SXUS-5SnUS- nXX#-nX#- n[R"SXUS-5SnUS- nXX%-nX%- n[R"U5U[R"U5'U[U5:aMU$)z< parse SELECT headers :param headers: :return: rBrz>HrS)rXrrrr)rXhmrkey_lenr value_lenvalues r*r$SelectResponse._parse_select_headers sc'l"mmC )BCAFG QJE1C  E dG519,EFqII QJE5#45E  E060H0H0OBv'', -c'l" r-)rrfrSN) r8r9r:r;r<r+rr5r}rr=r>r-r*rr s+!''Rr-r)Cr<rrS http.clientrir`rr]loggingrrbuiltinsrr future.utilsrrrconcurrent.futuresrr r r r% functoolsrbrr r baidubce.authrbaidubce.bce_base_clientrbaidubce.exceptionrrr baidubce.httprrrrrbaidubce.servicesrbaidubce.services.bosrrrbaidubce.utilsrrbaidubce.protocolrr getLoggerr8rFETCH_MODE_SYNCFETCH_MODE_ASYNCr~r_r r@rrrr>r-r*rs   88WW-'2--1)!,&&!-(/#$   H %4J4 J4Xh&-F&-PNVNr-