o iP@sdZddlZddlmZddlmZddlmZddlmZddlmZdd lmZdd lm Z dd lTdd l m Z m Z m Z mZdd lTdd l TddlZddlZeeZGd ddeZGdddeZGdddeZddZdZdZdZdZddZddZddZ GdddeZ!dS)u%. 文件上传方法中的data参数 ------------------------ 诸如 :func:`put_object ` 这样的上传接口都会有 `data` 参数用于接收用户数据。`data` 可以是下述类型 - unicode类型（对于Python3则是str类型）：内部会自动转换为UTF-8的bytes - bytes类型：不做任何转换 - file-like object：对于可以seek和tell的file object，从当前位置读取直到结束。其他类型，请确保当前位置是文件开始。 - 可迭代类型：对于无法探知长度的数据，要求一定是可迭代的。此时会通过Chunked Encoding传输。 Bucket配置修改方法中的input参数 ----------------------------- 诸如 :func:`put_bucket_cors ` 这样的Bucket配置修改接口都会有 `input` 参数接收用户提供的配置数据。 `input` 可以是下述类型 - Bucket配置信息相关的类，如 `BucketCors` - unicode类型（对于Python3则是str类型） - 经过utf-8编码的bytes类型 - file-like object - 可迭代类型，会通过Chunked Encoding传输 也就是说 `input` 参数可以比 `data` 参数多接受第一种类型的输入。 返回值 ------ :class:`Service` 和 :class:`Bucket` 类的大多数方法都是返回 :class:`RequestResult ` 及其子类。`RequestResult` 包含了HTTP响应的状态码、头部以及OSS Request ID，而它的子类则包含用户真正想要的结果。例如， `ListBucketsResult.buckets` 就是返回的Bucket信息列表；`GetObjectResult` 则是一个file-like object，可以调用 `read()` 来获取响应的 HTTP包体。 :class:`CryptoBucket`: 加密接口 ------- CryptoBucket仅提供上传下载加密数据的接口，诸如`get_object` 、 `put_object` ，返回值与Bucket相应接口一致。 异常 ---- 一般来说Python SDK可能会抛出三种类型的异常，这些异常都继承于 :class:`OssError ` ： - :class:`ClientError ` ：由于用户参数错误而引发的异常； - :class:`ServerError ` 及其子类：OSS服务器返回非成功的状态码，如4xx或5xx； - :class:`RequestError ` ：底层requests库抛出的异常，如DNS解析错误，超时等； 当然，`Bucket.put_object_from_file` 和 `Bucket.get_object_to_file` 这类函数还会抛出文件相关的异常。 .. _byte_range: 指定下载范围 ------------ 诸如 :func:`get_object ` 以及 :func:`upload_part_copy ` 这样的函数，可以接受 `byte_range` 参数，表明读取数据的范围。该参数是一个二元tuple：(start, last)。这些接口会把它转换为Range头部的值，如： - byte_range 为 (0, 99) 转换为 'bytes=0-99'，表示读取前100个字节 - byte_range 为 (None, 99) 转换为 'bytes=-99'，表示读取最后99个字节 - byte_range 为 (100, None) 转换为 'bytes=100-'，表示读取第101个字节到文件结尾的部分（包含第101个字节） 分页罗列 ------- 罗列各种资源的接口，如 :func:`list_buckets ` 、 :func:`list_objects ` 都支持 分页查询。通过设定分页标记（如：`marker` 、 `key_marker` ）的方式可以指定查询某一页。首次调用将分页标记设为空（缺省值，可以不设）， 后续的调用使用返回值中的 `next_marker` 、 `next_key_marker` 等。每次调用后检查返回值中的 `is_truncated` ，其值为 `False` 说明 已经到了最后一页。 .. _line_range: 指定查询CSV文件范围 ------------ 诸如 :func:`select_object ` 以及 :func:`select_object_to_file ` 这样的函数的select_csv_params参数，可以接受 `LineRange` 参数，表明读取CSV数据的范围。该参数是一个二元tuple：(start, last): - LineRange 为 (0, 99) 表示读取前100行 - LineRange 为 (None, 99) 表示读取最后99行 - LineRange 为 (100, None) 表示读取第101行到文件结尾的部分（包含第101行） .. _split_range: 指定查询CSV文件范围 ------------ split可以认为是切分好的大小大致相等的csv行簇。每个Split大小大致相等，这样以便更好的做到负载均衡。 诸如 :func:`select_object ` 以及 :func:`select_object_to_file ` 这样的函数的select_csv_params参数，可以接受 `SplitRange` 参数，表明读取CSV数据的范围。该参数是一个二元tuple：(start, last): - SplitRange 为 (0, 9) 表示读取前10个Split - SplitRange 为 (None, 9) 表示读取最后9个split - SplitRange 为 (10, None) 表示读取第11个split到文件结尾的部分（包含第11个Split） 分页查询 ------- 和create_csv_object_meta配合使用，有两种方法： - 方法1：先获取文件总的行数(create_csv_object_meta返回)，然后把文件以line_range分成若干部分并行查询 - 方法2：先获取文件总的Split数(create_csv_object_meta返回), 然后把文件分成若干个请求，每个请求含有大致相等的Split .. _progress_callback: 上传下载进度 ----------- 上传下载接口，诸如 `get_object` 、 `put_object` 、`resumable_upload`，都支持进度回调函数，可以用它实现进度条等功能。 `progress_callback` 的函数原型如下 :: def progress_callback(bytes_consumed, total_bytes): '''进度回调函数。 :param int bytes_consumed: 已经消费的字节数。对于上传，就是已经上传的量；对于下载，就是已经下载的量。 :param int total_bytes: 总长度。 ''' 其中 `total_bytes` 对于上传和下载有不同的含义： - 上传：当输入是bytes或可以seek/tell的文件对象，那么它的值就是总的字节数；否则，其值为None - 下载：当返回的HTTP相应中有Content-Length头部，那么它的值就是Content-Length的值；否则，其值为None .. _unix_time: Unix Time --------- OSS Python SDK会把从服务器获得时间戳都转换为自1970年1月1日UTC零点以来的秒数，即Unix Time。 参见 `Unix Time `_ OSS中常用的时间格式有 - HTTP Date格式，形如 `Sat, 05 Dec 2015 11:04:39 GMT` 这样的GMT时间。 用在If-Modified-Since、Last-Modified这些HTTP请求、响应头里。 - ISO8601格式，形如 `2015-12-05T00:00:00.000Z`。 用在生命周期管理配置、列举Bucket结果中的创建时间、列举文件结果中的最后修改时间等处。 `http_date` 函数把Unix Time转换为HTTP Date；而 `http_to_unixtime` 则做相反的转换。如 :: >>> import oss2, time >>> unix_time = int(time.time()) # 当前UNIX Time，设其值为 1449313829 >>> date_str = oss2.http_date(unix_time) # 得到 'Sat, 05 Dec 2015 11:10:29 GMT' >>> oss2.http_to_unixtime(date_str) # 得到 1449313829 .. note:: 生成HTTP协议所需的日期（即HTTP Date）时，请使用 `http_date` ， 不要使用 `strftime` 这样的函数。因为后者是和locale相关的。 比如，`strftime` 结果中可能会出现中文，而这样的格式，OSS服务器是不能识别的。 `iso8601_to_unixtime` 把ISO8601格式转换为Unix Time；`date_to_iso8601` 和 `iso8601_to_date` 则在ISO8601格式的字符串和 datetime.date之间相互转换。如 :: >>> import oss2 >>> d = oss2.iso8601_to_date('2015-12-05T00:00:00.000Z') # 得到 datetime.date(2015, 12, 5) >>> date_str = oss2.date_to_iso8601(d) # 得到 '2015-12-05T00:00:00.000Z' >>> oss2.iso8601_to_unixtime(date_str) # 得到 1449273600 .. _select_params: 指定OSS Select的文件格式。 对于Csv文件，支持如下Keys: >>> CsvHeaderInfo: None|Use|Ignore #None表示没有CSV Schema头，Use表示启用CSV Schema头，可以在Select语句中使用Name，Ignore表示有CSV Schema头，但忽略它（Select语句中不可以使用Name) 默认值是None >>> CommentCharacter: Comment字符,默认值是#,不支持多个字符 >>> RecordDelimiter: 行分隔符，默认是 ,最多支持两个字符分隔符（比如: ) >>> FieldDelimiter: 列分隔符，默认是逗号(,), 不支持多个字符 >>> QuoteCharacter: 列Quote字符，默认是双引号("),不支持多个字符。注意转义符合Quote字符相同。 >>> LineRange: 指定查询CSV文件的行范围，参见 `line_range`。 >>> SplitRange: 指定查询CSV文件的Split范围，参见 `split_range`. 注意LineRange和SplitRange两种不能同时指定。若同时指定LineRange会被忽略。 >>> CompressionType: 文件的压缩格式，默认值是None, 支持GZIP。 >>> OutputRawData: 指定是响应Body返回Raw数据，默认值是False. >>> SkipPartialDataRecord: 当CSV行数据不完整时(select语句中出现的列在该行为空)，是否跳过该行。默认是False。 >>> OutputHeader:是否输出CSV Header，默认是False. >>> EnablePayloadCrc:是否启用对Payload的CRC校验,默认是False. 该选项不能和OutputRawData:True混用。 >>> MaxSkippedRecordsAllowed: 允许跳过的最大行数。默认值是0表示一旦有一行跳过就报错。当下列两种情况下该行CSV被跳过:1）当SkipPartialDataRecord为True时且该行不完整时 2）当该行的数据类型和SQL不匹配时 对于Json 文件, 支持如下Keys: >>> Json_Type: DOCUMENT | LINES . DOCUMENT就是指一般的Json文件，LINES是指每一行是一个合法的JSON对象，文件由多行Json对象组成，整个文件本身不是合法的Json对象。 >>> LineRange: 指定查询JSON LINE文件的行范围，参见 `line_range`。注意该参数仅支持LINES类型 >>> SplitRange: 指定查询JSON LINE文件的Split范围，参见 `split_range`.注意该参数仅支持LINES类型 >>> CompressionType: 文件的压缩格式，默认值是None, 支持GZIP。 >>> OutputRawData: 指定是响应Body返回Raw数据，默认值是False. >>> SkipPartialDataRecord: 当一条JSON记录数据不完整时(select语句中出现的Key在该对象为空)，是否跳过该Json记录。默认是False。 >>> EnablePayloadCrc:是否启用对Payload的CRC校验,默认是False. 该选项不能和OutputRawData:True混用。 >>> MaxSkippedRecordsAllowed: 允许跳过的最大Json记录数。默认值是0表示一旦有一条Json记录跳过就报错。当下列两种情况下该JSON被跳过:1）当SkipPartialDataRecord为True时且该条Json记录不完整时 2）当该记录的数据类型和SQL不匹配时 >>> ParseJsonNumberAsString: 将Json文件中的数字解析成字符串。使用场景是当Json文件中的浮点数精度较高时，系统默认的浮点数精度无法达到要求，当解析成字符串时将完整保留原始数据精度，在Sql中使用Cast可以将字符串无精度损失地转成decimal. >>> AllowQuotedRecordDelimiter: 允许CSV中的列包含转义过的换行符。默认为true。当值为False时，select API可以用Range：bytes来设置选取目标对象内容的范围 ‘ .. _select_meta_params: create_select_object_meta参数集合，支持如下Keys: - RecordDelimiter: CSV换行符，最多支持两个字符 - FieldDelimiter: CSV列分隔符，最多支持一个字符 - QuoteCharacter: CSV转移Quote符，最多支持一个字符 - OverwriteIfExists: true|false. true表示重新获得csv meta，并覆盖原有的meta。一般情况下不需要使用 N) xml_utils)http)utils) exceptions)defaults)models) select_params)*)urlquoteurlparse to_unicode to_stringc@s4eZdZ d ddZddZd d Zed d ZdS)_BaseTNFc Cs||_t||_t|jdurtd||pt |_ t |t j |_||_||_||_| |_d|_| |_|jdurBd|_t|j|| |_| |_t|jdr_|jdkrad|_dSdSdS)NTz:The endpoint you has specified is not valid, endpoint: {0}ossz oss-cloudbox auth_versionv1F)auth_normalize_endpointstripendpointris_valid_endpoint ClientErrorformatrSessionsessionrgetconnect_timeouttimeoutapp_name enable_crcproxiesregionproduct cloudbox_id _UrlMaker _make_urlis_verify_object_stricthasattrr) selfrris_cnamerrr r!r"r#r% is_path_styler(r-r?)r*r@sign_urlrCrDrErFrGr-r-r._do_urls z _Base._do_urlcCs||}||||SN)r?)rE parse_funcklassresultr-r-r. _parse_result sz_Base._parse_result)rTNNNFT)__name__ __module__ __qualname__r/rHrJ staticmethodrOr-r-r-r.rs rcseZdZdZdZdZdZdZdZdZ dZ d Z d Z d1fdd Z d2ddZddZd3ddZd4ddZd5ddZd6ddZd7ddZdd Zd!d"Zd5d#d$Zd%d&Zd5d'd(Zd)d*Zd+d,Zd5d-d.Zd/d0ZZS)8Serviceu用于Service操作的类，如罗列用户所有的Bucket。 用法 :: >>> import oss2 >>> auth = oss2.Auth('your-access-key-id', 'your-access-key-secret') >>> service = oss2.Service(auth, 'oss-cn-hangzhou.aliyuncs.com') >>> service.list_buckets() :param auth: 包含了用户认证信息的Auth对象 :type auth: oss2.Auth :param str endpoint: 访问域名，如杭州区域的域名为oss-cn-hangzhou.aliyuncs.com :param session: 会话。如果是None表示新开会话，非None则复用传入的会话 :type session: oss2.Session :param float connect_timeout: 连接超时时间，以秒为单位。 :param str app_name: 应用名。该参数不为空，则在User Agent中加入其值。 注意到，最终这个字符串是要作为HTTP Header的值传输的，所以必须要遵循HTTP标准。 qosInforegionszx-oss-write-get-object-responsepublicAccessBlockrequesterQosInfo qosRequesterresourcePoolInfo resourcePoolresourcePoolBucketsNrFc s>td||||tt|j||d||||||| d dS)NzRInit oss service, endpoint: {0}, connect_timeout: {1}, app_name: {2}, proxies: {3}F)r r"r#r%r,)r:debugrsuperrTr/) r*rrrrr r"r#r%r, __class__r-r.r/6s zService.__init__r1cCstd|||i}||d<||d<t||d<t|}|dur(|||jddd||d}td |j|j | |t j t S) u根据前缀罗列用户的Bucket。 :param str prefix: 只罗列Bucket名为该前缀的Bucket，空串表示罗列所有的Bucket :param str marker: 分页标志。首次调用传空串，后续使用返回值中的next_marker :param int max_keys: 每次调用最多返回的Bucket数目 :param dict params: list操作参数，传入'tag-key','tag-value'对结果进行过滤 :param headers: 用户指定的HTTP头部。可以指定Content-Type、Content-MD5、x-oss-meta-开头的头部等。可以是dict，建议是oss2.CaseInsensitiveDict :return: 罗列的结果 :rtype: oss2.models.ListBucketsResult z>Start to list buckets, prefix: {0}, marker: {1}, max-keys: {2}prefixmarkermax-keysNGETrparamsr=z0List buckets done, req_id: {0}, status_code: {1})r:r]rstrrCaseInsensitiveDictupdaterH request_idr8rOrparse_list_bucketsListBucketsResult)r*rarbmax_keysrfr= listParamrEr-r-r. list_bucketsDs    zService.list_bucketscCHtd|jdddtjdid}td|j|j||t j t S)uo获取User的QoSInfo :return: :class:`GetUserQosInfoResult ` zStart to get user qos info.rdrrfz*get use qos, req_id: {0}, status_code: {1}) r:r]rHrTQOS_INFOrrjr8rOrparse_get_qos_infoGetUserQosInfoResultr*rEr-r-r.get_user_qos_info`s zService.get_user_qos_infocCsHtd|jdddtj|id}td|j|j||t j t S)u查询所有支持地域或者指定地域对应的Endpoint信息，包括外网Endpoint、内网Endpoint和传输加速Endpoint。 :param str regions : 地域。 :return: :class:`DescribeRegionsResult ` zStart to describe regionsrdrrqz4Describe regions done, req_id: {0}, status_code: {1}) r:r]rHrTREGIONSrrjr8rOrparse_describe_regionsDescribeRegionsResult)r*rVrEr-r-r.describe_regionsis zService.describe_regionscCsxtd|t|}|r||d<|r||d<|r||d<|jdddtjdi||d}td|j|j t |S) uwrite get object response. :param route: fc return route :param token: fc return token :param fwd_status: fwd_status :param data: 待上传的内容。 :type data: bytes，str或file-like object :param headers: 用户指定的HTTP头部。可以指定Content-Type、Content-MD5、x-oss-meta-开头的头部等 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`RequestResult ` z0Start to write get object response, headers: {0}zx-oss-request-routezx-oss-request-tokenzx-oss-fwd-statusPOSTrrfr=dataz=write get object response done, req_id: {0}, status_code: {1}) r:r]rrrhrHrTWRITE_GET_OBJECT_RESPONSErjr8 RequestResult)r*routetoken fwd_statusr}r=rEr-r-r.write_get_object_responsevs z!Service.write_get_object_responsec C\td|||jdddtjdd|dt|id}td|j|j| |t j t S)u.列举请求者所有的存储冗余转换任务。 :param str continuation_token: 分页标志,首次调用传空串 :param int max_keys: 最多返回数目 :return: :class:`ListUserDataRedundancyTransitionResult ` zUStart to list user data redundancy transition, continuation token: {0}, max keys: {1}rdrcontinuation-tokenrcrqzHList user data redundancy transition done, req_id: {0}, status_code: {1}) r:r]rrHBucketREDUNDANCY_TRANSITIONrgrjr8rOr*parse_list_user_data_redundancy_transition&ListUserDataRedundancyTransitionResultr*continuation_tokenrmrEr-r-r.$list_user_data_redundancy_transition$z,Service.list_user_data_redundancy_transitionc CsTtd|jdddtjddt|d|id}td|j|j| |t j t S)u查询某个Bucket下所有接入点。 param: int max_keys: 本次list返回access point的最大个数 param: str continuation_token: list时指定的起始标记 :return: :class:`ListBucketStyleResult ` z!Start to list bucket access pointrdrrcrrqz;query list access point done, req_id: {0}, status_code: {1}) r:r]rHr ACCESS_POINTrgrrjr8rOrparse_list_access_point_resultListAccessPointResultr*rmrrEr-r-r.list_access_pointss $zService.list_access_pointscCsLtdt|}|jddd|tjdid}td|j|j t |S)u为OSS全局开启阻止公共访问。 :param bool block_public_access : 是否开启阻止公共访问。 :return: :class:`RequestResult ` z Start to put public access blockPUTrr}rfz;Put public access block done, req_id: {0}, status_code: {1}) r:r]r"to_put_public_access_block_requestrHrTPUBLIC_ACCESS_BLOCKrrjr8rr*block_public_accessr}rEr-r-r.put_public_access_blocks  zService.put_public_access_blockcCrp)u获取OSS全局阻止公共访问的配置信息。 :return: :class:`GetPublicAccessBlockResult ` z Start to get public access blockrdrrqz;Get public access block done, req_id: {0}, status_code: {1}) r:r]rHrTrrrjr8rOr$parse_get_public_access_block_resultGetPublicAccessBlockResultrur-r-r.get_public_access_blocks zService.get_public_access_blockcCs@td|jdddtjdid}td|j|jt|S)u~删除OSS全局阻止公共访问配置信息。 :return: :class:`RequestResult ` z#Start to delete public access blockDELETErrqz>Delete public access block done, req_id: {0}, status_code: {1}) r:r]rHrTrrrjr8rrur-r-r.delete_public_access_blocks z"Service.delete_public_access_blockc Cr)u列举当前主账号在当前地域下的资源池。 :param str continuation_token: 分页标志,首次调用传空串 :param int max_keys: 最多返回数目 :return: :class:`ListResourcePoolsResult ` zDStart to list resource pools, continuation_token: {0}, max_keys: {1}rdrrrcrqz7List resource pools done, req_id: {0}, status_code: {1}) r:r]rrHrT RESOURCE_POOLrgrjr8rOrparse_list_resource_poolsListResourcePoolsResultrr-r-r.list_resource_poolsrzService.list_resource_poolscCs`td||std|jdddtjdtj|id}td|j|j | |t j t S)u获取特定资源池的基本信息。 :param str resource_pool_name : 请求的资源池的名称。 :return: :class:`ResourcePoolInfoResult ` z*Start to get resource pool info, uid: {0}.&resource_pool_name should not be emptyrdrrqz:Get resource pool info done, req_id: {0}, status_code: {1})r:r]rrrHrTRESOURCE_POOL_INFOrrjr8rOrparse_get_resource_pool_infoResourcePoolInfoResult)r*resource_pool_namerEr-r-r.get_resource_pool_infos zService.get_resource_pool_infoc Cptd||||std|jdddtjdtj|d|dt|id}td|j |j | |t j tS) uZ获取特定资源池中的Bucket列表。 :param str resource_pool_name : 请求的资源池的名称。 :param str continuation_token: 分页标志,首次调用传空串 :param int max_keys: 最多返回数目 :return: :class:`ListResourcePoolBucketsResult ` zbStart to list resource pool buckets, resource_pool_name:{0} continuation_token: {1}, max_keys: {2}rrdrrrcrqz>List resource pool buckets done, req_id: {0}, status_code: {1})r:r]rrrHrTRESOURCE_POOL_BUCKETSrrgrjr8rOr parse_list_resource_pool_bucketsListResourcePoolBucketsResultr*rrrmrEr-r-r.list_resource_pool_buckets  *z"Service.list_resource_pool_bucketsc Csztd||||std|stdt|}|jddd|tjdtj |tj |id}td|j |j t |S)uF修改子账号在资源池的请求者流控配置。 :param str uid: 请求者UID :param str resource_pool_name: 请求的资源池的名称 :param qos_configuration :class:`QoSConfiguration ` :return: :class:`RequestResult ` zhStart to put resource pool requester qos info, uid: {0}, resource_pool_name: {1}, qos_configuration: {2}uid should not be emptyrrrrzHPut resource pool requester qos info done, req_id: {0}, status_code: {1})r:r]rrrto_put_qos_inforHrTREQUESTER_QOS_INFO QOS_REQUESTERrrjr8r)r*uidrqos_configurationr}rEr-r-r.$put_resource_pool_requester_qos_infos &z,Service.put_resource_pool_requester_qos_infoc Csttd|||std|std|jdddtjdtj|tj|id}td|j |j | |t j tS)u获取子账号在资源池的流控配置。 :return: :class:`RequesterQoSInfoResult ` zQStart to get resource pool requester qos info, uid: {0}, resource_pool_name: {1}.rrrdrrqzHGet resource pool requester qos info done, req_id: {0}, status_code: {1})r:r]rrrHrTrrrrjr8rOrparse_get_requester_qos_infoRequesterQoSInfoResultr*rrrEr-r-r.$get_resource_pool_requester_qos_infos$z,Service.get_resource_pool_requester_qos_infoc Cr) uw列举子账号账号在资源池的流控配置。 :param str resource_pool_name : 请求的资源池的名称。 :param str continuation_token: 分页标志,首次调用传空串 :param int max_keys: 最多返回数目 :return: :class:`ListResourcePoolRequesterQoSInfosResult ` znStart to list resource pool requester qos infos, resource_pool_name:{0} continuation_token: {1}, max_keys: {2}rrdrrrcrqzJList resource pool requester qos infos done, req_id: {0}, status_code: {1})r:r]rrrHrTrrrgrjr8rOr,parse_list_resource_pool_requester_qos_infos'ListResourcePoolRequesterQoSInfosResultrr-r-r.&list_resource_pool_requester_qos_infos'rz.Service.list_resource_pool_requester_qos_infosc Csltd|||std|std|jdddtjdtj|tj|id}td|j |j t |S)u删除子账号在资源池的请求者流控配置。 :return: :class:`RequestResult ` zTStart to delete resource pool requester qos info, uid: {0}, resource_pool_name: {1}.rrrrrqzKDelete resource pool requester qos info done, req_id: {0}, status_code: {1}) r:r]rrrHrTrrrrjr8rrr-r-r.'delete_resource_pool_requester_qos_info8s$z/Service.delete_resource_pool_requester_qos_info)NNrNNNF)rrr1NN)rrKrr1r1rF)rPrQrR__doc__rrrwr~rrrrrrr/rorvrzrrrrrrrrrrrrr __classcell__r-r-r_r.rTsF        rTcsFeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!d Z"d!Z#d"Z$d#Z%d$Z&d%Z'd&Z(d'Z)d(Z*d)Z+d*Z,d+Z-d,Z.d-Z/d.Z0d/Z1d0Z2d1Z3d2Z4d3Z5d4Z6d5Z7d6Z8d7Z9d8Z:d7Z9d9Z;d:Z = > > ? @ > > > = @dfdAdB Z?ddCdDZ@dEdFZAddHdIZBddKdLZC > >ddMdNZD > >ddOdPZEddQdRZF > >ddSdTZG > > >ddUdVZH > > > > >ddWdXZI > > > >ddYdZZJ > > > > >dd[d\ZK > > >dd]d^ZL > > >dd_d`ZM > > >ddadbZNddcddZOddedfZPddgdhZQddidjZRddkdlZSdmdnZTddodpZUddqdrZVddsdtZWddudvZXddwdxZYddydzZZdd{d|Z[dd}d~Z\dddZ]dddZ^ ? ? ? ? >dddZ_ >dddZ` >dddZadddZbdddZcdddZdddZeddZfddZgddZhddZiddZjdddZkddZlddZmddZnddZoddZpddZqddZrddZsddZtddZuddZvddZwddZxddZyddZzddZ{dddZ|ddZ}ddÄZ~ddńZdddȄZddʄZddd̄Zddd΄ZdddЄZddd҄ZddԄZddքZdd؄ZdddڄZdd܄ZdddބZ ? >dddZdddZddZddZddZddZddZddZddZddZddZddZddZddZddZddZddZdddZddZdddZddZdd d Zdd d Zd dZddZddZddZddZddZddZddZddZdd Zd!d"Zd#d$Zd%d&Zd'd(Zd)d*Zd+d,Zd-d.Zd/d0Zd1d2Zd3d4Zd5d6Zd7d8Zd9d:Zd;d<Zd=d>Zd?d@ZddAdBZdCdDZdEdFZdGdHZddIdJZdKdLZdMdNZÐdOdPZĐdQdRZŐdSdTZƐdUdVZǐdWdXZȐdYdZZɐd[d\Zʐd]d^Zːdd_d`Z̐dadbZ͐dcddZΐdedfZϐddgdhZАdidjZѐdkdlZҐddmdnZӐdodpZԐdqdrZՐdsdtZ֐dudvZאddwdxZؐdydzZِd{d|Zڐd}d~ZېddZ܇ZS(ru用于Bucket和Object操作的类，诸如创建、删除Bucket，上传、下载Object等。 用法（假设Bucket属于杭州区域） :: >>> import oss2 >>> auth = oss2.Auth('your-access-key-id', 'your-access-key-secret') >>> bucket = oss2.Bucket(auth, 'http://oss-cn-hangzhou.aliyuncs.com', 'your-bucket') >>> bucket.put_object('readme.txt', 'content of the object') :param auth: 包含了用户认证信息的Auth对象 :type auth: oss2.ProviderAuth or oss2.ProviderAuthV4 :param str endpoint: 访问域名或者CNAME :param str bucket_name: Bucket名 :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 is_verify_object_strict: 严格验证对象名称的标志。默认为True。 aclcors lifecyclelocationloggingrefererwebsitelivecompr8vodsymlinkstat bucketInfo x-oss-processtagging encryptionversions versioning versionIdrestore objectMetapolicyrequestPaymentrUqos asyncFetch sequential inventory inventoryIdrwormwormId wormExtend replicationreplicationLocationreplicationProgresstransferAccelerationcname metaQuery accessmonitor resourceGroupstyle styleNamezx-oss-async-processcallbackbucketArchiveDirectRead httpsConfigredundancyTransitionzx-oss-target-redundancy-typez"x-oss-redundancy-transition-taskid accessPointaccessPointPolicyx-oss-access-point-namerWrXrYrZr[FNrTcsltd||||||| | tt|j|||||||| | | | | d ||_t |jdur4t ddS)NzInit Bucket: {0}, endpoint: {1}, isCname: {2}, connect_timeout: {3}, app_name: {4}, enabled_crc: {5}, region: {6}, proxies: {6})r r!r"r#r%r,r(Tz,The bucket_name is invalid, please check it.) r:r]rr^rr/rrAris_valid_bucket_namer)r*rrrAr+rrr r!r"r#r%r,r(r_r-r.r/s  zBucket.__init__c Cs|dus t|dkrtdt|}|jr |dr tdtd||j t|||||t j || |j |||||j |j|jd}d} |durX|j||j ||} | S|jj||j |||d } | S) u生成签名URL。 常见的用法是生成加签的URL以供授信用户下载，如为log.jpg生成一个5分钟后过期的下载链接:: >>> bucket.sign_url('GET', 'log.jpg', 5 * 60) r'http://your-bucket.oss-cn-hangzhou.aliyuncs.com/logo.jpg?OSSAccessKeyId=YourAccessKeyId\&Expires=1447178011&Signature=UJfeJgvcypWq6Q%2Bm3IJcSHbvSak%3D' :param method: HTTP方法，如'GET'、'PUT'、'DELETE'等 :type method: str :param key: 文件名 :param expires: 过期时间（单位：秒），链接在当前时间再过expires秒后过期 :param headers: 需要签名的HTTP头部，如名称以x-oss-meta-开头的头部（作为用户自定义元数据）、 Content-Type头部等。对于下载，不需要填。 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :param params: 需要签名的HTTP查询参数 :param slash_safe: 是否开启key名称中的‘/’转义保护，如果不开启'/'将会转义成%2F :type slash_safe: bool :param additional_headers: 额外的需要签名的HTTP头 :return: 签名URL。 Nrz$The key is invalid, please check it.?z/The key cannot start with `?`, please check it.zoStart to sign_url, method: {0}, bucket: {1}, key: {2}, expires: {3}, headers: {4}, params: {5}, slash_safe: {6})r=rfr#r$r%r)in_additional_headers)lenrrrr( startswithr:r]rrArr5r'r#r$r%r _sign_url) r*r@rBexpiresr=rf slash_safeadditional_headersrDrIr-r-r.rIs.zBucket.sign_urlcCsptd|j|||||jdddddd|}i}|dur-|dkr-||d <|j||j|||S) u生成RTMP推流的签名URL。 常见的用法是生成加签的URL以供授信用户向OSS推RTMP流。 :param channel_name: 直播频道的名称 :param expires: 过期时间（单位：秒），链接在当前时间再过expires秒后过期 :param playlist_name: 播放列表名称，注意与创建live channel时一致 :param params: 需要签名的HTTP查询参数 :return: 签名URL。 zOSign RTMP url, bucket: {0}, channel_name: {1}, playlist_name: {2}, expires: {3}rhttp://zrtmp://https:///Nr playlistName)r:r]rrAr'replacer_sign_rtmp_url)r* channel_name playlist_namerurlrfr-r-r. sign_rtmp_urls zBucket.sign_rtmp_urlr1c Csrt|}td|jt||t|||jd|||t|dd|d}td|j |j | |t j tS)u:根据前缀罗列Bucket里的文件。 :param str prefix: 只罗列文件名为该前缀的文件 :param str delimiter: 分隔符。可以用来模拟目录 :param str marker: 分页标志。首次调用传空串，后续使用返回值的next_marker :param int max_keys: 最多返回文件的个数，文件和目录的和不能超过该值 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`ListObjectsResult ` z[Start to List objects, bucket: {0}, prefix: {1}, delimiter: {2}, marker: {3}, max-keys: {4}rdr)ra delimiterrbrc encoding-typerez0List objects done, req_id: {0}, status_code: {1})rrhr:r]rrAr_Bucket__do_bucketrgrjr8rOrparse_list_objectsListObjectsResult)r*rarrbrmr=rEr-r-r. list_objectss" zBucket.list_objectsrc Cst|}td|jt||||||||jdd||||t| t||d|d} td| j | j | | t jtS)u!根据前缀罗列Bucket里的文件。 :param str prefix: 只罗列文件名为该前缀的文件 :param str delimiter: 分隔符。可以用来模拟目录 :param str continuation_token: 分页标志。首次调用传空串，后续使用返回值的next_continuation_token :param str start_after: 起始文件名称，OSS会返回按照字典序排列start_after之后的文件。 :param bool fetch_owner: 是否获取文件的owner信息，默认不返回。 :param int max_keys: 最多返回文件的个数，文件和目录的和不能超过该值 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`ListObjectsV2Result ` zStart to List objects, bucket: {0}, prefix: {1}, delimiter: {2}, continuation_token: {3}, start-after: {4}, fetch-owner: {5}, encoding_type: {6}, max-keys: {7}rd2)z list-typerarrz start-afterz fetch-ownerrcrrez3List objects V2 done, req_id: {0}, status_code: {1})rrhr:r]rrArr rglowerrjr8rOrparse_list_objects_v2ListObjectsV2Result) r*rarr start_after fetch_owner encoding_typermr=rEr-r-r.list_objects_v2s*   zBucket.list_objects_v2cCstt||}|rt||}|jrt|}td |j t |||j d|||d}td |j |jt|}|jrQ|jdurQtd|j|j|j |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 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 ` z8Start to put object, bucket: {0}, key: {1}, headers: {2}rr}r=z.Put object done, req_id: {0}, status_code: {1}N put object)rset_content_typerrhmake_progress_adapterr!make_crc_adapterr:r]rrAr_Bucket__do_objectrjr8PutObjectResultcrc check_crc)r*rBr}r=progress_callbackrErNr-r-r. put_object:s  zBucket.put_objectcCsptt||}td|jt||t t |d}|j ||||dWdS1s1wYdS)u%上传一个本地文件到OSS的普通文件。 :param str key: 上传到OSS的文件名 :param str filename: 本地文件名，需要有可读权限 :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;Put object from file, bucket: {0}, key: {1}, file path: {2}rbr=rN) rrrrhr:r]rrAropenr r)r*rBfilenamer=rfr-r-r.put_object_from_filecs $zBucket.put_object_from_filecCst|}|r t||}|jrt|}td|j |||j d|||d}td|j |j t |}|jrK|jdurKtd|j|j|j |S)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: zMStart to put object with signed url, bucket: {0}, sign_url: {1}, headers: {2}rrz7Put object with url done, req_id: {0}, status_code: {1}Nr)rrhrrr!rr:r]rrArJrjr8rrr)r*rIr}r=rrErNr-r-r.put_object_with_urlxs   zBucket.put_object_with_urlcCsZtd|j||tt|d}|j||||dWdS1s&wYdS)u 使用加签的url上传本地文件到oss :param sign_url: 加签的url :param filename: 本地文件路径 :param headers: 用户指定的HTTP头部。可以指定Content-Type、Content-MD5、x-oss-meta-开头的头部等，必须和签名时保持一致 :param progress_callback: 用户指定的进度回调函数。参考 :ref:`progress_callback` :return: zPPut object from file with signed url, bucket: {0}, sign_url: {1}, file path: {2}r r!N)r:r]rrAr"r r&)r*rIr#r=rr$r-r-r.put_object_with_url_from_files  $z$Bucket.put_object_with_url_from_filec Cstt||}|rt||}|jr|durt||}td |j t ||||j d|||dt |dd}td |j|jt|}|jra|jdura|duratd|j|j|j|S) u追加上传一个文件。 :param str key: 新的文件名，或已经存在的可追加文件名 :param int position: 追加上传一个新的文件， `position` 设为0；追加一个已经存在的可追加文件， `position` 设为文件的当前长度。 `position` 可以从上次追加的结果 `AppendObjectResult.next_position` 中获得。 :param data: 用户数据 :type data: str、bytes、file-like object或可迭代对象 :param headers: 用户指定的HTTP头部。可以指定Content-Type、Content-MD5、x-oss-开头的头部等 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :param progress_callback: 用户指定的进度回调函数。参考 :ref:`progress_callback` :return: :class:`AppendObjectResult ` :raises: 如果 `position` 和当前文件长度不一致，抛出 :class:`PositionNotEqualToLength ` ； 如果当前文件不是可追加类型，抛出 :class:`ObjectNotAppendable ` ； 还会抛出其他一些异常 NzJStart to append object, bucket: {0}, key: {1}, headers: {2}, position: {3}r{r)appendpositionr}r=rfz0Append object done, req_id: {0}, statu_code: {1}z append object)rrrrhrr!rr:r]rrArrrgrjr8AppendObjectResultrr) r*rBr)r}r=rinit_crcrErNr-r-r. append_objects$   zBucket.append_objectc Cst|}t|}|r||d<|durin|}|r!|tj|itd|j t |||||j d|||d}td|j |j t|||jS)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 ` ；还可能抛出其他异常 rangeNuSStart to get object, bucket: {0}， key: {1}, range: {2}, headers: {3}, params: {4}rdr=rfz.Get object done, req_id: {0}, status_code: {1})rrh_make_range_stringrirPROCESSr:r]rrArrrjr8GetObjectResultr!) r*rB byte_ranger=rprocessrf range_stringrEr-r-r. get_objects zBucket.get_objectc Csd}t|}t|}|r||d<d}|dkr/|dus+tj|vs+t|tjdkr/tdt ||} ddi} |durFtj |vrFd | d<d |_ |j d || || d } d} |durktj |vrkt|tj d krkd} t| || S)uSelect一个文件内容，支持(Csv,Json Doc,Json Lines及其GZIP压缩文件). 用法 :: 对于Csv: >>> result = bucket.select_object('access.log', 'select * from ossobject where _4 > 40') >>> print(result.read()) 'hello world' 对于Json Doc: { contacts:[{"firstName":"abc", "lastName":"def"},{"firstName":"abc1", "lastName":"def1"}]} >>> result = bucket.select_object('sample.json', 'select s.firstName, s.lastName from ossobject.contacts[*] s', select_params = {"Json_Type":"DOCUMENT"}) 对于Json Lines: {"firstName":"abc", "lastName":"def"},{"firstName":"abc1", "lastName":"def1"} >>> result = bucket.select_object('sample.json', 'select s.firstName, s.lastName from ossobject s', select_params = {"Json_Type":"LINES"}) :param key: 文件名 :param sql: sql statement :param select_params: select参数集合,对于Json文件必须制定Json_Type类型。参见 :ref:`select_params` :param progress_callback: 用户指定的进度回调函数。参考 :ref:`progress_callback` :param byte_range: select content of specific range。可以设置Bytes header指定select csv时的文件起始offset和长度。 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: file-like object :raises: 如果文件不存在，则抛出 :class:`NoSuchKey ` ；还可能抛出其他异常 Fr.TNfalsezm"AllowQuotedRecordDelimiter" must be specified in select_params as False when "Range" is specified in header.rz csv/selectz json/selectr{r*true)rrhr0SelectParametersAllowQuotedRecordDelimiterrgrrrto_select_object Json_TyperrEnablePayloadCrcSelectObjectResult) r*rBsqlrr r3r= range_selectr5bodyrfrE crc_enabledr-r-r. select_objects*!    zBucket.select_objectc Cstd|jt||tt|dL}|j||||||d} | jdur,t | |n t j | || j| j d|jrW|durW|dusLd|vsL|ddkrWt d| j| j| j | WdS1scwYdS) u下载一个文件到本地文件。 :param key: 文件名 :param filename: 本地文件名。要求父目录已经存在，且有写权限。 :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: 如果文件不存在，则抛出 :class:`NoSuchKey ` ；还可能抛出其他异常 zBStart to get object to file, bucket: {0}, key: {1}, file path: {2}wb)r3r=rr4rfNrjzAccept-Encodinggzipr)r:r]rrArr"r r6rGshutil copyfileobjrcopyfileobj_and_verifyrjr!r client_crc server_crc) r*rBr#r3r=rr4rfr$rNr-r-r.get_object_to_file>s   $zBucket.get_object_to_filecCsTt|}t|}|r||d<td|j||||jd||d}t|||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 ` ；还可能抛出其他异常 r.zRStart to get object with url, bucket: {0}, sign_url: {1}, range: {2}, headers: {3}rdr=) rrhr0r:r]rrArJr2r!)r*rIr3r=rr5rEr-r-r.get_object_with_urlgs  zBucket.get_object_with_urlc Cstd|j||||tt|d*}|j||||d}|jdur*t ||n t j |||j|j d|WdS1sAwYdS)u使用加签的url下载文件 :param sign_url: 加签的url :param filename: 本地文件名。要求父目录已经存在，且有写权限。 :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 ` ；还可能抛出其他异常 zbStart to get object with url, bucket: {0}, sign_url: {1}, file path: {2}, range: {3}, headers: {4}rE)r3r=rNrF) r:r]rrAr"r rOrGrHrIrrJrj)r*rIr#r3r=rr$rNr-r-r.get_object_with_url_to_files  $z"Bucket.get_object_with_url_to_filec Cs^tt|d}|j|||||d}|D]} || q|WdS1s(wYdS)u&Select一个文件的内容到本地文件 :param key: OSS文件名 :param filename: 本地文件名。其父亲目录已经存在且有写权限。 :param progress_callback: 调用进度的callback。参考 :ref:`progress_callback` :param select_params: select参数集合。参见 :ref:`select_params` :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: 如果文件不存在, 抛出 :class:`NoSuchKey ` rE)rr r=N)r"r rDwrite) r*rBr#r@rr r=r$rNchunkr-r-r.select_object_to_files  $zBucket.select_object_to_filecCsRtd|jt|||jd|||d}td|j|j||t j t S)u获取文件元信息。 HTTP响应的头部包含了文件元信息，可以通过 `RequestResult` 的 `headers` 成员获得。 用法 :: >>> result = bucket.head_object('readme.txt') >>> print(result.content_type) text/plain :param key: 文件名 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :param params: HTTP请求参数，传入versionId，获取指定版本Object元信息 :type params: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`HeadObjectResult ` :raises: 如果Bucket不存在或者Object不存在，则抛出 :class:`NotFound ` z9Start to head object, bucket: {0}, key: {1}, headers: {2}HEADr/z/Head object done, req_id: {0}, status_code: {1}) r:r]rrArrrjr8rOrparse_dummy_resultHeadObjectResult)r*rBr=rfrEr-r-r. head_objects  zBucket.head_objectcCsVt|}t|}ddi}|durd|vrd|d<d|_|jd||||d}t|S) uK获取或创建CSV,JSON LINES 文件元信息。如果元信息存在，返回之；不然则创建后返回之 HTTP响应的头部包含了文件元信息，可以通过 `RequestResult` 的 `headers` 成员获得。 CSV文件用法 :: >>> select_meta_params = { 'FieldDelimiter': ',', 'RecordDelimiter': ' ', 'QuoteCharacter': '"', 'OverwriteIfExists' : 'false'} >>> result = bucket.create_select_object_meta('csv.txt', select_meta_params) >>> print(result.rows) JSON LINES文件用法 :: >>> select_meta_params = { 'Json_Type':'LINES', 'OverwriteIfExists':'False'} >>> result = bucket.create_select_object_meta('jsonlines.json', select_meta_params) :param key: 文件名 :param select_meta_params: 参数词典，可以是dict，参见ref:`csv_meta_params` :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`GetSelectObjectMetaResult `. 除了 rows 和splits 属性之外, 它也返回head object返回的其他属性。 rows表示该文件的总记录数。 splits表示该文件的总Split个数，一个Split包含若干条记录，每个Split的总字节数大致相当。用户可以以Split为单位进行分片查询。 :raises: 如果Bucket不存在或者Object不存在，则抛出:class:`NotFound ` rzcsv/metaNr=z json/metar8r{r*)rrhrto_get_select_object_metarrGetSelectObjectMetaResult)r*rBselect_meta_paramsr=rBrfrEr-r-r.create_select_object_metas  z Bucket.create_select_object_metacCstt|}td|jt||durt}tj |vr"d|tj <|j d|||d}td|j |j t |S)u获取文件基本元信息，包括该Object的ETag、Size（文件大小）、LastModified，并不返回其内容。 HTTP响应的头部包含了文件基本元信息，可以通过 `GetObjectMetaResult` 的 `last_modified`，`content_length`,`etag` 成员获得。 :param key: 文件名 :param dict params: 请求参数 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`GetObjectMetaResult ` :raises: 如果文件不存在，则抛出 :class:`NoSuchKey ` ；还可能抛出其他异常 z3Start to get object metadata, bucket: {0}, key: {1}NrrTrez7Get object metadata done, req_id: {0}, status_code: {1})rrhr:r]rrArdictr OBJECTMETArrjr8GetObjectMetaResultr*rBrfr=rEr-r-r.get_object_metas   zBucket.get_object_metacCsntd|jt|z |j||dWdStjy!YdStjy)tj y3YdS)u{如果文件存在就返回True，否则返回False。如果Bucket不存在，或是发生其他错误，则抛出异常。z6Start to check if object exists, bucket: {0}, key: {1}rNFT) r:r]rrArr`r NoSuchKey NoSuchBucketNotFoundr*rBr=r-r-r. object_exists#s zBucket.object_existsc Cst|}|r!tj|vr!d|dt|dd|tj|t<n d|dt|d|t<td|t ||j t |||j d||d}td|j |j t|S)u拷贝一个文件到当前Bucket。 :param str source_bucket_name: 源Bucket名 :param str source_key: 源文件名 :param str target_key: 目标文件名 :param dict params: 请求参数 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`PutObjectResult ` rr ?versionId=z^Start to copy object, source bucket: {0}, source key: {1}, bucket: {2}, key: {3}, headers: {4}rrNz/Copy object done, req_id: {0}, status_code: {1})rrhr VERSIONIDr OSS_COPY_OBJECT_SOURCEr:r]rrrArrjr8r)r*source_bucket_name source_key target_keyr=rfrEr-r-r. copy_objectCs(  zBucket.copy_objectcCs<|durd|t<td|jt||j|j|||dS)u更改Object的元数据信息，包括Content-Type这类标准的HTTP头部，以及以x-oss-meta-开头的自定义元数据。 用户可以通过 :func:`head_object` 获得元数据信息。 :param str key: 文件名 :param headers: HTTP头部，包含了元数据信息 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`RequestResult ` NREPLACEz6Start to update object metadata, bucket: {0}, key: {1}rN)OSS_METADATA_DIRECTIVEr:r]rrArrlrdr-r-r.update_object_metaas zBucket.update_object_metacCsRt|}td|jt||jd|||d}td|j |j t |S)u删除一个文件。 :param str key: 文件名 :param params: 请求参数 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`RequestResult ` z-Start to delete object, bucket: {0}, key: {1}rrez1Delete object done, req_id: {0}, status_code: {1}) rrhr:r;rrArrr]rjr8rr_r-r-r. delete_objectts zBucket.delete_objectcCst|}td|jt||durt}tj |vr"d|tj <| t t j |}|jd||||d}td|j|jt|S)uxrestore an object 如果是第一次针对该object调用接口，返回RequestResult.status = 202； 如果已经成功调用过restore接口，且服务端仍处于解冻中，抛异常RestoreAlreadyInProgress(status=409) 如果已经成功调用过restore接口，且服务端解冻已经完成，再次调用时返回RequestResult.status = 200，且会将object的可下载时间延长一天，最多延长7天。 如果object不存在，则抛异常NoSuchKey(status=404)； 对非Archive类型的Object提交restore，则抛异常OperationNotSupported(status=400) 也可以通过调用head_object接口来获取meta信息来判断是否可以restore与restore的状态 代码示例:: >>> meta = bucket.head_object(key) >>> if meta.resp.headers['x-oss-storage-class'] == oss2.BUCKET_STORAGE_CLASS_ARCHIVE: >>> bucket.restore_object(key) >>> while True: >>> meta = bucket.head_object(key) >>> if meta.resp.headers['x-oss-restore'] == 'ongoing-request="true"': >>> time.sleep(5) >>> else: >>> break :param str key: object name :param params: 请求参数 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :param input: 解冻配置。 :type input: class:`RestoreConfiguration ` :return: :class:`RequestResult ` z.Start to restore object, bucket: {0}, key: {1}Nrr{r|z2Restore object done, req_id: {0}, status_code: {1})rrhr:r]rrArr\rRESTORE_Bucket__convert_dataRestoreConfigurationrto_put_restore_configrrjr8r)r*rBrfr=inputr}rEr-r-r.restore_objects   zBucket.restore_objectcCs~td|jt||t|}||t<|durt}t j |vr'd|t j <|j d|||d}td|j |j t|S)u设置文件的ACL。 :param str key: 文件名 :param str permission: 可以是oss2.OBJECT_ACL_DEFAULT、oss2.OBJECT_ACL_PRIVATE、oss2.OBJECT_ACL_PUBLIC_READ或 oss2.OBJECT_ACL_PUBLIC_READ_WRITE。 :param dict params: 请求参数 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`RequestResult ` z8Start to put object acl, bucket: {0}, key: {1}, acl: {2}Nrrrez2Put object acl done, req_id: {0}, status_code: {1})r:r]rrArrrhOSS_OBJECT_ACLr\rACLrrjr8r)r*rB permissionrfr=rEr-r-r.put_object_acls    zBucket.put_object_aclcCs|td|jt|t|}|durt}tj |vr"d|tj <|j d|||d}td|j |j | |tjtS)u获取文件的ACL。 :param key: 文件名 :param params: 请求参数 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`GetObjectAclResult ` z.Start to get object acl, bucket: {0}, key: {1}Nrrdrez2Get object acl done, req_id: {0}, status_code: {1})r:r]rrArrrhr\rrxrrjr8rOrparse_get_object_aclGetObjectAclResultr_r-r-r.get_object_acls   zBucket.get_object_aclcCs|stdtd|j|t|d}t|}t ||d<|j d|ddd|d }td |j |j ||tjtS) u!批量删除文件。待删除文件列表不能为空。 :param key_list: 文件名列表，不能为空。 :type key_list: list of str :param headers: HTTP头部 :return: :class:`BatchDeleteObjectsResult ` zkey_list should not be emptyz/Start to delete objects, bucket: {0}, keys: {1}F Content-MD5r{rrdeleterr}rfr=z2Delete objects done, req_id: {0}, status_code: {1})rr:r]rrArto_batch_delete_objects_requestrrhr content_md5r rjr8rOparse_batch_delete_objectsBatchDeleteObjectsResult)r*key_listr=r}rEr-r-r.batch_delete_objectss   zBucket.batch_delete_objectscCs|stdtd|jt|d}t|}t ||d<|j d|ddd|d }td |j |j ||tjtS) u{批量删除带版本文件。待删除文件列表不能为空。 :param key_list_with_version: 带版本的文件名列表，不能为空。（如果传入，则不能为空） :type key_list: list of BatchDeleteObjectsList :param headers: HTTP头部 :return: :class:`BatchDeleteObjectsResult ` z$keylist_versions should not be emptyz,Start to delete object versions, bucket: {0}Fr~r{rrrrz:Delete object versions done, req_id: {0}, status_code: {1})rr:r]rrAr'to_batch_delete_objects_version_requestrrhrrr rjr8rOrr)r*keylist_versionsr=r}rEr-r-r.delete_object_versionss   zBucket.delete_object_versionscCstt||}|durt}n|}d|d<td|j t ||||j d|||d}td|j |j ||tjtS)u初始化分片上传。 返回值中的 `upload_id` 以及Bucket名和Object名三元组唯一对应了此次分片上传事件。 :param str key: 待上传的文件名 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`InitMultipartUploadResult ` NruploadszQStart to init multipart upload, bucket: {0}, keys: {1}, headers: {2}, params: {3}r{rez9Init multipart upload done, req_id: {0}, status_code: {1})rrrrhr\copyr:r]rrArrrjr8rOrparse_init_multipart_uploadInitMultipartUploadResult)r*rBr=rf tmp_paramsrEr-r-r.init_multipart_uploads zBucket.init_multipart_uploadc Cst|}|r t||}|jrt|}td|j t |||||j d||t |d||d}td|j |jt|}|jrU|jdurUtd|j|j|j |S)u上传一个分片。 :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 ` z`Start to upload multipart, bucket: {0}, key: {1}, upload_id: {2}, part_number: {3}, headers: {4}r)uploadId partNumberr|z4Upload multipart done, req_id: {0}, status_code: {1}Nz upload part)rrhrrr!rr:r]rrArrrgrjr8rrr) r*rB upload_id part_numberr}rr=rErNr-r-r. upload_part9s(    zBucket.upload_partc Cst|}d}|durt|ddd}t|}td|jt ||||j d|d|i||d}td |j |j t |}|jrW|durWt|}td ||j|j |S) ue完成分片上传，创建文件。 :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 ` NcSs|jSrK)r)pr-r-r.psz2Bucket.complete_multipart_upload..)rBzUStart to complete multipart upload, bucket: {0}, key: {1}, upload_id: {2}, parts: {3}r{r)rfr}r=z=Complete multipart upload done, req_id: {0}, status_code: {1}zmultipart upload)rrhsortedrto_complete_upload_requestr:r]rrArrrjr8rr!rcalc_obj_crc_from_partsrr) r*rBrpartsr=r}rErN object_crcr-r-r.complete_multipart_upload^s*   z Bucket.complete_multipart_uploadcCsXtd|jt||t|}|jd|d|i|d}td|j|j t |S)ux取消分片上传。 :param str key: 待上传的文件名，这个文件名要和 :func:`init_multipart_upload` 的文件名一致。 :param str upload_id: 分片上传ID :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`RequestResult ` zFStart to abort multipart upload, bucket: {0}, key: {1}, upload_id: {2}rrrez3Abort multipart done, req_id: {0}, status_code: {1}) r:r]rrArrrhrrjr8r)r*rBrr=rEr-r-r.abort_multipart_uploads  zBucket.abort_multipart_uploadc Csxtd|jt||t|||t|}|jdd||||t|dd|d}td|j |j | |t j tS)u罗列正在进行中的分片上传。支持分页。 :param str prefix: 只罗列匹配该前缀的文件的分片上传 :param str delimiter: 目录分割符 :param str key_marker: 文件名分页符。第一次调用可以不传，后续设为返回值中的 `next_key_marker` :param str upload_id_marker: 分片ID分页符。第一次调用可以不传，后续设为返回值中的 `next_upload_id_marker` :param int max_uploads: 一次罗列最多能够返回的条目数 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`ListMultipartUploadsResult ` zStart to list multipart uploads, bucket: {0}, prefix: {1}, delimiter: {2}, key_marker: {3}, upload_id_marker: {4}, max_uploads: {5}rdrr)rrar key-markerzupload-id-markerz max-uploadsrrez:List multipart uploads done, req_id: {0}, status_code: {1})r:r]rrArrrhr rgrjr8rOrparse_list_multipart_uploadsListMultipartUploadsResult)r*rar key_markerupload_id_marker max_uploadsr=rEr-r-r.list_multipart_uploadss(  zBucket.list_multipart_uploadsc Cst|}|r!tj|vr!d|dt|dd|tj|t<n d|dt|d|t<t|} | r8| |t<t d |t ||j t ||||||durSt }||d<t||d<|jd|||d } t d | j| jt| S) u分片拷贝。把一个已有文件的一部分或整体拷贝成目标文件的一个分片。 :source_bucket_name: 源文件所在bucket的名称 :source_key:源文件名称 :param byte_range: 指定待拷贝内容在源文件里的范围。参见 :ref:`byte_range` :target_key: 目的文件的名称 :target_upload_id: 目的文件的uploadid :target_part_number: 目的文件的分片号 :param params: 请求参数 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`PutObjectResult ` rrrfzStart to upload part copy, source bucket: {0}, source key: {1}, bucket: {2}, key: {3}, range: {4}, upload id: {5}, part_number: {6}, headers: {7}Nrrrrez4Upload part copy done, req_id: {0}, status_code: {1})rrhrrgr rhr0OSS_COPY_OBJECT_SOURCE_RANGEr:r]rrrAr\rgrrjr8r) r*rirjr3rktarget_upload_idtarget_part_numberr=rfr5rEr-r-r.upload_part_copys<   zBucket.upload_part_copyc Csltd|jt||||t|}|jd|||t|d|d}td|j |j | |t j tS)u列举已经上传的分片。支持分页。 :param headers: HTTP头部 :param str key: 文件名 :param str upload_id: 分片上传ID :param str marker: 分页符 :param int max_parts: 一次最多罗列多少分片 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`ListPartsResult ` zWStart to list parts, bucket: {0}, key: {1}, upload_id: {2}, marker: {3}, max_parts: {4}rd)rzpart-number-markerz max-partsrez.List parts done, req_id: {0}, status_code: {1})r:r]rrArrrhrrgrjr8rOrparse_list_partsListPartsResult)r*rBrrb max_partsr=rEr-r-r. list_partss zBucket.list_partscCsnt|}t|d|t<td|jt|t|||j d||t j did}td|j |j t|S)u创建Symlink。 :param str target_key: 目标文件，目标文件不能为符号连接 :param str symlink_key: 符号连接类文件，其实质是一个特殊的文件，数据指向目标文件 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`RequestResult ` rzRStart to put symlink, bucket: {0}, target_key: {1}, symlink_key: {2}, headers: {3}rr/z/Put symlink done, req_id: {0}, status_code: {1})rrhr OSS_SYMLINK_TARGETr:r]rrArrrSYMLINKrjr8r)r*rk symlink_keyr=rEr-r-r. put_symlink s zBucket.put_symlinkcCsttd|jt|t|}|durt}tj |vr"d|tj <|j d|||d}td|j |j t |S)u获取符号连接文件的目标文件。 :param str symlink_key: 符号连接类文件 :param dict params: 请求参数 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`GetSymlinkResult ` :raises: 如果文件的符号链接不存在，则抛出 :class:`NoSuchKey ` ；还可能抛出其他异常 z3Start to get symlink, bucket: {0}, symlink_key: {1}Nrrdrez/Get symlink done, req_id: {0}, status_code: {1})r:r]rrArrrhr\rrrrjr8GetSymlinkResult)r*rrfr=rEr-r-r. get_symlink!s    zBucket.get_symlinkcCsjt|}|r ||t<|ttj|}td |j |||j d||d}td |j |j t|S)u9创建新的Bucket。 :param str permission: 指定Bucket的ACL。可以是oss2.BUCKET_ACL_PRIVATE（推荐、缺省）、oss2.BUCKET_ACL_PUBLIC_READ或是 oss2.BUCKET_ACL_PUBLIC_READ_WRITE。 :param input: :class:`BucketCreateConfig ` object zAStart to create bucket, bucket: {0}, permission: {1}, config: {2}r)r=r}z1Create bucket done, req_id: {0}, status_code: {1})rrhOSS_CANNED_ACLrrBucketCreateConfigrto_put_bucket_configr:r]rrAr rjr8r)r*ryrur=r}rEr-r-r. create_bucket=s  zBucket.create_bucketcCs:td|j|d}td|j|jt|S)u=删除一个Bucket。只有没有任何文件，也没有任何未完成的分片上传的Bucket才能被删除。 :return: :class:`RequestResult ` ":raises: 如果试图删除一个非空Bucket，则抛出 :class:`BucketNotEmpty ` z#Start to delete bucket, bucket: {0}rz1Delete bucket done, req_id: {0}, status_code: {1}) r:r;rrAr r]rjr8rrur-r-r. delete_bucketPs zBucket.delete_bucketcCsLtd|j||jdt|itjdid}td|j|j t |S)u设置Bucket的ACL。 :param str permission: 新的ACL，可以是oss2.BUCKET_ACL_PRIVATE、oss2.BUCKET_ACL_PUBLIC_READ或 oss2.BUCKET_ACL_PUBLIC_READ_WRITE z.Start to put bucket acl, bucket: {0}, acl: {1}rrr/z2Put bucket acl done, req_id: {0}, status_code: {1}) r:r]rrAr rrrxrjr8r)r*ryrEr-r-r.put_bucket_acl\szBucket.put_bucket_aclcCLtd|j|jdtjdid}td|j|j| |t j t S)um获取Bucket的ACL。 :return: :class:`GetBucketAclResult ` z$Start to get bucket acl, bucket: {0}rdrrqz2Get bucket acl done, req_id: {0}, status_code: {1}) r:r]rrAr rrxrjr8rOrparse_get_bucket_aclGetBucketAclResultrur-r-r.get_bucket_aclgzBucket.get_bucket_aclcCX|ttj|}td|j||jd|t j did}td|j |j t |S)us设置Bucket的CORS。 :param input: :class:`BucketCors ` 对象或其他 z0Start to put bucket cors, bucket: {0}, cors: {1}rrrz3Put bucket cors done, req_id: {0}, status_code: {1})rr BucketCorsrto_put_bucket_corsr:r]rrAr rCORSrjr8rr*rur}rEr-r-r.put_bucket_corsq zBucket.put_bucket_corscCr)uv获取Bucket的CORS配置。 :return: :class:`GetBucketCorsResult ` z%Start to get bucket CORS, bucket: {0}rdrrqz3Get bucket CORS done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rOrparse_get_bucket_corsGetBucketCorsResultrur-r-r.get_bucket_cors|rzBucket.get_bucket_corscCDtd|j|jdtjdid}td|j|jt |S)u删除Bucket的CORS配置。z(Start to delete bucket CORS, bucket: {0}rrrqz6Delete bucket CORS done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rrur-r-r.delete_bucket_corszBucket.delete_bucket_corscCsdt|}|ttj|}td|j ||j d|t j di|d}td|j |jt|S)u设置生命周期管理的配置。 :param input: :class:`BucketLifecycle ` 对象或其他 z:Start to put bucket lifecycle, bucket: {0}, lifecycle: {1}rrr8Put bucket lifecycle done, req_id: {0}, status_code: {1})rrhrrBucketLifecyclerto_put_bucket_lifecycler:r]rrAr r LIFECYCLErjr8r)r*rur=r}rEr-r-r.put_bucket_lifecycles zBucket.put_bucket_lifecyclecCr)u获取生命周期管理配置。 :return: :class:`GetBucketLifecycleResult ` :raises: 如果没有设置Lifecycle，则抛出 :class:`NoSuchLifecycle ` z*Start to get bucket lifecycle, bucket: {0}rdrrqz8Get bucket lifecycle done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rOrparse_get_bucket_lifecycleGetBucketLifecycleResultrur-r-r.get_bucket_lifecyclezBucket.get_bucket_lifecyclecCr)uQ删除生命周期管理配置。如果Lifecycle没有设置，也返回成功。z-Start to delete bucket lifecycle, bucket: {0}rrrqz;Delete bucket lifecycle done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rrur-r-r.delete_bucket_lifecyclerzBucket.delete_bucket_lifecyclecCr)u获取Bucket的数据中心。 :return: :class:`GetBucketLocationResult ` z)Start to get bucket location, bucket: {0}rdrrqz7Get bucket location done, req_id: {0}, status_code: {1}) r:r]rrAr rLOCATIONrjr8rOrparse_get_bucket_locationGetBucketLocationResultrur-r-r.get_bucket_locationrzBucket.get_bucket_locationcCr)u设置Bucket的访问日志功能。 :param input: :class:`BucketLogging ` 对象或其他 z6Start to put bucket logging, bucket: {0}, logging: {1}rrrz6Put bucket logging done, req_id: {0}, status_code: {1})rr BucketLoggingrto_put_bucket_loggingr:r]rrAr rLOGGINGrjr8rrr-r-r.put_bucket_loggingrzBucket.put_bucket_loggingcCr)u获取Bucket的访问日志功能配置。 :return: :class:`GetBucketLoggingResult ` z(Start to get bucket logging, bucket: {0}rdrrqz6Get bucket logging done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rOrparse_get_bucket_loggingGetBucketLoggingResultrur-r-r.get_bucket_loggingrzBucket.get_bucket_loggingcCr)u$关闭Bucket的访问日志功能。z,Start to delete bucket loggging, bucket: {0}rrrqr) r:r]rrAr rrrjr8rrur-r-r.delete_bucket_loggingrzBucket.delete_bucket_loggingcCs\|ttj|}td|jt||j d|t j did}td|j |j t|S)u~为Bucket设置防盗链。 :param input: :class:`BucketReferer ` 对象或其他 z6Start to put bucket referer, bucket: {0}, referer: {1}rrrz6Put bucket referer done, req_id: {0}, status_code: {1})rr BucketRefererrto_put_bucket_refererr:r]rrArr rREFERERrjr8rrr-r-r.put_bucket_referers zBucket.put_bucket_referercCr)u获取Bucket的防盗链配置。 :return: :class:`GetBucketRefererResult ` z(Start to get bucket referer, bucket: {0}rdrrqz6Get bucket referer done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rOrparse_get_bucket_refererGetBucketRefererResultrur-r-r.get_bucket_refererrzBucket.get_bucket_referercCr)u查看Bucket的状态，目前包括bucket大小，bucket的object数量，bucket正在上传的Multipart Upload事件个数等。 :return: :class:`GetBucketStatResult ` z%Start to get bucket stat, bucket: {0}rdrrqz3Get bucket stat done, req_id: {0}, status_code: {1}) r:r]rrAr rSTATrjr8rOrparse_get_bucket_statGetBucketStatResultrur-r-r.get_bucket_statrzBucket.get_bucket_statcCr)u获取bucket相关信息，如创建时间，访问Endpoint，Owner与ACL等。 :return: :class:`GetBucketInfoResult ` z%Start to get bucket info, bucket: {0}rdrrqz3Get bucket info done, req_id: {0}, status_code: {1}) r:r]rrAr r BUCKET_INFOrjr8rOrparse_get_bucket_infoGetBucketInfoResultrur-r-r.get_bucket_inforzBucket.get_bucket_infocCst|ttj|}t}t||d<t d |j t ||j d|tjdi|d}t d |j|jt|S)u}为Bucket配置静态网站托管功能。 :param input: :class:`BucketWebsite ` r~z6Start to put bucket website, bucket: {0}, website: {1}rrrz6Put bucket website done, req_id: {0}, status_code: {1})rr BucketWebsiterto_put_bucket_websiterrhrrr:r]rrArr rWEBSITErjr8r)r*rur}r=rEr-r-r.put_bucket_websiteszBucket.put_bucket_websitecCr)u 获取Bucket的静态网站托管配置。 :return: :class:`GetBucketWebsiteResult ` :raises: 如果没有设置静态网站托管，那么就抛出 :class:`NoSuchWebsite ` z(Start to get bucket website, bucket: {0}rdrrqz6Get bucket website done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rOrparse_get_bucket_websiteGetBucketWebsiteResultrur-r-r.get_bucket_website szBucket.get_bucket_websitecCr)u*关闭Bucket的静态网站托管功能。z+Start to delete bucket website, bucket: {0}rrrqz9Delete bucket website done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rrur-r-r.delete_bucket_websiterzBucket.delete_bucket_websitecCsl|ttj|}td|jt|t||j d||t j did}td|j |j ||tjtS)u创建推流直播频道 :param str channel_name: 要创建的live channel的名称 :param input: LiveChannelInfo类型，包含了live channel中的描述信息 :return: :class:`CreateLiveChannelResult ` zGStart to create live-channel, bucket: {0}, channel_name: {1}, info: {2}rrrz7Create live-channel done, req_id: {0}, status_code: {1})rrLiveChannelInforto_create_live_channelr:r]rrArrrLIVErjr8rOparse_create_live_channelCreateLiveChannelResult)r*rrur}rEr-r-r.create_live_channelszBucket.create_live_channelcCsLtd|jt||jd|tjdid}td|j|j t |S)ue删除推流直播频道 :param str channel_name: 要删除的live channel的名称 z` z>Start to get live-channel info: bucket: {0}, live_channel: {1}rdrrqz4Get live-channel done, req_id: {0}, status_code: {1})r:r]rrArrrrrjr8rOrparse_get_live_channelGetLiveChannelResultrr-r-r.get_live_channel9s  zBucket.get_live_channelc Csjtd|jt|t|||jdtjdd|d|dt|id}td|j |j | |t j tS) uN列举出Bucket下所有符合条件的live channel param: str prefix: list时channel_id的公共前缀 param: str marker: list时指定的起始标记 param: int max_keys: 本次list返回live channel的最大个数 return: :class:`ListLiveChannelResult ` zQStart to list live-channels, bucket: {0}, prefix: {1}, marker: {2}, max_keys: {3}rdrrarbrcrqz5List live-channel done, req_id: {0}, status_code: {1})r:r]rrArr rrrgrjr8rOrparse_list_live_channelListLiveChannelResult)r*rarbrmrEr-r-r.list_live_channelFs  zBucket.list_live_channelcCZtd|jt||jd|tjdtjdid}td|j |j | |t j tS)u获取live channel当前推流的状态 param str channel_name: 要获取推流状态的live channel的名称 return: :class:`GetLiveChannelStatResult ` z>Start to get live-channel stat, bucket: {0}, channel_name: {1}rdrrrqz9Get live-channel stat done, req_id: {0}, status_code: {1})r:r]rrArrrrCOMPrjr8rOrparse_live_channel_statGetLiveChannelStatResultrr-r-r.get_live_channel_statXs  zBucket.get_live_channel_statcCsTtd|jt|||jd|tjdtj|id}td|j |j t |S)u更改live channel的status，仅能在“enabled”和“disabled”两种状态中更改 param str channel_name: 要更改status的live channel的名称 param str status: live channel的目标status zMStart to put live-channel status, bucket: {0}, channel_name: {1}, status: {2}rrrqz;Put live-channel status done, req_id: {0}, status_code: {1}) r:r]rrArrrrSTATUSrjr8r)r*rr8rEr-r-r.put_live_channel_statusfs  zBucket.put_live_channel_statuscCr)u0获取live channel中最近的最多十次的推流记录，记录中包含推流的起止时间和远端的地址 param str channel_name: 要获取最近推流记录的live channel的名称 return: :class:`GetLiveChannelHistoryResult ` zAStart to get live-channel history, bucket: {0}, channel_name: {1}rdrhistoryrqz` 对象 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :param dict params: HTTP请求参数 :return: :class:`RequestResult ` z@Start to put object tagging, bucket: {0}, key: {1}, tagging: {2}Nrrr)r:r]rrArrrhr\rTAGGINGrrTaggingrto_put_taggingrr)r*rBrr=rfr}rEr-r-r.put_object_taggings   zBucket.put_object_taggingcCsbtd|jt|t|t|}|durt}d|t j <|j d|||d}| |t jtS)u# :param str key: 要获取tagging的对象名称 :param dict params: 请求参数 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`GetTaggingResult ` z>Start to get object tagging, bucket: {0}, key: {1} params: {2}Nrrdre)r:r]rrArrgrrhr\rr rrOrparse_get_taggingGetTaggingResultr_r-r-r.get_object_taggings   zBucket.get_object_taggingcCsjtd|jt|t|}|durt}d|tj <|j d|||d}td|j |j t |S)u :param str key: 要删除tagging的对象名称 :param dict params: 请求参数 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`RequestResult ` z5Start to delete object tagging, bucket: {0}, key: {1}Nrrrez9Delete object tagging done, req_id: {0}, status_code: {1})r:r]rrArrrhr\rr rrjr8rr_r-r-r.delete_object_taggings   zBucket.delete_object_taggingcCr)u设置bucket加密配置。 :param rule: :class:` ServerSideEncryptionRule` 对象 z6Start to put bucket encryption, bucket: {0}, rule: {1}rrrz9Put bucket encryption done, req_id: {0}, status_code: {1})rrServerSideEncryptionRulerto_put_bucket_encryptionr:r]rrAr r ENCRYPTIONrjr8r)r*ruler}rEr-r-r.put_bucket_encryption s zBucket.put_bucket_encryptioncCr)u$获取bucket加密配置。 :return: :class:`GetServerSideEncryptionResult ` :raises: 如果没有设置Bucket encryption，则抛出 :class:`NoSuchServerSideEncryptionRule ` z+Start to get bucket encryption, bucket: {0}rdrrqz9Get bucket encryption done, req_id: {0}, status_code: {1}) r:r]rrAr rr*rjr8rOrparse_get_bucket_encryptionGetServerSideEncryptionResultrur-r-r.get_bucket_encryption rzBucket.get_bucket_encryptioncCr)uN删除Bucket加密配置。如果Bucket加密没有设置，也返回成功。z.Start to delete bucket encryption, bucket: {0}rrrqz` 对象 :return: :class:`RequestResult ` z5Start to put object tagging, bucket: {0} tagging: {1}rrrz6Put bucket tagging done, req_id: {0}, status_code: {1})r:r]rrArrhrrr!rr"r rr rjr8r)r*rr=r}rEr-r-r.put_bucket_tagging# s  zBucket.put_bucket_taggingcCr)u :param str key: 要获取tagging的对象名称 :param dict params: 请求参数 :return: :class:`GetTaggingResult` z(Start to get bucket tagging, bucket: {0}rdrrqz6Get bucket tagging done, req_id: {0}, status_code: {1}) r:r]rrAr rr rjr8rOrr$r%rur-r-r.get_bucket_tagging8 s zBucket.get_bucket_taggingcCs`td|j|durt}tj|vrd|tj<|jd|d}td|j|j t |S)zN :return: :class:`RequestResult ` z+Start to delete bucket tagging, bucket: {0}Nrrrqz9Delete bucket tagging done, req_id: {0}, status_code: {1}) r:r]rrAr\rr r rjr8r)r*rfrEr-r-r.delete_bucket_taggingG s  zBucket.delete_bucket_taggingcCstdd|jt||t|t||t|}|jdd|d|d|d|dt|d d t j d i|d }td |j |j | |tjtS)u根据前缀罗列Bucket里的文件的版本。 :param str prefix: 只罗列文件名为该前缀的文件 :param str delimiter: 分隔符。可以用来模拟目录 :param str key_marker: 分页标志。首次调用传空串，后续使用返回值的next_marker :param int max_keys: 最多返回文件的个数，文件和目录的和不能超过该值 :param str versionid_marker: 设定结果从key-marker对象的 versionid-marker之后按新旧版本排序开始返回，该版本不会在返回的结果当中。 :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict :return: :class:`ListObjectVersionsResult ` zHStart to List object versions, bucket: {0}, prefix: {1}, delimiter: {2},z5key_marker: {3}, versionid_marker: {4}, max-keys: {5}rdrarrzversion-id-markerrcrrrrez8List object versions done, req_id: {0}, status_code: {1})r:r]rrArrrhr rgrVERSIONSrjr8rOrparse_list_object_versionsListObjectVersionsResult)r*rarrrmversionid_markerr=rEr-r-r.list_object_versions[ s0  zBucket.list_object_versionscCsptd|j|ttj|}t |}t ||d<|j d|t jdi|d}td|j|jt|S)u :param str operation: 设置bucket是否开启多版本特性，可取值为:[Enabled,Suspend] :return: :class:`RequestResult ` z+Start to put object versioning, bucket: {0}r~rrrz7Put bucket versiong done, req_id: {0}, status_code: {1})r:r]rrArrBucketVersioningConfigrto_put_bucket_versioningrrhrrr r VERSIONINGrjr8r)r*configr=r}rEr-r-r.put_bucket_versioning s zBucket.put_bucket_versioningcCr)ze :return: :class:`GetBucketVersioningResult` z+Start to get bucket versioning, bucket: {0}rdrrqz7Get bucket versiong done, req_id: {0}, status_code: {1}) r:r]rrAr rr;rjr8rOrparse_get_bucket_versioningGetBucketVersioningResultrur-r-r.get_bucket_versioning szBucket.get_bucket_versioningcCsTtd|j||jd|tjdidt|id}td|j |j t |S)uy设置bucket授权策略, 具体policy书写规则请参考官方文档 :param str policy: 授权策略 z4Start to put bucket policy, bucket: {0}, policy: {1}rrr~rz5Put bucket policy done, req_id: {0}, status_code: {1}) r:r]rrAr rPOLICYrrrjr8r)r*rrEr-r-r.put_bucket_policy s"zBucket.put_bucket_policycCr)uv获取bucket授权策略 :return: :class:`GetBucketPolicyResult ` z'Start to get bucket policy, bucket: {0}rdrrqz5Get bucket policy done, req_id: {0}, status_code: {1}) r:r]rrAr rrArjr8GetBucketPolicyResultrur-r-r.get_bucket_policy szBucket.get_bucket_policycCr)ue删除bucket授权策略 :return: :class:`RequestResult ` z*Start to delete bucket policy, bucket: {0}rrrqz8Delete bucket policy done, req_id: {0}, status_code: {1}) r:r]rrAr rrArjr8rrur-r-r.delete_bucket_policy zBucket.delete_bucket_policycCs^t|}td|j||jd|tjdidt |id}td|j |j t |S)u?设置付费者。 :param input: :class: str zPut bucket request payment done, req_id: {0}, status_code: {1})rto_put_bucket_request_paymentr:r]rrAr rREQUESTPAYMENTrrrjr8r)r*payerr}rEr-r-r.put_bucket_request_payment s "z!Bucket.put_bucket_request_paymentcCr)u获取付费者设置。 :return: :class:`GetBucketRequestPaymentResult ` z1Start to get bucket request payment, bucket: {0}.rdrrqz>Get bucket request payment done, req_id: {0}, status_code: {1}) r:r]rrAr rrHrjr8rOr parse_get_bucket_request_paymentGetBucketRequestPaymentResultrur-r-r.get_bucket_request_payment z!Bucket.get_bucket_request_paymentcCsntd|j|ttj|}t }t ||d<|j d|t jdi|d}td|j|jt|S)u配置bucket的QoSInfo :param bucket_qos_info :class:`BucketQosInfo ` :return: :class:`RequestResult ` z)Start to put bucket qos info, bucket: {0}r~rrrz7Get bucket qos info done, req_id: {0}, status_code: {1})r:r]rrArr BucketQosInforrrrhrrr rrrrjr8r)r*bucket_qos_infor}r=rEr-r-r.put_bucket_qos_info szBucket.put_bucket_qos_infocCr)uv获取bucket的QoSInfo :return: :class:`GetBucketQosInfoResult ` z)Start to get bucket qos info, bucket: {0}rdrrqz2Get bucket qos info, req_id: {0}, status_code: {1}) r:r]rrAr rrrrjr8rOrrsGetBucketQosInfoResultrur-r-r.get_bucket_qos_info rNzBucket.get_bucket_qos_infocCr)ud删除bucket的QoSInfo :return: :class:`RequestResult ` z,Start to delete bucket qos info, bucket: {0}rrrqz:Delete bucket qos info done, req_id: {0}, status_code: {1}) r:r]rrAr rrrrjr8rrur-r-r.delete_bucket_qos_info szBucket.delete_bucket_qos_infocCPtd|jt|}|jd|tjdid}td|j |j t |S)uu设置Bucket的容量，单位GB :param user_qos :class:`BucketUserQos ` z)Start to set bucket storage capacity: {0}rrrz?Set bucket storage capacity done, req_id: {0}, status_code: {1}) r:r]rrArto_put_bucket_user_qosr rUSER_QOSrjr8r)r*user_qosr}rEr-r-r.set_bucket_storage_capacity s  z"Bucket.set_bucket_storage_capacitycCr)u~获取bucket的容量信息。 :return: :class:`GetBucketUserQosResult ` z0Start to get bucket storage capacity, bucket:{0}rdrrqz?Get bucket storage capacity done, req_id: {0}, status_code: {1}) r:r]rrAr rrWrjr8rOrparse_get_bucket_user_qosGetBucketUserQosResultrur-r-r.get_bucket_storage_capacity rNz"Bucket.get_bucket_storage_capacitycCsptd|jt|}t}t ||d<|j d|t j di|d}td|j |j||tjtS)u)创建一个异步获取文件到bucket的任务。 :param task_config: 任务配置 :type task_config: class:`AsyncFetchTaskConfiguration ` :return: :class:`PutAsyncFetchTaskResult ` z)Start to put async fetch task, bucket:{0}r~r{rr8Put async fetch task done, req_id: {0}, status_code: {1})r:r]rrArto_put_async_fetch_taskrrhrrr r ASYNC_FETCHrjr8rO!parse_put_async_fetch_task_resultPutAsyncFetchTaskResult)r* task_configr}r=rEr-r-r.put_async_fetch_task s zBucket.put_async_fetch_taskcCsTtd|j||jdt|itjdid}td|j|j | |t j t S)u获取一个异步获取文件到bucket的任务信息。 :param str task_id: 任务id :return: :class:`GetAsyncFetchTaskResult ` z6Start to get async fetch task, bucket:{0}, task_id:{1}rdrr/r])r:r]rrAr  OSS_TASK_IDrr_rjr8rOr!parse_get_async_fetch_task_resultGetAsyncFetchTaskResult)r*task_idrEr-r-r.get_async_fetch_task! szBucket.get_async_fetch_taskcCsvtd|j|ttj|}t }t ||d<|j d|t jdt j|ji|d}td|j|jt|S)u设置bucket清单配置 :param inventory_configuration :class:`InventoryConfiguration ` :return: :class:`RequestResult ` z8Start to put bucket inventory configuration, bucket: {0}r~rrrzFPut bucket inventory configuration done, req_id: {0}, status_code: {1})r:r]rrArrInventoryConfigurationrto_put_inventory_configurationrrhrrr r INVENTORYINVENTORY_CONFIG_ID inventory_idrjr8r)r*inventory_configurationr}r=rEr-r-r."put_bucket_inventory_configuration- s z)Bucket.put_bucket_inventory_configurationcCRtd|j|jdtjdtj|id}td|j|j | |t j t S)u获取指定的清单配置。 :param str inventory_id : 清单配置id :return: :class:`GetInventoryConfigurationResult ` z8Start to get bucket inventory configuration, bucket: {0}rdrrqzEGet bucket inventory cinfguration done, req_id: {0}, status_code: {1})r:r]rrAr rrkrlrjr8rOr(parse_get_bucket_inventory_configurationGetInventoryConfigurationResultr*rmrEr-r-r."get_bucket_inventory_configuration= sz)Bucket.get_bucket_inventory_configurationcCsbtd|jtjdi}|dur||tj<|jd|d}td|j|j | |t j t S)u罗列清单配置，默认单次最大返回100条配置，如果存在超过100条配置，罗列结果将会分页， 分页信息保存在 class:`ListInventoryConfigurationResult `中。 :param str continuation_token: 分页标识, 默认值为None, 如果上次罗列不完整，这里设置为上次罗列结果中的next_continuation_token值。 :return: :class:`ListInventoryConfigurationResult ` z9Start to list bucket inventory configuration, bucket: {0}rNrdrqzGList bucket inventory configuration done, req_id: {0}, status_code: {1})r:r]rrArrkCONTINUATION_TOKENr rjr8rOr*parse_list_bucket_inventory_configurations!ListInventoryConfigurationsResult)r*rrfrEr-r-r.$list_bucket_inventory_configurationsI s  z+Bucket.list_bucket_inventory_configurationscCLtd|j||jdtjdtj|id}td|j|j t |S)u删除指定的清单配置 :param str inventory_id : 清单配置id :return: :class:`RequestResult ` zSStart to delete bucket inventory configuration, bucket: {0}, configuration id: {1}.rrrqzDDelete bucket inventory configuration, req_id: {0}, status_code: {1}) r:r]rrAr rrkrlrjr8rrsr-r-r.%delete_bucket_inventory_configurationY sz,Bucket.delete_bucket_inventory_configurationcCs|td|j|t|}t}t ||d<|j d|t j di|d}td|j |jt|}|jd|_|S)u创建一条合规保留策略 :param int retention_period_days : 指定object的保留天数 :return: :class:`InitBucketWormResult ` zCStart to init bucket worm, bucket: {0}, retention_period_days: {1}.r~r{rrz4init bucket worm done, req_id: {0}, status_code: {1}z x-oss-worm-id)r:r]rrArto_put_init_bucket_wormrrhrrr rWORMrjr8InitBucketWormResultr=rworm_id)r*retention_period_daysr}r=rErNr-r-r.init_bucket_wormf s  zBucket.init_bucket_wormcCr)u删除一条合规保留策略 只有未锁定保留策略的状态下才能删除，一旦锁定bucket数据将处于保护状态。 :return: :class:`RequestResult ` z(Start to abort bucket worm, bucket: {0}.rrrqz5abort bucket worm done, req_id: {0}, status_code: {1}) r:r]rrAr rr|rjr8rrur-r-r.abort_bucket_wormx szBucket.abort_bucket_wormcCsFtd|j||jdtj|id}td|j|jt |S)u锁定一条合规保留策略 :param str worm_id : 合规保留策略的id。 :return: :class:`RequestResult ` z9Start to complete bucket worm, bucket: {0}, worm_id: {1}.r{rqz8complete bucket worm done, req_id: {0}, status_code: {1}) r:r]rrAr rWORM_IDrjr8r)r*r~rEr-r-r.complete_bucket_worm szBucket.complete_bucket_wormcCsrt|}t}t||d<td|j |||j d|t j |t j di|d}td|j|jt|S)u 延长已经锁定的合规保留策略的object保护天数。 :param str worm_id : 合规保留策略的id。 :param int retention_period_days : 指定object的保留天数 :return: :class:`RequestResult ` r~zNStart to extend bucket worm, bucket: {0}, worm_id: {1}, retention_period_days.r{rrz6extend bucket worm done, req_id: {0}, status_code: {1})rto_put_extend_bucket_wormrrhrrr:r]rrAr rr WORM_EXTENDrjr8r)r*r~rr}r=rEr-r-r.extend_bucket_worm s  zBucket.extend_bucket_wormcCr)ur获取合规保留策略 :return: :class:`GetBucketWormResult ` z&Start to get bucket worm, bucket: {0}.rdrrqz3get bucket worm done, req_id: {0}, status_code: {1}) r:r]rrAr rr|rjr8rOrparse_get_bucket_worm_resultGetBucketWormResultrur-r-r.get_bucket_worm rNzBucket.get_bucket_wormcCltd|jt|}t}t ||d<|j d|t j dddi|d}td|j |jt|S) u设置bucket跨区域复制规则 :param rule :class:`ReplicationRule ` :return: :class:`RequestResult ` z$Start to put bucket replication: {0}r~r{rraddrz:Put bucket replication done, req_id: {0}, status_code: {1})r:r]rrArto_put_bucket_replicationrrhrrr r REPLICATIONrjr8r)r*r+r}r=rEr-r-r.put_bucket_replication  zBucket.put_bucket_replicationcCr)u获取bucket跨区域复制规则 :return: :class:`GetBucketReplicationResult ` z$Start to get bucket replication: {0}rdrrqz:Get bucket replication done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rOr#parse_get_bucket_replication_resultGetBucketReplicationResultrur-r-r.get_bucket_replication rNzBucket.get_bucket_replicationcCr) u停止Bucket的跨区域复制并删除Bucket的复制配置 :param str rule_id: Bucket跨区域复制规则的id。 :return: :class:`RequestResult ` z'Start to delete bucket replication: {0}r~r{rrrrz=Delete bucket replication done, req_id: {0}, status_code: {1})r:r]rrArto_delete_bucket_replicationrrhrrr rrrjr8r)r*rule_idr}r=rEr-r-r.delete_bucket_replication rz Bucket.delete_bucket_replicationcCr)u获取可复制到的Bucket所在的地域 :return: :class:`ReplicationLocation ` z-Start to get bucket replication location: {0}rdrrqzCGet bucket replication location done, req_id: {0}, status_code: {1}) r:r]rrAr rREPLICATION_LOCATIONrjr8rOr,parse_get_bucket_replication_location_result"GetBucketReplicationLocationResultrur-r-r.get_bucket_replication_location rNz&Bucket.get_bucket_replication_locationcCsPtd|j|jdtjdd|id}td|j|j| |t j t S)u获取获取某个Bucket的跨区域复制进度 :param str rule_id: Bucket跨区域复制规则的id。 :return: :class:`GetBucketReplicationProgressResult ` z-Start to get bucket replication progress: {0}rdrzrule-idrqzCGet bucket replication progress done, req_id: {0}, status_code: {1}) r:r]rrAr rREPLICATION_PROGRESSrjr8rOr,parse_get_bucket_replication_progress_result"GetBucketReplicationProgressResult)r*rrEr-r-r.get_bucket_replication_progress sz&Bucket.get_bucket_replication_progresscCs>td|j|jd|did}td|j|j|S)uW获得Bucket某项配置，具体哪种配置由 `config` 指定。该接口直接返回 `RequestResult` 对象。 通过read()接口可以获得XML字符串。不建议使用。 :param str config: 可以是 `Bucket.ACL` 、 `Bucket.LOGGING` 等。 :return: :class:`RequestResult ` z'Start to get bucket config, bucket: {0}rdrrqz5Get bucket config done, req_id: {0}, status_code: {1})r:r]rrAr rjr8)r*r<rEr-r-r._get_bucket_config szBucket._get_bucket_configcCsjtd|j|t|}t}t ||d<|j d|t j di|d}td|j |jt|S)u为存储空间（Bucket）配置传输加速 :param str enabled : 是否开启传输加速。true：开启传输加速; false：关闭传输加速. :return: :class:`RequestResult ` zAStart to bucket transfer acceleration, bucket: {0}, enabled: {1}.r~rrrz@bucket transfer acceleration done, req_id: {0}, status_code: {1})r:r]rrAr#to_put_bucket_transfer_accelerationrrhrrr rTRANSFER_ACCELERATIONrjr8r)r*enabledr}r=rEr-r-r. put_bucket_transfer_acceleration s  z'Bucket.put_bucket_transfer_accelerationcCr)u获取目标存储空间（Bucket）的传输加速配置 :return: :class:`GetBucketTransferAccelerationResult ` z.Start to get bucket transfer acceleration: {0}rdrrqzDGet bucket transfer acceleration done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rOr-parse_get_bucket_transfer_acceleration_result#GetBucketTransferAccelerationResultrur-r-r. get_bucket_transfer_acceleration rNz'Bucket.get_bucket_transfer_accelerationcCs^td|jt|}|jd|tjdtj did}td|j |j | |tj tS)u创建域名所有权验证所需的CnameToken。 :param str domain : 绑定的Cname名称。 :return: :class:`CreateBucketCnameTokenResult ` z0Start to create bucket cname token, bucket: {0}.r{rrrz6bucket cname token done, req_id: {0}, status_code: {1})r:r]rrArto_bucket_cname_configurationr rCNAMEr rjr8rOparse_create_bucket_cname_tokenCreateBucketCnameTokenResultr*domainr}rEr-r-r.create_bucket_cname_token s  z Bucket.create_bucket_cname_tokencCsRtd|j|jdtj|tjdid}td|j|j | |t j t S)u获取已创建的CnameToken。 :param str domain : 绑定的Cname名称。 :return: :class:`GetBucketCnameTokenResult ` zStart to get bucket cname: {0}rdrrqz4Get bucket cname done, req_id: {0}, status_code: {1})r:r]rrAr rrr rjr8rOrparse_get_bucket_cname_tokenGetBucketCnameTokenResult)r*rrEr-r-r.get_bucket_cname_token szBucket.get_bucket_cname_tokencCs\td|jt|j|j}|jd|t j dt j did}td|j |j t|S)u为某个存储空间（Bucket）绑定自定义域名。 :param input: PutBucketCnameRequest类型，包含了证书和自定义域名信息 :return: :class:`RequestResult ` z'Start to add bucket cname, bucket: {0}.r{rrrz0bucket cname done, req_id: {0}, status_code: {1})r:r]rrArrrcertr rrr rjr8rrr-r-r.put_bucket_cname+ s zBucket.put_bucket_cnamecCr)u查询某个存储空间（Bucket）下绑定的所有Cname列表。 :return: :class:`ListBucketCnameResult ` z(Start to do query list bucket cname: {0}rdrrq;query list bucket cname done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rOrparse_list_bucket_cnameListBucketCnameResultrur-r-r.list_bucket_cname7 zBucket.list_bucket_cnamecCsVtd|jt|}|jd|tjdtj did}td|j |j t |S)u删除某个存储空间（Bucket）已绑定的Cname :param str domain : 绑定的Cname名称。 :return: :class:`RequestResult ` z!Start to delete bucket cname: {0}r{rrrz7delete bucket cname done, req_id: {0}, status_code: {1}) r:r]rrArrr rrr rjr8rrr-r-r.delete_bucket_cnameB s  zBucket.delete_bucket_cnamecCsHtd|j|jdtjdddid}td|j|jt |S)u为存储空间（Bucket）开启元数据管理功能 :return: :class:`RequestResult ` z(Start to bucket meta query, bucket: {0}.r{rrrrq5bucket meta query done, req_id: {0}, status_code: {1}) r:r]rrAr r META_QUERYrjr8rrur-r-r.open_bucket_meta_queryN szBucket.open_bucket_meta_querycCr)u获取指定存储空间（Bucket）的元数据索引库信息。 :return: :class:`GetBucketMetaQueryResult ` z#Start to get bucket meta query: {0}rdrrqz9Get bucket meta query done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rOr"parse_get_bucket_meta_query_resultGetBucketMetaQueryResultrur-r-r.get_bucket_meta_query_statusX rz#Bucket.get_bucket_meta_query_statuscCsdtd|j|ttj|}|jd|t j dt j did}td|j |j ||tjtS)u查询满足指定条件的文件（Object），并按照指定字段和排序方式列出文件信息。 :param do_meta_query_request :class:`MetaQuery ` :return: :class:`DoBucketMetaQueryResult ` z"Start to do bucket meta query: {0}r{rqueryrz8do bucket meta query done, req_id: {0}, status_code: {1})r:r]rrArr MetaQueryrto_do_bucket_meta_query_requestr rrr rjr8rO!parse_do_bucket_meta_query_resultDoBucketMetaQueryResult)r*do_meta_query_requestr}rEr-r-r.do_bucket_meta_queryb s zBucket.do_bucket_meta_querycCsJtd|j|jdtjdtjdid}td|j|j t |S)u关闭存储空间（Bucket）的元数据管理功能 :return: :class:`RequestResult ` z%Start to close bucket meta query: {0}r{rrrqr) r:r]rrAr rrr rjr8rrur-r-r.close_bucket_meta_queryo szBucket.close_bucket_meta_querycCrU)u更新 Bucket 访问跟踪状态。 :param str status : bucket访问跟踪的开启状态 :return: :class:`RequestResult ` z0Start to put bucket access monitor, bucket: {0}.rrrz9bucket access monitor done, req_id: {0}, status_code: {1}) r:r]rrArto_put_bucket_access_monitorr rACCESS_MONITORrjr8r)r*r8r}rEr-r-r.put_bucket_access_monitory  z Bucket.put_bucket_access_monitorcCr)u获取当前Bucket的访问跟踪的状态。 :return: :class:`GetBucketAccessMonitorResult ` z'Start to get bucket access monitor: {0}rdrrqr) r:r]rrAr rrrjr8rOr&parse_get_bucket_access_monitor_resultGetBucketAccessMonitorResultrur-r-r.get_bucket_access_monitor rz Bucket.get_bucket_access_monitorcCr)u查询存储空间（Bucket）的资源组ID。 :return: :class:`GetBucketResourceGroupResult ` z'Start to get bucket resource group: {0}rdrrqz=Get bucket resource group done, req_id: {0}, status_code: {1}) r:r]rrAr rRESOURCE_GROUPrjr8rOr&parse_get_bucket_resource_group_resultGetBucketResourceGroupResultrur-r-r.get_bucket_resource_group rNz Bucket.get_bucket_resource_groupcCrU)u为存储空间（Bucket）配置所属资源组。 :param str resourceGroupId : Bucket所属的资源组ID。 :return: :class:`RequestResult ` z0Start to put bucket resource group, bucket: {0}.rrrz9bucket resource group done, req_id: {0}, status_code: {1}) r:r]rrArto_put_bucket_resource_groupr rrrjr8r)r*resourceGroupIdr}rEr-r-r.put_bucket_resource_group rz Bucket.put_bucket_resource_groupcCsVtd|jt|}|jd|tjdtj |id}td|j |j t |S)u新增图片样式。 :param str styleName : 样式名称。 :param str content : 图片样式内容，图片样式可以包含一个或多个图片处理操作。 :return: :class:`RequestResult ` z'Start to put bucket style, bucket: {0}.rrrz0bucket style done, req_id: {0}, status_code: {1}) r:r]rrArto_put_bucket_styler rSTYLE STYLE_NAMErjr8r)r*rcontentr}rEr-r-r.put_bucket_style s  zBucket.put_bucket_stylecCrp)u查询某个Bucket下指定的图片样式信息。 :param str styleName : 样式名称。 :return: :class:`GetBucketStyleResult ` zStart to get bucket style: {0}rdrrqz4Get bucket style done, req_id: {0}, status_code: {1})r:r]rrAr rrrrjr8rOrparse_get_bucket_style_resultGetBucketStyleResultr*rrEr-r-r.get_bucket_style szBucket.get_bucket_stylecCr)u查询某个Bucket下已创建的所有图片样式。 :return: :class:`ListBucketStyleResult ` zStart to list bucket style: {0}rdrrqz;query list bucket style done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rOrparse_list_bucket_styleListBucketStyleResultrur-r-r.list_bucket_style rzBucket.list_bucket_stylecCJtd|j|jdtjdtj|id}td|j|j t |S)u删除某个Bucket下指定的图片样式。 :param str styleName : 样式名称。 :return: :class:`RequestResult ` z!Start to delete bucket style: {0}rrrqz7delete bucket style done, req_id: {0}, status_code: {1}) r:r]rrAr rrrrjr8rrr-r-r.delete_bucket_style szBucket.delete_bucket_stylecCsrt|}td|jt||dtj|f}|j d|tjdi||d}td|j |j | |t jtS)u异步处理多媒体接口。 :param str key: 处理的多媒体的对象名称 :param str process: 处理的字符串，例如"video/convert,f_mp4,vcodec_h265,s_1920x1080,vb_2000000,fps_30,acodec_aac,ab_100000,sn_1|sys/saveas,o_dGVzdC5qcGc,b_dGVzdA" :param headers: HTTP头部 :type headers: 可以是dict，建议是oss2.CaseInsensitiveDict zBStart to async process object, bucket: {0}, key: {1}, process: {2}rr{rr|z8Async process object done, req_id: {0}, status_code: {1})rrhr:r]rrArr ASYNC_PROCESSrrjr8rOrparse_async_process_objectAsyncProcessObjectrr-r-r.async_process_object s  zBucket.async_process_objectcCsZtd|j|t|}|jd|tjdtj tj id}td|j |j t |S)uR设置bucket回调策略 :param str callbackPolicy: 回调策略 zFStart to put bucket callback policy, bucket: {0}, callback policy: {1}rrrz>Put bucket callback policy done, req_id: {0}, status_code: {1})r:r]rrAr$to_do_bucket_callback_policy_requestr rrAr CALLBACKrjr8r)r*callbackPolicyr}rEr-r-r.put_bucket_callback_policy s  z!Bucket.put_bucket_callback_policycCsTtd|j|jdtjdtjtjid}td|j |j | |t j tS)ut获取bucket回调策略 :return: :class:`GetBucketPolicyResult ` z0Start to get bucket callback policy, bucket: {0}rdrrqz>Get bucket callback policy done, req_id: {0}, status_code: {1})r:r]rrAr rrAr rrjr8rOrparse_callback_policy_resultCallbackPolicyResultrur-r-r.get_bucket_callback_policy sz!Bucket.get_bucket_callback_policycCsLtd|j|jdtjdtjtjid}td|j |j t |S)ue删除bucket回调策略 :return: :class:`RequestResult ` z3Start to delete bucket callback policy, bucket: {0}rrrqzADelete bucket callback policy done, req_id: {0}, status_code: {1}) r:r]rrAr rrAr rrjr8rrur-r-r.delete_bucket_callback_policy sz$Bucket.delete_bucket_callback_policycCRtd|j|t|}|jd|tjdid}td|j |j t |S)u[设置归档直读 :param boolean enabled: Bucket是否开启归档直读 zBStart to put bucket archive direct read, bucket: {0}, enabled: {1}rrrz>bucket archive direct read done, req_id: {0}, status_code: {1}) r:r]rrAr!to_put_bucket_archive_direct_readr rARCHIVE_DIRECT_READrjr8r)r*rr}rEr-r-r.put_bucket_archive_direct_read s  z%Bucket.put_bucket_archive_direct_readcCr)u获取归档直读 :return: :class:`GetBucketArchiveDirectReadResult ` z4Start to get bucket archive direct read, bucket: {0}rdrrqzBGet bucket archive direct read done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rOr$parse_get_bucket_archive_direct_read GetBucketArchiveDirectReadResultrur-r-r.get_bucket_archive_direct_read rz%Bucket.get_bucket_archive_direct_readcCr)ubBucket开启或关闭TLS版本设置。 :param httpsConfig: TLS版本信息设置 z@Start to put bucket https config, bucket: {0}, https config: {1}rrrz;Put bucket https config done, req_id: {0}, status_code: {1}) r:r]rrAr!to_do_bucket_https_config_requestr r HTTPS_CONFIGrjr8r)r*rr}rEr-r-r.put_bucket_https_config s  zBucket.put_bucket_https_configcCTtd|j||jdtjdtj|id}td|j|j | |t j t S)ul为Bucket创建存储冗余转换任务。 :param str targetType: 目标存储冗余类型 zPStart to create bucket data redundancy transition, bucket: {0}, target type: {1}r{rrqzLCreate bucket data redundancy transition done, req_id: {0}, status_code: {1})r:r]rrAr rrTARGET_REDUNDANCY_TYPErjr8rOr.parse_create_data_redundancy_transition_result$CreateDataRedundancyTransitionResult)r* targetTyperEr-r-r.(create_bucket_data_redundancy_transition+ sz/Bucket.create_bucket_data_redundancy_transitioncCrp)u获取存储冗余转换任务。 :return: :class:`DataRedundancyTransitionInfoResult ` z;Start to get bucket data redundancy transition, bucket: {0}rdrrqzIGet bucket data redundancy transition done, req_id: {0}, status_code: {1})r:r]rrAr rrREDUNDANCY_TRANSITION_TASK_IDrjr8rOr+parse_get_bucket_data_redundancy_transition"DataRedundancyTransitionInfoResultr*taskIdrEr-r-r.%get_bucket_data_redundancy_transition7 sz,Bucket.get_bucket_data_redundancy_transitioncCr)un删除存储冗余转换任务。 :return: :class:`RequestResult ` z>Start to delete bucket data redundancy transition, bucket: {0}rrrqzLDelete bucket data redundancy transition done, req_id: {0}, status_code: {1}) r:r]rrAr rrrrjr8rrr-r-r.(delete_bucket_data_redundancy_transitionA sz/Bucket.delete_bucket_data_redundancy_transitioncCr)uv查看Bucket的TLS版本设置。 :return: :class:`HttpsConfigResult ` z-Start to get bucket https config, bucket: {0}rdrrqz;Get bucket https config done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rOrparse_get_bucket_https_configHttpsConfigResultrur-r-r.get_bucket_https_configJ szBucket.get_bucket_https_configcCr)u列举某个Bucket下所有的存储冗余转换任务。 :return: :class:`ListBucketDataRedundancyTransitionResult ` z=Start to do query list bucket data redundancy transition: {0}rdrrqzPquery list bucket data redundancy transition done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rOr,parse_list_bucket_data_redundancy_transition(ListBucketDataRedundancyTransitionResultrur-r-r.&list_bucket_data_redundancy_transitionT rz-Bucket.list_bucket_data_redundancy_transitioncCsXtd|jt|}|jd|tjdid}td|j |j | |tj t S)u创建接入点 :param accessPoint :class:`CreateAccessPointRequest ` :return: :class:`CreateAccessPointResult ` z)Start to create access point, bucket: {0}rrrz7Create access point done, req_id: {0}, status_code: {1})r:r]rrAr!to_do_create_access_point_requestr rrrjr8rO parse_create_access_point_resultCreateAccessPointResult)r*rr}rEr-r-r.create_access_point_ s  zBucket.create_access_pointcCs^td|jt}||d<|jdtjdi|d}td|j |j | |t j tS)u获取接入点信息 :param str accessPointName: 接入点名称 :return: :class:`GetAccessPointResult ` z&Start to get access point, bucket: {0}rrdrrez4Get access point done, req_id: {0}, status_code: {1})r:r]rrArrhr rrrjr8rOrparse_get_access_point_resultGetAccessPointResultr*accessPointNamer=rEr-r-r.get_access_pointj s zBucket.get_access_pointcCVtd|jt}||d<|jdtjdi|d}td|j |j t |S)u删除接入点 :param str accessPointName: 接入点名称 :return: :class:`RequestResult ` z)Start to delete access point, bucket: {0}rrrrez7Delete access point done, req_id: {0}, status_code: {1}) r:r]rrArrhr rrrjr8rrr-r-r.delete_access_pointw zBucket.delete_access_pointcCsXtd|j|jdtjddt|d|id}td|j|j | |t j t S)u查询某个Bucket下所有接入点。 param: int max_keys: 本次list返回access point的最大个数 param: str continuation_token: list时指定的起始标记 :return: :class:`ListAccessPointResult ` z&Start to list bucket access point: {0}rdrrcrrqzBquery list bucket access point done, req_id: {0}, status_code: {1})r:r]rrAr rrrgrjr8rOrrrrr-r-r.list_bucket_access_points s z Bucket.list_bucket_access_pointscCsZtd|j|t}||d<|jd|tjdi|d}td|j |j t |S)u设置接入点策略 :param str accessPointName: 接入点名称 :param str accessPointPolicy : 接入点策略 :return: :class:`RequestResult ` zEStart to put access point policy, bucket: {0}, accessPointPolicy: {1}rrrrz>Create access point policy done, req_id: {0}, status_code: {1} r:r]rrArrhr rACCESS_POINT_POLICYrjr8r)r*rrr=rEr-r-r.put_access_point_policy s zBucket.put_access_point_policycCr)u获取接入点策略 :param str accessPointName: 接入点名称 :return: :class:`GetAccessPointPolicyResult ` z-Start to get access point policy, bucket: {0}rrdrrez;Get access point policy done, req_id: {0}, status_code: {1}) r:r]rrArrhr rrrjr8GetAccessPointPolicyResultrr-r-r.get_access_point_policy s zBucket.get_access_point_policycCr)u删除接入点策略 :param str accessPointName: 接入点名称 :return: :class:`RequestResult ` z0Start to delete access point policy, bucket: {0}rrrrez>Delete access point policy done, req_id: {0}, status_code: {1}rrr-r-r.delete_access_point_policy rz!Bucket.delete_access_point_policycCr)u为Bucket开启阻止公共访问。 :param bool block_public_access : 是否开启阻止公共访问。 :return: :class:`RequestResult ` zCStart to bucket put public access block, bucket: {0}, enabled: {1}.rrrz>bucket public access block done, req_id: {0}, status_code: {1}) r:r]rrArrr rrrjr8rrr-r-r.put_bucket_public_access_block s  z%Bucket.put_bucket_public_access_blockcCr)u获取指定Bucket的阻止公共访问配置信息。 :return: :class:`GetBucketPublicAccessBlockResult ` z,Start to get bucket public access block: {0}rdrrqzBGet bucket public access block done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rOrr GetBucketPublicAccessBlockResultrur-r-r.get_bucket_public_access_block rNz%Bucket.get_bucket_public_access_blockcCr)u删除指定Bucket的阻止公共访问配置信息。 :return: :class:`RequestResult ` z7Start to delete bucket public access block, bucket: {0}rrrqzEDelete bucket public access block done, req_id: {0}, status_code: {1}) r:r]rrAr rrrjr8rrur-r-r.!delete_bucket_public_access_block rFz(Bucket.delete_bucket_public_access_blockcCsZtd|j||t|}|jd|tjdtj |id}td|j |j t |S)u为接入点开启阻止公共访问。 :param bool block_public_access : 是否开启阻止公共访问。 :return: :class:`RequestResult ` zmStart to put access point public access block, bucket: {0}, access point name: {1}, block public access: {2}.rrrzDaccess point public access block done, req_id: {0}, status_code: {1}) r:r]rrArrr rrOSS_ACCESS_POINT_NAMErjr8r)r*access_point_namerr}rEr-r-r.$put_access_point_public_access_block s  z+Bucket.put_access_point_public_access_blockcCr)u获取指定接入点的阻止公共访问配置信息。 :return: :class:`GetBucketPublicAccessBlockResult ` zKStart to get access point public access block: {0}, access point name: {1}.rdrrqzHGet access point public access block done, req_id: {0}, status_code: {1})r:r]rrAr rrr"rjr8rOrrrr*r#rEr-r-r.$get_access_point_public_access_block sz+Bucket.get_access_point_public_access_blockcCry)u删除指定接入点的阻止公共访问配置信息。 :return: :class:`RequestResult ` zVStart to delete access point public access block, bucket: {0}, access point name: {1}.rrrqzKDelete access point public access block done, req_id: {0}, status_code: {1}) r:r]rrAr rrr"rjr8rr%r-r-r.'delete_access_point_public_access_block sz.Bucket.delete_access_point_public_access_blockcCsftd|j|||stdt|}|jd|tj dtj |id}td|j |j t |S)u修改请求者在Bucket上的流控配置。 :param str uid: 请求者UID :param qos_configuration :class:`QoSConfiguration ` :return: :class:`RequestResult ` zVStart to put bucket requester qos info, bucket: {0}, uid: {1}, qos_configuration: {2}.rrrrzAput bucket requester qos info done, req_id: {0}, status_code: {1})r:r]rrArrrr rrrrjr8r)r*rrr}rEr-r-r.put_bucket_requester_qos_info s  z$Bucket.put_bucket_requester_qos_infocCs`td|j||std|jdtjdtj|id}td|j |j | |t j tS)u获取请求者在Bucket上的流控配置。 :return: :class:`RequesterQoSInfoResult ` z6Start to get bucket requester qos info: {0}, uid: {1}.rrdrrqz` z6Start to do query list bucket requester qos infos: {0}rdrrrcrqzIquery list bucket requester qos infos done, req_id: {0}, status_code: {1})r:r]rrAr rrrgrjr8rOr%parse_list_bucket_requester_qos_infos!ListBucketRequesterQoSInfosResultrr-r-r.list_bucket_requester_qos_infos s z&Bucket.list_bucket_requester_qos_infoscCsXtd|j||std|jdtjdtj|id}td|j |j t |S)uz删除在Bucket上的请求者流控配置。 :return: :class:`RequestResult ` zAStart to delete bucket requester qos info, bucket: {0}, uid: {1}.rrrrqzDDelete bucket requester qos info done, req_id: {0}, status_code: {1}) r:r]rrArr rrrrjr8rr)r-r-r. delete_bucket_requester_qos_info. s z'Bucket.delete_bucket_requester_qos_infocKs2|jstd|s td|j||j|fi|S)Nz(Bucket name should not be null or empty.z key should not be null or empty.)rArrH)r*r@rBrCr-r-r. __do_object; s zBucket.__do_objectcKs|j||jdfi|SNr)rHrA)r*r@rCr-r-r. __do_bucketB szBucket.__do_bucketcCst||r ||S|SrK) isinstance)r*rM converterr}r-r-r.__convert_dataE s zBucket.__convert_data) FNNrTNNNFT)NNFN)rrrr1N)rrrrFrr1N)NN)NNN)NNNNN)NNNNrK)rrrrrN)rrN)rrr1)rr)rrrr1rNrrr)rPrQrRrrxrrrrrrrr r rrrrr1r r*r4r;rgrqr]rArHrrrWr_ SEQUENTIALrkrlrur|rrrrrrrrrrrrrrrrrrrrrr"rrrrrr/rIrr rrr%r&r'r-r6rDrMrOrPrSrWr[r`rerlrorprvrzr}rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr rrrrrr#r&r'r,r/r0r1r2r3r8r=r@rBrDrErJrMrQrSrTrYr\rcrhrortrxrzrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr rrrrrrrrr r!r$r&r'r(r*r-r.rr rrrr-r-r_r.rIs  1  " *   / 1 ; *  #   (     -      % ' ) 0                           &                              rcCs`|}|ds|dsd|}t|}|jdur(|jd|jdt|jS|jd|jS)Nrrz://:)rr portschemehostnamerg)rrrr-r-r.rL s rr2cCs>|durdS|d}|d}|dur|durdSdt||S)Nrrrzbytes=)_range)r.startlastr-r-r.r0_ sr0cCsdd}||d||S)NcSs|durdSt|Sr0)rg)posr-r-r.to_strm sz_range..to_str-r-)r<r=r?r-r-r.r;l sr;cCs0t|rtS|r tS|rtSt|rtStSrK)ris_ip_or_localhost_ENDPOINT_TYPE_IP_ENDPOINT_TYPE_CNAME_ENDPOINT_TYPE_PATH_STYLEr_ENDPOINT_TYPE_ALIYUN)netlocr+rAr,r-r-r._determine_endpoint_typev s  rGc@seZdZddZdddZdS)r&cCs(t|}|j|_|j|_||_||_dSrK)r r8rFr+r,)r*rr+r,rr-r-r.r/ s  z_UrlMaker.__init__FcCst|j|j||j|_|durdnd}t||d}|jtkr'd|j|j|S|jt ks1|jt krF|r=d|j|j||Sd|j|j|S|sT|rLJd|j|jSd|j||j|S) NTrr)safez {0}://{1}/{2}z{0}://{1}/{2}/{3}z {0}://{1}z{0}://{1}.{2}/{3}) rGrFr+r,typer rCrr8rBrD)r*rArBrrHr-r-r.__call__ s  z_UrlMaker.__call__Nr)rPrQrRr/rJr-r-r-r.r& sr&)"rrrrrrrrrr compatr r r rr=timerH getLoggerrPr:objectrrTrrrErCrBrDr0r;rGr&r-r-r-r.sj5        H7