"hj+FddlmZddlmZddlmZddlmZddlddlmZm Z m Z ddl m Z ddlm Z d d lZd d lZej#eZGd d eZy ) )http) exceptions)Bucket)_make_range_string)*) to_stringurlsplitparse_qs)BaseCryptoProvider ClientErrorNceZdZdZ dfd ZdZ dfd ZddZ ddZ ddZ ddZ dd Z dd Z dfd Z dfd Zdfd Zdfd Z ddZdZxZS) CryptoBucketu用于加密Bucket和Object操作的类，诸如上传、下载Object等。创建、删除bucket的操作需使用Bucket类接口。 用法（假设Bucket属于杭州区域） :: >>> import oss2 >>> auth = oss2.Auth('your-access-key-id', 'your-access-key-secret') >>> bucket = oss2.CryptoBucket(auth, 'http://oss-cn-hangzhou.aliyuncs.com', 'your-bucket', oss2.LocalRsaProvider()) >>> bucket.put_object('readme.txt', 'content of the object') :param auth: 包含了用户认证信息的Auth对象 :type auth: oss2.Auth :param str endpoint: 访问域名或者CNAME :param str bucket_name: Bucket名 :param crypto_provider: 客户端加密类。该参数默认为空 :type crypto_provider: oss2.crypto.BaseCryptoProvider :param bool is_cname: 如果endpoint是CNAME则设为True；反之，则为False。 :param session: 会话。如果是None表示新开会话，非None则复用传入的会话 :type session: oss2.Session :param float connect_timeout: 连接超时时间，以秒为单位。 :param str app_name: 应用名。该参数不为空，则在User Agent中加入其值。 注意到，最终这个字符串是要作为HTTP Header的值传输的，所以必须要遵循HTTP标准。 :param bool enable_crc: 如果开启crc校验则设为True；反之，则为False ct|ts tdtj dj |t t|#|||||||| | | | |  ||_ i|_ tj|_ |jr0tj dz|jzdzt"z|_ytj dzt"z|_y)Nz9crypto_provider must be an instance of BaseCryptoProviderzInit CryptoBucket: {0})proxiesregion cloudbox_id is_path_style/) isinstancer r loggerdebugformatsuperr__init__crypto_providerupload_contexts threadingLockupload_contexts_lockapp_namer USER_AGENTOSS_ENCRYPTION_CLIENT user_agent)selfauthendpoint bucket_nameris_cnamesessionconnect_timeoutr" enable_crcrrrr __class__s P/root/.hermes/SkillClaw/.venv/lib/python3.12/site-packages/oss2/crypto_bucket.pyrzCryptoBucket.__init__2s/+=>YZ Z -44[AB lD*4;RY[jlt+5wvcn@M + N /!$-NN$4! =="oo3dmmCcILaaDO"oo36KKDOcTd|vr|j|d<y|dxxdtzz cc<y)Nz User-Agentr)r%r$)r&headerss r/_init_user_agentzCryptoBucket._init_user_agentNs. w &$(OOGL ! L !S+@%@ @ !r0cHtjdtj|}|j ||j j }|j j||j}|j|}tt|3||||S)u\上传一个普通文件。 用法 :: >>> bucket.put_object('readme.txt', 'content of readme.txt') >>> with open(u'local_file.txt', 'rb') as f: >>> bucket.put_object('remote_file.txt', f) :param mat_desc: map，对象文件的description :param key: 上传到OSS的文件名 :param data: 待上传的内容。 :type data: bytes，str或file-like object :param headers: 用户指定的HTTP头部。可以指定Content-Type、Content-MD5、x-oss-meta-开头的头部等 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :param progress_callback: 用户指定的进度回调函数。可以用来实现进度条等功能。参考 :ref:`progress_callback` 。 :return: :class:`PutObjectResult ` z#Start to put object to CryptoBucket) rrrCaseInsensitiveDictr3rcreate_content_materialmake_encrypt_adaptercipherto_object_metarr put_object)r&keydatar2progress_callbackcontent_crypto_materialr.s r/r:zCryptoBucket.put_objectTs.  :;**73 g&"&"6"6"N"N"P##88?V?]?]^)88A\43CwHYZZr0ctd)u 使用加签的url上传对象 :param sign_url: 加签的url :param data: 待上传的数据 :param headers: 用户指定的HTTP头部。可以指定Content-Type、Content-MD5、x-oss-meta-开头的头部等，必须和签名时保持一致 :param progress_callback: 用户指定的进度回调函数。参考 :ref:`progress_callback` :return: 1The operation is not support for CryptoBucket nowr )r&sign_urlr<r2r=s r/put_object_with_urlz CryptoBucket.put_object_with_urlusMNNr0ctdNz-The operation is not support for CryptoBucketr )r&r;positionr<r2r=init_crcs r/ append_objectzCryptoBucket.append_objectIJJr0c |r tdtj|}|j|d}d}|r|d|dr td|jj |d|d\} } | | f} t | }|r||d<|dr| d|dkr |d| dz }tjdj|| |tjdj|jt|||||jd |j||| } tjd j| j| jt| ||j |j| S) u\下载一个文件。 用法 :: >>> result = bucket.get_object('readme.txt') >>> print(result.read()) 'hello world' :param key: 文件名 :param byte_range: 指定下载范围。参见 :ref:`byte_range` :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :param progress_callback: 用户指定的进度回调函数。参考 :ref:`progress_callback` :param process: oss文件处理，如图像服务等。指定后process，返回的内容为处理后的文件。 :param params: http 请求的查询字符串参数 :type params: dict :return: file-like object :raises: 如果文件不存在，则抛出 :class:`NoSuchKey ` ；还可能抛出其他异常 9Process object operation is not support for Crypto Bucketrr:Don't support range get while start is none and end is notrangeQadjust range of get object, byte_range: {0}, adjust_byte_range: {1}, discard: {2}z[Start to get object from CryptoBucket: {0}, key: {1}, range: {2}, headers: {3}, params: {4}GET)r2paramsz.Get object done, req_id: {0}, status_code: {1}rdiscard)r rr5r3r adjust_rangerrrrr)r_do request_idstatusGetObjectResultr-) r&r; byte_ranger2r=processrPrR range_stringstartendadjust_byte_rangeresps r/ get_objectzCryptoBucket.get_objects< YZ Z**73 g& !}$A!"^__--:::a=*UV-XJE3!& -.?@L#/ !}!21!5 1 !E$Q-*;A*>> LLlss-w8 9  i p p  )C., Q Rxxt//gfxU ELLT__^b^i^ijkt%6Y]YmYm'.0 0r0ctt|j}|rtj|vr t dt j|}|j|d}d}|r|ds|dr t d|jj|d|d\}} || f} t| }|r||d<|dr| d|dkr |d| dz }tjdj|| |tjdj|j||||j!d || } t#| ||j$|j| S) u1使用加签的url下载文件 :param sign_url: 加签的url :param byte_range: 指定下载范围。参见 :ref:`byte_range` :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict，必须和签名时保持一致 :param progress_callback: 用户指定的进度回调函数。参考 :ref:`progress_callback` :return: file-like object :raises: 如果文件不存在，则抛出 :class:`NoSuchKey ` ；还可能抛出其他异常 rJrrKrrLrMrNz\Start to get object with url from CryptoBucket: {0}, sign_url: {1}, range: {2}, headers: {3}rO)r2rQ)r r queryrPROCESSr rr5r3rrSrrrrr)_do_urlrWr-) r&rArXr2r=rarRrZr[r\r]r^s r/get_object_with_urlz CryptoBucket.get_object_with_urlst$(+112 fnn-YZ Z**73 g& a=Z]!"^__--:::a=*UV-XJE3!& -.?@L#/ !}!21!5 1 !E$Q-*;A*>> LLlss-w8 9  j q q  (L' C D||E8W|=t%6/3/C/CWV Vr0ctd)Nz.The operation is not support for Crypto Bucketr )r&r;select_meta_paramss r/create_select_object_metaz&CryptoBucket.create_select_object_metasJKKr0ctdrDr )r&r;sqlr= select_paramss r/ select_objectzCryptoBucket.select_objectrHr0ctj|}|j||r |js t dt j dj|j|j|jrG|jjj|j|j}|s?t d|jjj|j|_|jj}||_|j||}t t"|K||}|S)u客户端加密初始化分片上传。 :param params :param upload_context :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`InitMultipartUploadResult ` 返回值中的 `crypto_multipart_context` 记录了加密Meta信息，在upload_part时需要一并传入 zSIt is not support none upload_context and must specify data_size of upload_context zNStart to init multipart upload by CryptoBucket, data_size: {0}, part_size: {1}z:part_size is invalid for multipart upload for CryptoBucket)rr5r3 data_sizer rinfor part_sizerr8is_valid_part_sizedetermine_part_sizer6r>r9rrinit_multipart_upload) r&r;r2rPupload_contextresr>r^r.s r/rrz"CryptoBucket.init_multipart_uploads**73 g&^%=%=st t dkk  $ $n&>&>@ A  # #&&--@@AYAY[i[s[stC!"^__'+';';'B'B'V'VWeWoWo'pN $"&"6"6"N"N"P1H.)88.Q\4>sGL r0ctjdj||tj|}|j ||r|}n t d|j} | j|jjjk7s#| j|jjk7rd} t| || j||}|jj| j } |jj#| j$} |j&|dz z} |jjj)| }t+j*| j}|j-| | ||jj/||}t0t2|k||||||}|S)u客户端加密上传一个分片。 :param upload_context: :param str key: 待上传文件名，这个文件名要和 :func:`init_multipart_upload` 的文件名一致。 :param str upload_id: 分片上传ID :param int part_number: 分片号，最小值是1. :param data: 待上传数据。 :param progress_callback: 用户指定进度回调函数。可以用来实现进度条等功能。参考 :ref:`progress_callback` 。 :param headers: 用户指定的HTTP头部。可以指定Content-MD5头部等 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`PutObjectResult ` zMStart to upload multipart of CryptoBucket, upload_id = {0}, part_number = {1}zWCould not init upload context, upload contexts flag is False and upload context is nonez@Envelope or data encryption/decryption algorithm is inconsistentr)rrnrrr5r3r r>cek_algrr8algwrap_algInconsistentErrorr9decrypt_encrypted_key encrypted_keydecrypt_encrypted_iv encrypted_ivro calc_offsetcopy initializer7rr upload_part)r&r; upload_id part_numberr<r=r2rscontextr>err_msg plain_keyplain_ivoffsetcounterr8r^r.s r/rzCryptoBucket.upload_part's  [ b bclcn p q**73 g& $Gwx x")"A"A " * *d.B.B.I.I.M.M MQhQqQq$$--R.XG#GT2 2)88'J((>>?V?d?de ''<<=T=a=ab""kAo6&&--99&A299:)Xw7##88vF\44S)[RVXikrs r0ctjdj|tj|}|j | t t|#||||}|S#t$r}|d}~wwxYw)u客户端加密完成分片上传，创建文件。 当所有分片均已上传成功，才可以调用此函数 :param str key: 待上传的文件名，这个文件名要和 :func:`init_multipart_upload` 的文件名一致。 :param str upload_id: 分片上传ID :param parts: PartInfo列表。PartInfo中的part_number和etag是必填项。其中的etag可以从 :func:`upload_part` 的返回值中得到。 :type parts: list of `PartInfo ` :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`PutObjectResult ` zCStart to complete multipart upload of CryptoBucket, upload_id = {0}N) rrnrrr5r3rrcomplete_multipart_uploadr)r&r;rpartsr2r^er.s r/rz&CryptoBucket.complete_multipart_uploadVsx  Y``ajkl**73 g& tFsIW\^efD  G s A%% A5.A00A5ctjdj|tj|}|j | t t|#||}|S#t$r}|d}~wwxYw)uU取消分片上传。 :param headers: 可以是dict，建议是oss2.CaseInsensitiveDict :param str key: 待上传的文件名，这个文件名要和 :func:`init_multipart_upload` 的文件名一致。 :param str upload_id: 分片上传ID :return: :class:`RequestResult ` z@Start to abort multipart upload of CryptoBucket, upload_id = {0}N) rrnrrr5r3rrabort_multipart_uploadr)r&r;rr2r^rr.s r/rz#CryptoBucket.abort_multipart_uploadpsr  V]]^ghi**73 g& tCCSD  G s A## A3,A..A3ctd)u!分片拷贝。把一个已有文件的一部分或整体拷贝成目标文件的一个分片。 :param target_part_number: :param target_upload_id: :param target_key: :param source_key: :param source_bucket_name: :param byte_range: 指定待拷贝内容在源文件里的范围。参见 :ref:`byte_range` :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`PutObjectResult ` r@r )r&source_bucket_name source_keyrX target_keytarget_upload_idtarget_part_numberr2s r/upload_part_copyzCryptoBucket.upload_part_copys MNNr0ctdrDr )r&r;rYs r/process_objectzCryptoBucket.process_objectsIJJr0) FNNrKTNNNF)NN)NNN)NNNNN)N)__name__ __module__ __qualname____doc__rr3r:rBrGr_rdrgrkrrrrrrr __classcell__)r.s@r/rrs@ !% !$L8A %)[B O#(,#K#%) =0@(,$(.20VdL)-$(K $L-^4*6:O$Kr0r)rKrrrapirmodelscompatrr r cryptor r rrlogging getLoggerrrrr0r/rsH#11&#    8 $EK6EKr0