9ilSrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK J r SSK J r SSK JrJrJr SSKJrJrJrJr SSKrSSKrSSKrSSKrSSKJr SSKJr SS KJr SS KJr 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 SSKJ1r1 \Rd"\35r4Sr5Sr6Sr7Sr8"SS5r9"SS\5r:"S S!\;5r<"S"S#\;5r=g)$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) storage_class)required)compatssyncsasyncAES256shttpc*\rSrSrSrSrSrSrSrg)UploadTaskHandle>z7 handle to control multi upload file with multi-thread cFSUl[R"5UlgNF) cancel_flag threadingLock cancel_lockselfs `/var/www/html/land-doc-ocr/venv/lib/python3.13/site-packages/baidubce/services/bos/bos_client.py__init__UploadTaskHandle.__init__Bs$>>+czURR5 SUlURR5 g)z9 cancel putting super object from file with multi-thread TNr&acquirer#releaser's r)cancelUploadTaskHandle.cancelFs0   "   "r,cURR5 URnURR5 U$)z get cancel flag r.)r(results r) is_cancelUploadTaskHandle.is_cancelNs8   "!!   " r,)r#r&N) __name__ __module__ __qualname____firstlineno____doc__r*r1r5__static_attributes__r,r)rr>s,#r,rc P\rSrSrSrSSjrSSjr\"\\ 4S9SSj5r \"\\ 4S9SSj5r \"\\ 4S9SS j5r \"\\ 4S9SS j5r \S 5r\"\\ 4\\4S 9SS j5r\"\\ 4\S9SSj5r\"\\ 4S9SSj5r\"\\ 4S9SSj5r\"\\ 4S9SSj5r\"\\ 4S9SSj5r\"\\ 4S9SSj5r\"\\ 4S9SSj5r\"\\ 4S9\S4Sj5r\"\\ 4S9SSj5r\"\\ 4S9SSj5r\"\\ 4\S9SSj5r\"\\ 4S9SSj5r\"\\ 4S9SSj5r \"\\ 4\S9SSj5r!\"\\ 4S9SSj5r"\"\\ 4S9SS j5r#\"\\ 4S9SS!j5r$\"\\ 4S9SS"j5r%\"\\ 4\S#9SS$j5r&\"\\ 4\\ 4S%9SS&j5r'\"\\ 4\\ 4S%9SS'j5r(\"\\ 4S9SS(j5r)\"\\ 4S9SS)j5r*\"\\ 4S9SS*j5r+\"\\ 4S9SS+j5r,\"\\ 4\\ 4S,9S-S.SSSSS\-R\4S/j5r/\"\\ 4\\4S09SS1j5r0\"\\ 4S9SS2j5r1\"\\ 4S9SS3j5r2\"\\ 4\S49SS5j5r3\"\\ 4S9SS6j5r4\"\\ 4S9SS7j5r5\"\\ 4S9SS8j5r6\"\\ 4S9SS9j5r7\S:5r8\S;5r9\"\\ 4\\ 4S,9SS<j5r:\"\\ 4\\ 4S,9SS=j5r;\SS>j5r<\S?5r=\"\\ 4\\ 4S,9SS@j5r>\"\\ 4\\ 4\\ 4SA9SSBj5r?\"\\ 4\\ 4S,9SSCj5r@\"\\ 4\\ 4\A\BR\\ 4SD9SSEj5rD\"\\ 4\\ 4\\ 4SF9SSGj5rE\"\\ 4\\ 4\A\BR\\ 4SD9SSHj5rF\"\\ 4\\ 4\\ 4SI9SSJj5rG\"\\ 4\\ 4\\ 4SK9SSLj5rH\"\\ 4\\ 4\\ 4\\ 4SM9SSNj5rI\"\\ 4\\ 4S,9SSOj5rJ\"\\ 4\SP9SSQj5rK\"\\ 4\\ 4\\ 4SR9SSSj5rL\"\\ 4S9SSTj5rM\"\\ 4S9SSUj5rN\"\\ 4\\ 4S,9SSVj5rO\"\\ 4\\ 4\\ 4\P\BR\ASW9SSXj5rQ\"\\ 4\\ 4\\ 4\\ 4\\ 4\P\BR\BRSY9SSZj5rR\"\\ 4\\ 4\\ 4\P\BR\\ 4\BRS[9SS\j5rS\"\\ 4\\ 4\\ 4\S]9SS^j5rT\"\\ 4\\ 4\\ 4S_9SS`j5rU\"\\ 4\\ 4\\ 4S_9SSaj5rV\"\\ 4\\ 4\\ 4S_9SSbj5rW\"\\ 4S9SScj5rX\"\\ 4S9SSdj5rYSSejrZ\"\\ 4\\ 4\\ 4SA9SSfj5r[\"\\ 4\\ 4\\4Sg9SShj5r\\"\\ 4\\ 4S,9SSij5r]\"\\ 4\\ 4S,9SSjj5r^\"\\ 4\\ 4S,9SSkj5r_\"\\ 4\\ 4\\ 4Sl9SSmj5r`\"\\ 4\\ 4\\ 4\aSn9SSoj5rb\"\\ 4\\ 4Sp9SSqj5rc\"\\ 4\\ 4\4Sr9SSsj5rdSStjre\"\P\PSu9SSvj5rfSSwjrg\"\\ 4S9SSxj5rh\"\\ 4\4Sy9SSzj5ri\"\\ 4S9SS{j5rj\"\\ 4\4S|9SS}j5rk\"\\ 4S9SS~j5rl\"\\ 4S9SSj5rmSSjrnSSjroSSjrpSSjrqSSjrr\"\\ 4S9SSj5rs\"\\ 4\S49SSj5rt\"\\ 4S9SSj5ru\"\\ 4S9SSj5rv\"\\ 4\S49SSj5rw\"\\ 4\S49SSj5rx\"\\ 4\S49SSj5ry\"\\ 4\S49SSj5rz\"\\ 4\S49SSj5r{\"\\ 4\S49SSj5r|\"\\ 4\S49SSj5r}\"\\ 4\S49SSj5r~\SSj5r\SSj5rSr\SSj5rSrSr\S5rSSjrSrg) BosClientXz 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 rD _send_requestrGETrCs r) list_bucketsBosClient.list_buckets_s !!,"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,paramsrD)rIrrJlocation_constraint)r(rMrDrPresponses r)get_bucket_locationBosClient.get_bucket_locationjs8s#%%l&6&6 [a%b+++r,c>UR[RXS9$)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 rG)rIrPUTr(rMrDs r) create_bucketBosClient.create_bucket{s !!,"2"2K!OOr,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 rGTNF) rIrHEADr isinstance last_errorr status_codehttpclient FORBIDDEN NOT_FOUND)r(rMrDes 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,rOrHrWs r)get_bucket_aclBosClient.get_bucket_acls2!!  } " r,c~0n[UR5H!up#URS5(aMX1U'M# U$)N_)r__dict__ startswith)aclr4kvs r)_dump_acl_objectBosClient._dump_acl_objects9cll+DA<<$$q , r,)rMrnc UR[RU[R"SU0[ R S9[R[R0SS0US9 g)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** accessControlListdefaultrgr,bodyheadersrPrDN rIrrVjsondumpsr?rqr CONTENT_TYPErJSON)r(rMrnrDs r)set_bucket_aclBosClient.set_bucket_acls_ <++& $ ,?+E3<3M3M!O$0$=$=?Q?V?V#W#)3-"(  *r,)rM canned_aclcjUR[RU[RU0SS0US9 g)zA :param bucket_name: :param canned_acl: :param config: :return: rgr,ryrPrDN)rIrrVrBCE_ACL)r(rMrrDs r)set_bucket_canned_aclBosClient.set_bucket_canned_acls: <++&$0$8$8*#E#)3-"(  *r,c [R"U5nUR[RU[ R "SU0[RS9[R[R0SS0US9$). :param bucket_name: :param config: :return: storageClassru storageClassr,rw rconvert_to_stringrIrrVr{r|r?rqrr}rr~)r(rMrrDs 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,rOrHrWs 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** rGrIrDELETErWs r) delete_bucketBosClient.delete_buckets !!,"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** indexnotFoundruwebsiter,rwrz)r(rMr not_foundrDrxs 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,rOrHrWs r)get_bucket_static_website#BosClient.get_bucket_static_website$s2!!,"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,rOrrWs r)delete_bucket_static_website&BosClient.delete_bucket_static_website5s2!!,"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** encryptionAlgorithmru encryptionr,rwr)r(rMencryption_algorithmrDs r)put_bucket_encryptionBosClient.put_bucket_encryptionFsx &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,rOrHrWs r)get_bucket_encryptionBosClient.get_bucket_encryption^s2!!,"2"2�#"6"("* *r,cFUR[RUSS0US9$)zh Close server encryption :type bucket: string :param bucket: None :return: **HttpResponse Class** rr,rOrrWs r)delete_bucket_encryption"BosClient.delete_bucket_encryptionos2!!,"5"5�#"6"("* *r,)rMresourcec 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** rrucopyrightProtectionr,rwrz)r(rMrrDs 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,rOrHrWs 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,rOrrWs r)"delete_bucket_copyright_protection,BosClient.delete_bucket_copyright_protections2!!,"5"5]"?"("* *r,)rM 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,ididrurw rconvert_to_bytesrIrrVr{r|r?rqrr}rr~)r(rMrrDrPs 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,rrOrrrIrrJr(rMrrDrPs 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,rrOrrrIrrrs 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,rrOrrs 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,)rslistrOrHrWs r)list_bucket_replication!BosClient.list_bucket_replications2!!,"2"2&36"E"("* *r,)rM 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** rrur, inventoryrrwr)r(rMrrDconf_ids r)put_bucket_inventoryBosClient.put_bucket_inventory'ss)))D/:!!,"2"2& $ 93<3M3M!O$0$=$=?Q?V?V#W14W"E"( "* *r,)rMinventory_conf_idcpUR[RUS[R"U5S.US9$)zv Get configuration of bucket inventory :type bucket: string :param bucket: None :return: **HttpResponse Class** r,rrO)rIrrJrrr(rMrrDs r)get_bucket_inventoryBosClient.get_bucket_inventory>s>!!,"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,rrO)rIrrrrrs r)delete_bucket_inventory!BosClient.delete_bucket_inventoryNs>!!,"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,rOrHrWs r)list_bucket_inventoryBosClient.list_bucket_inventory^s2!!,"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** trashDirrutrashr,rwr)r(rM trash_dirrDs r)put_bucket_trashBosClient.put_bucket_trashnsy  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,rOrHrWs 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,rOrrWs r)delete_bucket_trashBosClient.delete_bucket_trashs1!!,"5"5&#+S/"("* *r,)rMkeyric [R"U5n[U5S:XdUS:Xa [S5eUR X5n U=(d 0nU=(d 0nUbXl[ R"U RU R 5upn U nXR:waUS[R"U 5-- nX[R'URXU5nU [R:wa U [R:wa [!S/5nU R"b+U R"U[R$R'5'[(R*"U R,U UUUUUU5U[R.R'5'S[R"U R05UU[ R2"US54-$)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** rsv1z!generate url the key param error!:shosts %s://%s%s?%sF)rrlen ValueError _merge_configprotocolr parse_host_portendpoint default_portrHOST _get_pathrrJr[setsecurity_tokenSTS_SECURITY_TOKENlowerrsign credentials AUTHORIZATIONnameget_canonical_querystring)r(rMr timestampexpiration_in_secondsryrPheaders_to_signrrD httpmethodendpoint_protocol endpoint_host endpoint_port full_hostpaths r)generate_pre_signed_url!BosClient.generate_pre_signed_urls<%%c* s8q=C5L@A A##F8-R2  &O  ! !&//6?? C 8-" :: :  7 7 FF FI%. !!"~~f37 )) )jLD>S>SF<2288: ;5B5G5G         ! 6|))//12&"9"9:K:P:P"Q!*!%!&!@!@!O"QQ Qr,)rMrulesc tUR[RUSS0[R"SU05US9$)z Put Bucket Lifecycle :type bucket: string :param bucket: None :type rules: list :param rules: None :return:**Http Response** lifecycler,rulerPrxrDrIrrVr{r|)r(rMrrDs 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** rr,rOrHrWs r)get_bucket_lifecycleBosClient.get_bucket_lifecycles2!!,"2"2"-*6)<)/"1 1r,cFUR[RUSS0US9$)z^ Delete Bucket Lifecycle :type bucket: string :param bucket: None :return:**Http Response** rr,rOrrWs r)delete_bucket_lifecycle!BosClient.delete_bucket_lifecycles2!!,"5"5"-*6)<)/"1 1r,)rMcors_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,corsConfigurationrr)r(rMrrDs r)put_bucket_corsBosClient.put_bucket_cors#sD!!,"2"2"-*13'+zz3FHZ2['\)/ "1 1r,cFUR[RUSS0US9$)zV Get Bucket Cors :type bucket: string :param bucket: None :return:**Http Response** r!r,rOrHrWs r)get_bucket_corsBosClient.get_bucket_cors8s1!!,"2"2"-*13)/"1 1r,cFUR[RUSS0US9$)zY Delete Bucket Cors :type bucket: string :param bucket: None :return:**Http Response** r!r,rOrrWs r)delete_bucket_corsBosClient.delete_bucket_corsGs1!!,"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 delimiterrOrH)r(rMmax_keysprefixmarker delimiterrDrPs r) list_objectsBosClient.list_objectsVs`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)r3r2r4rD)r5contents is_truncated next_marker)r(rMr2r4rDr3rRitems r)list_all_objectsBosClient.list_all_objects{s^((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)r\listtuple TypeErrorrrrRANGE)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_PREFIXrmrconvert_to_unicodemetadata user_metadatadata) http_responserRrP headers_list temp_headsrorpr2s 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 U5nUbUc0nXH[R'UR[RUUUUU[ RS9$)H :param bucket_name: :param key: :param range: :param config: :return: versionIdr/(Key can not be empty or start with '/' .ryrPrD body_parser) rrrrmrr?rGrBOS_TRAFFIC_LIMITrIrrJrU) r(rMrrF traffic_limit version_idrD query_params range_headers r) get_objectBosClient.get_objects  !00  $#! ;H77 8!!      !33"5 5r,c x[R"U5n0nUbX6[R'[R"U5S;a[ SR U55e[R"U5U[R'UR[RUUUSS0U[RS9$)z: :param bucket_name: :param key: :param config: :return: )Standard ExpeditedLowCostz\invalid tier:{} for restore_object.The valid value is "Standard" or "Expedited" or "LowCost"srestorer,r\) rrrBOS_RESTORE_DAYSrrformatBOS_RESTORE_TIERrIrPOSTr?rU)r(rMrdaystierrDrys r)restore_objectBosClient.restore_objects%%c*  59L11 2  # #D )1U U""(&,1 1171H1H1N --.!!     $!33"5 5r,c6[US5nU(a7[URR5n[R "XU5nOUn[ R"XuU5 UR5 UR5 g!UR5 f=f)NwbT) openintrOcontent_lengthr make_progress_adaptershutil copyfileobjclose)rRrR file_namebuf_sizeprogress_callbackf file_sizestreams r)_save_body_to_fileBosClient._save_body_to_filesy D !   1 1 @ @A 44]W`a&   v( 3    ! GGI GGIs A'BBc&URX5 g)NT)init_from_http_responserRrRselect_responses r)_parse_select_messageBosClient._parse_select_messages// Hr,c[R"U5nURXX4US9nURR 5nURR 5 U$)rX)rFr`rD)rrrcrQreadry)r(rMrrFr`rDrRss r)get_object_as_stringBosClient.get_object_as_string sP%%c*??;5bh?i MM    r,)rMrrzc ^^^^0n Ub[R"U5nSU0n [R"U5n[U5S:XdURS5(a [ S5e[R"T5m[ R U5n UbU c0n Xz[R'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** rYrrZr[c R>[RUUTTRTS5TS9$)N recv_buf_size)r|)r?r_get_config_parameter)rRrRrDrzr|r(s r).BosClient.get_object_to_file..Fs2 8T8T**6?C"3 9U95r,r\) rrrrmrr?rGrr^rIrrJ) r(rMrrzrFrDr|r_r`rarbs ` ` `` r)get_object_to_fileBosClient.get_object_to_files(  !00  $#! ;H77 8!!      5" 6 6r,c0nUb[R"U5nSU0n[R"U5nUR[RXXTS9$)z Get head of object :type bucket: string :param bucket: None :type key: string :param key: None :return: **_GetObjectMetaDataResponse Class** rYrO)rrrIrr[r(rMrr`rDras r)get_object_meta_dataBosClient.get_object_meta_dataNs^  !00@C@\@\]^ ^S!   &F9  ..tGD!!     " r,)rMrrQc[R"U5n[U[5(aUR [ R 5nSn[R"U5nUc$[R"XRU S5S9nURUUUU[U5UUUUU U U U U S9UbUR5 $$!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{)rMrrQrrurrrPrrrr|r_rD)rrr\rencodebaidubceDEFAULT_ENCODINGioBytesIOr get_md5_from_fprrrry)r(rMrrQrrrrPrrrr|r_rDfps r)append_object_from_string#BosClient.append_object_from_strings$%%c* dC ;;x889D  D!B"#33!;!;FO!TV %%+*-+-2=58Y-33?4A5C4A3?8I4A-3& 5~ r~ s A!CCc [R"U5n[R"U5nURUUUUUU U UUS9 nURUS5nU[R :a[ S[R -5eU(a[R"X>5nUR[RUUUUUS9$)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** rrr)rxryrD) rrrrrMAX_PUT_OBJECT_LENGTHrr rvrIrrV)r(rMrrQrurrrrPrr encryption customer_keycustomer_key_md5r|r_rrDryr{s r) put_objectBosClient.put_objectsL%%c*--k: ..)#%)''%')/ ,--foF C55 5>@C@Y@YZ[ [ 224K!!      " r,)bucketrrQc[R"U5n[U[5(aUR [ R 5nSn[R"U5nUc%[R"UURUS5S9nURXU[U5UUUUUU U U U U UUUS9UbUR5 $$!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** NrrrurrrrPrrrrrr|r_rrD)rrr\rrrrrrr rrrrry)r(rrrQrrrrPrrrrrr|r_rrDrs r)put_object_from_string BosClient.put_object_from_strings@%%c* dC ;;x889D  D!B"#33!;!;FO!TV ??625d)/:0<2@1>1>0<.80<4D7H1>2@*0#2 ~ r~ s A$CC)rrrzc[R"U5n[US5nUcAURS[R 5 UR 5nURS5 Uc(URUS5n[R"UUUS9nUc[R"U5nURXUUUUUUU U U U U UUUUS9UR5 $!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** rbrr)lengthr{r) rrrsseekosSEEK_ENDtellrr rguess_content_type_by_file_namerry)r(rrrzrurrrrPrrrrrr|r_rrDrrs r)put_object_from_fileBosClient.put_object_from_fileTsF%%c* )T " %2;;'!# " $ : :6? S #33B~=JL #$DDYO ??62@/:0<2@1>1>0<.80<4D5F1>2@*0#2 HHJBHHJs B%CC,)source_bucket_name source_keytarget_bucket_name target_keyc [R"U5n[R"U5nURUUUU U U S9n[R"S[R"U5U4-S5nU bUS[R"U 5--nUU[ R 'UbX_[ R'UcUbSU[ R'OSU[ R'U b[RXS5nUR[RUUUU[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** )rrPrrr_r/%s/%sFNs ?versionId=%ssreplacescopyT)ryrDr])rrrr normalize_stringrBCE_COPY_SOURCEBCE_COPY_SOURCE_IF_MATCHBCE_COPY_METADATA_DIRECTIVEr?_get_user_header ExceptionrIrrVrparse_copy_object_response)r(rrrretagrrPrrcopy_object_user_headersr_rsource_version_idrDrymerge_source_keyrcs r) copy_objectBosClient.copy_objectsdD,,Z8 ,,Z8 ..%''%') /+!11 ''(:; "$  (/2BVE\E\]nEo2oo 0@ ,,-  =AL99 :  $ (@@JGL<< =@GGL<< = # / #44WX\]!!     #>> "@ @  s)D// E9D;;Ec0nUb[R"U5nSU0n[R"U5nUR[RXXTS9$)z Delete Object :type bucket: string :param bucket: None :type key: string :param key: None :return: **HttpResponse Class** rYrOrrs r) delete_objectBosClient.delete_objects^  !00B88 C CC )rMr upload_id part_number part_sizepart_fpc r[R"U5nU[R:dU[R:a-[ SU[R[R4-5eU[R :a[ S[R -5e[RU[R[R0n UbX{[R'U(a[R"XhU5nU bX[R'UR!["R$UUUU XCS.U S9$)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. s partNumberuploadIdrw)rrrMIN_PART_NUMBERMAX_PART_NUMBERrrrCONTENT_LENGTHr}rr CONTENT_MD5r rvr^rIrrV) r(rMrrrrrpart_md5r|r_rDrys r) upload_partBosClient.upload_partjs*N%%c* ,, , c>Q>Q0QXS00#2E2E\GGH H s00 0J"889: : .. ,,.@.M.MO  08L,, - 11'iXG  $6CL22 3!!     #.G" r,)rrrrrrrrc [R"U5n[R"U5nURU 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** )rrPr_rFrArr) rrrr rrrBCE_COPY_SOURCE_RANGErrIrrV)r(rrrrrrrrrrrPr_rDryrFs r)upload_part_copyBosClient.upload_part_copysL,,Z8 ,,Z8 ..&2'4'4/6160F0F"f&=&=>P&Q#&%%&+1- ,,-#fy.@1.D%EE6; 223  =AL99 :!!     #.G " r,)rMrrrrrzrc [R"U5n[US5n U RU5 UR XX4X\XXS9 U R 5 $!U R 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)rr|r_rD)rrrsrrry) r(rMrrrrrzrrr|r_rDr}s r)upload_part_from_fileBosClient.upload_part_from_filese.%%c* D !  FF6N##Kii-52?$P GGIAGGIs #AA*)rMrr part_listc [R"U5nUR[RUUS9nUR [ RUU[R"SU05USU0S9$)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** )rrPrpartsr)rxryrP) rrrrr~rIrrlr{r|) r(rMrrrrPrrDrys r)complete_multipart_upload#BosClient.complete_multipart_upload s}6%%c*..+00'%/' !!     Wi01+ "- -r,)rMrrcp[R"U5nUR[RXSU0S9$)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(rMrrrDs r)abort_multipart_upload BosClient.abort_multipart_upload3s@ %%c*!!,"5"5{*5y)A"C Cr,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** rsmaxPartsspartNumberMarkerrOr)r(rMrr max_partspart_number_markerrDrPs r) list_partsBosClient.list_partsGsY0%%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)rrD)rrrrr:next_part_number_marker)r(rMrrrDrrRr<s 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,r0s maxUploadss keyMarkerr.rOrH)r(rM max_uploads key_markerr2r4rDrPs r)list_multipart_uploads BosClient.list_multipart_uploads}se8c"  #,<  "$/= !  !#-<   &9 !!,"2"2KW]!^^r,c#(# SnURUUUUUS9nURHnUv M UR(dgURb URnO4[ UR5S:waURSR nOgM7f)r8N)r#r2r4rDr)r$uploadsr:next_key_markerrr)r(rMr2r4rDr#rRr<s r)list_all_multipart_uploads$BosClient.list_all_multipart_uploadss 22;>H:@=F:@ 3BH !(( )((''3%55 X%%&!+%--b155 sBBc U R5(a%[RSRU55 gUR XUXEXgU U S9 n UR UU R RS.5 [RSRU55 g![a+n [RSRU55 U eSn A ff=f)Nz(upload task canceled with partNumber={}!)r|r_) partNumbereTagz'upload task success with partNumber={}!z&upload task failed with partNumber={}!) r5_loggerdebugrjrrLrOrr)r(rM object_keyrrrrzrruploadTaskHandler|r_rRrcs r) _upload_taskBosClient._upload_tasks  % % ' ' MMDKKKX Y  11+9 M^ -2/H   ) ))..  MMCJJ;W X  MMBII+V WG sA B C'&C  Cc jUS:dUS::a [S5e[RRU5n U S:a [S5eUbUS::a[R "5nUS-S-nX-nX-S:waUS- nUc [ 5nURXUUU S9Rn[U5n/nSnSn/nU S:aRX:aU nURURXUUUUUUXjU 5 nURU5 X-n UU- nUS- nU S:aMR[U[S 9 UR5(a&[ R#S 5 UR%XUS 9 g ['U5U:wa&[ R#S 5 UR%XUS 9 g UR)SS9 UR+XUU5 g)zV Multipart Upload file to bos param chunk_size: part size , default part size is 5MB irzEchunk size is valid, it should be more than 0 and not nore than 5120!lPCz'File size must not be more than 48.8TB!r i)rrr) return_whenz!putting super object is canceled!)rFzputting super object failed!c US$)Nr-r=)xs r)r6BosClient.put_super_obejct_from_file..sQ|_r,)rT)rrrgetsizemultiprocessing cpu_countrrrrsubmitr3rLr r r5r/r0rrsortr)r(rMrrz chunk_size thread_numr2rrrr|r_rD left_sizer total_partrexecutor all_tasksrrr temp_tasks r)put_super_obejct_from_file$BosClient.put_super_obejct_from_files  J!O gh hGGOOI. 1 1 IJ J  q'113:%, +  A % !OJ  #/1 22;)+)3+,59  &j1   !m$% t'8'8+IWbdm69.>S`bI   Y '  "I i F 1 K!m YM2  % % ' ' MM= >  ' ' i ' P ^z ) MM8 9  ' ' i ' P45 &&{INr,)rMrrnc [R"U5nUR[RUU[ R "SU0[RS9[R[R0SS0US9 g)z Set Access Control Level of object :type bucket: string :param bucket: None :type acl: list of grant :param acl: None :return: **HttpResponse Class** rtrurgr,rwNr)r(rMrrnrDs r)set_object_aclBosClient.set_object_aclsr%%c* <++& $ ,?+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 g) 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** Nrr z,donn't give any object canned acl arguments!r@z5cann't get more than one object canned acl arguments!rgr,r) rrrrBOS_GRANT_READBOS_GRANT_FULL_CONTROLrrIrrV) r(rMrr grant_readgrant_full_controlrDrynum_argss r)set_object_canned_aclBosClient.set_object_canned_acl/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,)rMract[R"U5nUR[RUUSS0US9$)z Get symlink info :type bucket: string :param bucket: None :type symlink: string :param symlink: symlink :return: **HttpResponse Class** rdr,rOr)r(rMrarDrs r)get_object_symlinkBosClient.get_object_symlinksF%%g.!!  "C( " r,)rMrselect_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 selectRequestrur,)sselectstypec0>[RXT5$rB)r?rrs r)r)BosClient.select_object.. s 8W8W9:r,)rxryrPrDr]) rrSelectResponserIrrlr{r|r?rq)r(rMrrmryrD select_typers @r) select_objectBosClient.select_objects %%c*-R #5 5&DVWkDl:l!K !%7 7EEWXlEm'U b'[R"U 5U [R@'U $![<anUeSnAff=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)!rrrrrr rrr}rrBCE_CONTENT_SHA256ETAGrr\dictrDraddrrMrrMAX_USER_METADATA_SIZErBOS_SERVER_SIDE_ENCRYPTION'BOS_SERVER_SIDE_ENCRYPTION_CUSTOMER_KEY+BOS_SERVER_SIDE_ENCRYPTION_CUSTOMER_KEY_MD5r?rrr^r)rurrrrrPrrrrrr_rry meta_size meta_data_setrorpnormalized_keyrcs r)r!BosClient._prepare_object_headers s  %.1"4 !IJJ393J3J>3ZGL// 0  "050P0PQ\0]GL,, -  #161Q1QR^1_GL-- .1C1P1PGL-- .  %7EL33 4  )053S3STX3Y)YGL%% &  $IEMmT22 GHH!-01!!!''),44Q744Q7!-!F!F!J*+'S00 SV# 13555 BSE_E__aa=!S%77 !HII  $6CL22 3  !?D?_?_`j?kGL;; <  #00> LHH I  '001AB LLL M  # #44WER  $6CL22 3  %060G0G0WGL,, -  s+L L LLc [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.)r\rrDrBOS_BASE_ALLOW_HEADERSunionr 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)ryris_copy bos_headersuser_headers_setrorps r)rBosClient._get_user_headerP 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$rB)getattrrD)r(rDattrr4s r)rBosClient._get_config_parameterj s3  V*F  Mt{{D))r,cURnU(a URn[R"URUR5upVnUR (d6[R "U5(d[R"Xa5(a%[R"[RU5$[R"[RX5$rB) rbackup_endpointr rr cname_enabledis_cname_like_hostis_custom_host append_urir URL_PREFIX)rDrMruse_backup_endpointhostr  host_namer s r)rBosClient._get_paths s ))D  ! !&//6?? C 4m   5#;#;I#F#F%J^J^_hJvJv##CNNC8 8 AAr,c[R"UR5nUbURU5 URX25nXClU$rB)copyrDmerge_non_none_values_change_user_endpointr)r(rDrM new_configrs 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.z??&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(ag[U[5(aqUR[R R :XagUR[R R:XagUR[R:Xagg)NTF) r\IOErrorrr^r_r`INTERNAL_SERVER_ERRORSERVICE_UNAVAILABLEcodeREQUEST_EXPIRED)errors r)_need_retry_backup_endpoint%BosClient._need_retry_backup_endpoint sq eW % % e^ , ,  DKK$E$EE  DKK$C$CCzz^;;;r,c URXr5n[RXrU5n Uc[RnUR b(U=(d 0nUR U[ R'[R"U[R[RU/XXEU5$![an URcU e[RU R 5(ak["R%S5 [RXrUS5n [R&"U[R[RU/XXEUS5 sSn A $U eSn A ff=f)NsRetry for backup endpoint.T)rr?rr parse_jsonrrrr send_requestrr parse_errorrrr.r]r/r0send_request_no_underlined) r( http_methodrMrrxryrPrDr]rrcs r)rIBosClient._send_request s/ ##F8""6<  !,,K  ,mG7=7L7LGL33 4 "// **W-@-@+,N4&: :" %%-44Q\\BB ;< **6TJ&AAM..1D1Dk0RtfdDD s%18B** E4BE EEEr=rB)NNN)NN)NNNN)NNNN)NrfN)i@N)NNNNN) NNNNNNNNNN) NNNNNNNNNNNN) NNNNNNNNNNNNN)NNNNNNNNNNNNNN) NNNNNNNN)NNNNNN)r7NNNNN)F)NNF)NNNNNNN)r7r8r9r:r;r*rKrrrrSrXrdrh staticmethodrqrBrrrrrrrrrENCRYPTION_ALGORITHMrrrrrrrrrrrrrrrrrrrrJrrrrr#r&r)r5r=rGrUrcrorrrrrobjectr integer_typesrrrrrrrrrrrrrtrr rrrrrr$r*r3rFrIrQrUrXr_boolrhrkrvrzrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr.rIr<r=r,r)r?r?Xs- C5#,',(, 5#,' P( P5#,'((5#,' ( 5#,T4L9*:*(5#,59 *: *5#,'*(*"5#,' *( *5#,' S( S5#,'*(*:5#,' *( * 5#,' *( * 5#,'FZcg*(*.5#,' *( * 5#,' *( *"5#,$8*9**5#,' *( * 5#,' *( * 5#,T;*<*05#,'*(*,5#,'*(*,5#,'*(*,5#,' *( *5#,49*:*,5#,5#,G *H *5#,5#,G *H *5#,' *( *5#,'*(*.5#,' *( * 5#,' *( *5#,UCL9+,6:(,'+04)-'++7+;+;EQ:EQN5#,tTl;%)1<1*5#,' 1( 15#,' 1( 15#,4@ $1A1(5#,' 1( 15#,' 1( 15#,'HL "_("_H5#,'((CC  D5#,UCL95:5<5#,UCL95:52 5#,UCL9 : 5#,UCLUCLQQUSW-6R-6`5#,UCL9,:,(5#,#,#11 #, (!"&#'$(#'"&'+#'$( : ( :x5#, %s|!& ./3)-/3041504/34804)-*.*X5#,#,#11 #, (!%"&!%!% $" $$(%)!%"&= ( =~eS\s|5#,G+/,0.2-1-1,0*.,00415-1.2&*:H:xeS\s|s|L,0)-*.,0+/+/*.(,*..2/3+/,0$(?M?B%"''!%"&"&!%-1"&#'&*B@ 'B@H5#,UCL90:0(5#,6171&UCL"CL"CL* )-!% 1*1.5#,' 1( 15#,' 1( 15#,UCL90404/3)- (:(T5#,#, ,, ?CGK;  ;z%"' ,,))+#&*'+'+ $2+2h5#,#, ,, )) +SWQU+45#,#,  15/3)- #- #-J5#,UCLUCLQCRC&5#,UCLUCLQ6:dRd@5#,UCLUCLQBRB(5#,'OS6:&*%_(%_N5#,'(:/3(5#,UCLUCLQQR!"@R@D5#,UCLtTlK*L*,5#,UCL9# 4*:4*l5#,UCL9:*5#,UCL9:*5#,UCLuclK$L$L5#,E3<%QTimoTXbf%*p%*P5#, =>*5#,UCLdXV#W#JJsD7E7&L5#,' ;( ;5#,th?;@;"5#,' ( 5#,TH=>$5#,'(5#,'( .2&& 5#,'MQ,0$_($_L5#,4@ $1A1(5#,' 1( 15#,' 1( 15#,4@ $1A1$5#,4@ $1A1(5#,4@ $ 1A 15#,4@ $1A1(5#,4@ $ 1A 15#,4@ $ 1A 15#,4@ $1A1(5#,4@ $ 1A 1!OOd2* B B*X   6:,0 r,r?c0\rSrSrSrSrSrSrSrSr g) SelectMessagei z) returned message from select object api c6SUlXlX lX0lg)z Initialize for record message RecordsN)typerypayloadcrc)r(ryrCrDs r)set_record_message SelectMessage.set_record_message s   r,cBSUlXlX lX0lX@lg)z! Initialize for continue message ContN)rBry bytes_scannedbytes_returnedrD)r(ryrIrJrDs r)set_cont_messageSelectMessage.set_cont_message s!  *,r,c*SUlXlX lg)z Initialize for end message EndN)rBryrD)r(ryrDs r)set_end_messageSelectMessage.set_end_message s  r,c&URS:Xa&SRURUR5$URS:Xa1SRURURUR 5$SRUR5$)NrAz{} {}rHz%{} bytes_scanned/bytes_returned={}/{}z{})rBrjryrCrIrJr's r)__str__SelectMessage.__str__ su 99 !??4<<> > YY& ;BB4<Irrz message-typerA rHz>QrNz error-codesuccessz error-message)r+ request_idT)rRrVr StopIterationrystructunpack_parse_select_headersr?rErrrKrrRrObce_request_idrO) r(r}prelude total_len headers_lenry headers_mapmsg payload_lenrCrDrIrJs r)r4SelectResponse.result s*  $ '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"&DKIAkkkB     $ $ &s I;IIII88I;c`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: rBr z>Hr@)rr`rarr)ryhmrkey_lenr value_lenvalues r)rb$SelectResponse._parse_select_headersH sc'l"mmC )BCAFG QJE1C  E dG519,EFqII QJE5#45E  E060H0H0OBv'', -c'l" r,)rVrRrRN) r7r8r9r:r;r*rr4r9rbr<r=r,r)rtrt s+!)'Vr,rt)>r;rr http.clientr_rr{loggingrwr`builtinsrr future.utilsrrrconcurrent.futuresrr r r r$ functoolsr;rr r baidubce.authrbaidubce.bce_base_clientrbaidubce.exceptionrrr baidubce.httprrrrrbaidubce.servicesrbaidubce.services.bosrrbaidubce.utilsrr getLoggerr7r/FETCH_MODE_SYNCFETCH_MODE_ASYNCr:rrr?r;r?rtr=r,r)rs   88WW-'2--1)!,&&!-/#   H %4L. L.^\&-F&-PPVPr,