背景

最近公司我的项目须要应用阿里云的oss存储来线上实时存储图片文件。因而调研开发了python版本的阿里云oss SDK。这里咱们介绍一下oss以及python oss的罕用办法。

oss介绍

阿里云对象存储OSS（Object Storage Service）是阿里云提供的海量、平安、低成本、高长久的云存储服务。其数据设计持久性不低于99.9999999999%（12个9），服务可用性（或业务连续性）不低于99.995%。
OSS具备与平台无关的RESTful API接口，您能够在任何利用、任何工夫、任何地点存储和拜访任意类型的数据。
您能够应用阿里云提供的API、SDK接口或者OSS迁徙工具轻松地将海量数据移入或移出阿里云OSS。数据存储到阿里云OSS当前，您能够抉择规范存储（Standard）作为挪动利用、大型网站、图片分享或热点音视频的次要存储形式，也能够抉择老本更低、存储期限更长的低频拜访存储（Infrequent Access）、归档存储（Archive）、冷归档存储（Cold Archive）作为不常常拜访数据的存储形式。
以上是阿里云官网对于oss的介绍，总结来看，就是其能够提供高可用，高长久、低成本、反对多种文件及数据格式、反对RESTful API接口的云存储服务。就咱们理论应用来说的确还不错，老本的话咱们申请的海内节点，30多T数据每月差不多5000，也算比拟低了。

在代码示例前，咱们先意识一些概念：

存储类型（Storage Class）

OSS提供规范、低频拜访、归档、冷归档四种存储类型，全面笼罩从热到冷的各种数据存储场景。其中规范存储类型提供高长久、高可用、高性能的对象存储服务，可能反对频繁的数据拜访；低频拜访存储类型适宜长期保留不常常拜访的数据（均匀每月拜访频率1到2次），存储单价低于规范类型；归档存储类型适宜须要长期保留（倡议半年以上）的归档数据；冷归档存储适宜须要超长工夫寄存的极冷数据。

存储空间（Bucket）

存储空间是您用于存储对象（Object）的容器，所有的对象都必须隶属于某个存储空间。存储空间具备各种配置属性，包含地区、拜访权限、存储类型等。您能够依据理论需要，创立不同类型的存储空间来存储不同的数据。

对象（Object）

对象是OSS存储数据的根本单元，也被称为OSS的文件。对象由元信息（Object Meta）、用户数据（Data）和文件名（Key）组成。对象由存储空间外部惟一的Key来标识。对象元信息是一组键值对，示意了对象的一些属性，例如最初批改工夫、大小等信息，同时您也能够在元信息中存储一些自定义的信息。

地区（Region）

地区示意OSS的数据中心所在物理地位。您能够依据费用、申请起源等抉择适合的地区创立Bucket。

拜访域名（Endpoint）

Endpoint示意OSS对外服务的拜访域名。OSS以HTTP RESTful API的模式对外提供服务，当拜访不同地区的时候，须要不同的域名。通过内网和外网拜访同一个地区所须要的域名也是不同的。

拜访密钥（AccessKey）

AccessKey简称AK，指的是拜访身份验证中用到的AccessKey Id和AccessKey Secret。OSS通过应用AccessKey Id和AccessKey Secret对称加密的办法来验证某个申请的发送者身份。AccessKey Id用于标识用户；AccessKey Secret是用户用于加密签名字符串和OSS用来验证签名字符串的密钥，必须窃密。

oss python SDK

OssClient反对的办法：
1、上传文件对象到oss存储空间
2、上传本地指定门路文件到oss存储空间
3、下载文件到文件流对象
4、下载文件到本地指定门路
5、生成加签的长期URL以供授信用户下载

以上性能根本能够满足日常业务需要，当然oss也提供了很多个性化的操作，比方断点下载、范畴下载、断点上传、追加上传、上传回调、图片调整等等，这里不再赘述，都有专门的接口办法。
以下列举了接口实现办法，并没有在其中退出各种判断逻辑，比方文件是否存在、权限管制、是否笼罩、是否加密等等。有须要的能够本人增加逻辑

import oss2AccessKeyId = 'LTA************hpmoN9'AccessKeySecret = '0ise*************bkIyF'BucketName = '*******'Endpoint = 'http://oss-ap-south-1.aliyuncs.com'class OssClient(object):    __instance = None    __first_init = False    # 单例模式    def __new__(cls, *args, **kwargs):        if not cls.__instance:            cls.__instance = super().__new__(cls)        return cls.__instance    def __init__(self):        cls = self.__class__        if not cls.__first_init:            self.auth = oss2.Auth(AccessKeyId, AccessKeySecret)            self.bucket = oss2.Bucket(self.auth, Endpoint, BucketName)            cls.__first_init = True    def upload_file_from_fileobj(self):        """            upload_file_from_fileobj办法：上传文件对象到oss存储空间, 该办法可用于咱们从上游服务接管了图片参数，而后以二进制模式读文件，上传到oss存储空间指定地位（abc/efg/00），        当然也能够将本地文件上传到oss咱们的bucket. 其中fileobj不止能够是文件对象，也能够是本地文件门路。 put_object办法底层仍是RESTful API的调用，能够指定headers，规定Content-Type等内容        """        # 判断bucket中文件是否存在，也能够不判断，会上传更新        exist = self.bucket.object_exists('abc/efg/00') #<yourObjectName>        if exist:            return True        with open('/home/rong/www/0', 'rb') as fileobj:            result = self.bucket.put_object('abc/efg/00', fileobj, headers=None) #<yourObjectName>        if result.status == 200:            return True        else:            return False    def upload_file_from_loaclfilepath(self):        """            upload_file_from_loaclfilepath：上传本地指定门路文件（/home/rong/www/0）到oss存储空间指定地位（abc/efg/0）。与put_object办法不同，put_object_from_file的第二个参数只能是本地文件门路        """        # 判断bucket中文件是否存在，也能够不判断，会上传更新        exist = self.bucket.object_exists('abc/efg/0') #<yourObjectName>        if exist:            return True        result = self.bucket.put_object_from_file('abc/efg/0', '/home/rong/www/0', headers=None) #(<yourObjectName>, <yourLocalFile>)        if result.status == 200:            return True        else:            return False    def download_file_to_fileobj(self):        """            download_file_to_fileobj：下载文件到文件流对象。因为get_object接口返回的是一个stream流，须要执行read()后能力计算出返回Object数据的CRC checksum，因而须要在调用该接口后做CRC校验。        """        object_stream = self.bucket.get_object('abc/efg/0') #<yourObjectName>        result = object_stream.read()        if object_stream.client_crc != object_stream.server_crc:            print("The CRC checksum between client and server is inconsistent!")            result = None        return result    def download_file_to_loaclfilepath(self):        """            download_file_to_loaclfilepath：下载文件到本地门路。get_object和get_object_to_file的区别是前者是获取文件流实例，可用于代码解决和近程调用参赛。后者是存储到本地门路，返回的是一个http状态的json后果        """        result = self.bucket.get_object_to_file('abc/efg/0', '/home/rong/www/download/0') # ('<yourObjectName>', '<yourLocalFile>')        if result.status == 200:            return True        else:            return False    def generate_temporary_download_url(self):        """            generate_temporary_download_url: 生成加签的长期URL以供授信用户下载。个别在理论业务中，咱们是提供给调用方一个长期下载链接，来让其获取文件数据，而不是间接应用以上裸露AccessKeyId和AccessKeySecret的办法。            因而个别咱们会存储某条数据oss的门路（<yourObjectName>）与调用方某个惟一标识的对应关系（如手机号身份证号），在调用方申请时，通过该标识获取其数据的oss文件门路（<yourObjectName>），            而后制订过期工夫，为其生成长期下载链接            http://bucketname.oss-ap-south-1.aliyuncs.com/abc/efg/0?OSSAccessKeyId=LTA************oN9&Expires=1604638842&Signature=tPgvWz*************Uk%3D        """        res_temporary_url = self.bucket.sign_url('GET', 'abc/efg/0', 60, slash_safe=True)        return res_temporary_urlif __name__ == '__main__':    oss_client = OssClient()    print(oss_client.bucket.bucket_name)    print(oss_client.bucket.ACL)    from itertools import islice    for b in islice(oss2.ObjectIterator(oss_client.bucket), 10):        print(b.key)    ...