Python在七牛云平台的应用（一）

七牛云：(引用百度的介绍)七牛云是国内领先的企业级公有云服务商，致力于打造以数据为核心的场景化PaaS服务。围绕富媒体场景，七牛前后推出了对象存储，融合CDN加速，数据通用处理，内容反垃圾服务，以及直播云服务等。目前，七牛云已经在为 50多万家企业提供服务, 亲历互联网创新创业发展的同时，也深刻理解传统企业转型过程当中的云服务需求场景，推出了有针对性的一系列行业解决方案。

（一）在这里介绍一下Python怎么经过官方提供的库对本身空间进行操做

  首先须要注册一个七牛的帐号，并建立一个Bucket，另外还须要在我的面板中的密匙中获得AK和SK.以后就能经过七牛的SDK对本身的空间进行操做了.

 本文对上传／下载／删除 三个操做的方法进行说明：

 1.经过七牛的开发者中心能够获得相关的官方文档

 2.能够看到python须要安装七牛提供的库，先在cmd中执行如下语句：

pip install qiniu

 3.以后请到我的界面获得本身的Accesskey和Secretkey.

 4.根据官方文档用python写出适合本身的程序

 

(二)简单描述下上传的步骤

1.接口形式 七牛云选择 HTTP协议 做为基准接口形式

2.上传接口

用于单文件直传，若是不用官方的SDK也可使用multipart/from-data格式组织上传数据，能够参考官方文档

3.上传请求报文

上传的请求主要分红三个

 1)上传受权凭证 Token 用于确认上传者的身份是否能进行上传操做

具体也有格式： <AccessKey>:<EncodedSign>:<EncodedPutPolicy>第二个第三个分别是加密签名和上传策略，都要通过url-base64加密，上传策略能够定义各类上传的参数，具体

的参数请见官方文档.

 2)文件 用于上传的文件的内容

 3)文件名

下面就是详细的介绍

 

(三)三个操做方法

1.上传，下面代码：

#上传
def upload(bucket,path,filename,key):
    token = key.upload_token(bucket, filename, 3600)
    print('正在上传..')
    reform,inform = put_file(token, filename, path)
    if reform != None:
        print('已经成功地将{}->>{}'.format(filename,bucket))
    else:
        print('这里出现了一个小错误.')

其中bucket是上传的空间，path是上传文件存放的路径，filename是文件的名字，key提供了对操做者的身份进行了鉴定 token.

2.下载，见下方代码：

#下载        
def download(url,path):
    r = requests.get(url)
    contenter=r.content
    with open(path,'wb') as filer:
        filer.write(contenter)
        filer.close()
    print("已经保存文件到{}".format(path))

由于这里的下载使用的是公共空间，并不是是私有的，因此能够直接获得文件的url连接，这样子能够直接经过requests库和操做文件的方法进行保存到本地，下载私有空间的方法请见七牛云提

供的方法，这里不作介绍.

3.删除，见下方代码：

#删除
def delete(bucketer,filename,key):
    print('正在删除..')
    bucket = BucketManager(key)
    reform,fo = bucket.delete(bucketer, filename)
    if reform != None:
        print('已经成功地将{}->>X'.format(filename))
    else:
        print('这里出现了一个小错误.(多是空间并无这个文件)')

这里须要的是bucketer-空间的名字，为了和bucket这个类区分开；filename和key和上传的时候使用的同样.

 

（四）七牛云提供了不少官方的和非官方的一些API，能够很方便的对存贮在七牛云空间中的文件进行操做，这样子可使咱们的一些工做更加方便和简单.在后面几周我会对我使用得七牛云

平台上的一些API时遇到的一些好的和你们进行分享.

 

（五）这里提供一个我写的上面操做的集合体供各位同窗参考，代码以下：

#七牛云上传文件到空间内.
#请获得本身的secret和access key
#PS原本 AK 和SK 用了getpass库，可是由于不支持，因此暂时屏蔽了.

#import SDK
from qiniu import Auth,put_file,etag,BucketManager
import qiniu.config
from getpass import getpass
import requests

#上传
def upload(bucket,path,filename,key):
    token = key.upload_token(bucket, filename, 3600)
    print('正在上传..')
    reform,inform = put_file(token, filename, path)
    if reform != None:
        print('已经成功地将{}->>{}'.format(filename,bucket))
    else:
        print('这里出现了一个小错误.')

#下载        
def download(url,path):
    r = requests.get(url)
    contenter=r.content
    with open(path,'wb') as filer:
        filer.write(contenter)
        filer.close()
    print("已经保存文件到{}".format(path))
#删除
def delete(bucketer,filename,key):
    print('正在删除..')
    bucket = BucketManager(key)
    reform,fo = bucket.delete(bucketer, filename)
    if reform != None:
        print('已经成功地将{}->>X'.format(filename))
    else:
        print('这里出现了一个小错误.(多是空间并无这个文件)')

#主体        
def main():
    #填写你的 AK 和 SK
    accesskey = input('请输入您在七牛云的AccessKey：')
    secretkey = input('请输入您在七牛云的SecretKey：')

    #鉴定身份
    keyq=Auth(accesskey,secretkey)

    #所要操做的空间
    bucketname =input("请输入要操做的空间(公开)名字:")

    #断定操做类型
    while 1:
        order=input('请输入你须要进行的操做：')
        mode=order.split(' ')[0]
        if mode == '上传':
            path=order.split(' ')[1]
            fname=path.split('/')[-1:][0]
            print('正在尝试生成Token.请稍后..')
            upload(bucketname,path,fname,keyq)
        elif mode == '下载':
            print('正在尝试生成Token.请稍后..')
            download(order.split(' ')[1],order.split(' ')[2])
        elif mode == '更换':
            if order.split(' ')[1] == '空间':
                bucketname =input("请输入您想要更改的空间(公开)名字:")
            elif order.split(' ')[1] == 'AK':
                #accesskey = getpass(prompt= '请输入新的AK:')
                accesskey = input( '请输入新的AK:')
            elif order.split(' ')[1] == 'SK':
                #secretkey = getpass('请输入新的SK:')
                secretkey = input('请输入新的SK:')
            else:
                print('您输入的命令有误')
        elif mode == '删除':
            print('正在尝试生成Token.请稍后..')
            delete(bucketname,order.split(' ')[1],keyq)
            
        elif mode =='退出':
            break
        else:
            print('输入的命令存在错误')

print('+---------------------------------------------------+')
print('|欢迎使用本Qiniu云的上传下载程序，如下为使用方法    |')
print('|---------------------------------------------------|')
print('|1.清先输入您的Accesskey和SecretKey进行鉴权         |')
print('|2.以后请输入您要进行操做的buket空间                |')
print('|3.上传操做的命令为: 上传 文件地址(带后缀)          |')
print('|4.下载操做的命令为: 下载 连接地址 本地路径带后缀)  |')
print('|5.删除操做的命令为: 删除 空间中的文件名称          |')
print('|6.更换bucket操做为: 更换 空间名                    |')
print('|7.更换AKSK的操做为: 更换 AK/SK                     |')
print('|8.退出程序的操做为: 退出                           |')
print('+---------------------------------------------------+')
main()
    

 具体的使用效果以下：