上一章我们讲到如何利用alembic来更新数据库，这章，我们讲如何通过七牛服务来存储图片。
像我们大多数公司一样，公司资金比较少，如果自己开发图片服务器，代价太大；如果我们用自己的网站服务器来保存图片，很可能会把带宽阻塞住。因此，一款优秀的第三方图片服务变得非常重要。七牛就是这么一款，上传代码简单，可以在线编辑，简单的变换url，可以得到图片的不同效果。关键是，它是在一定限额内是免费的，只要通过认证，基本都够用了。我们公司现在包括app，网站所有图片都放在七牛，一直用的很好，一分钱也没有花。
好了，闲话少说，自己先申请一个七牛账号，登录进去，可以自己先玩一下，直接上传一个图片。
这就是我七牛账号里面的图片，我们点击内容上传，
速度不是一般的快呀，做技术出生的CEO果然就是不同，点击"关闭"，然后打开外链，看看效果吧。http://7xk6rc.com1.z0.glb.clouddn.com/2016-05-04%2015-06-21%E5%B1%8F%E5%B9%95%E6%88%AA%E5%9B%BE.png 这是我刚才上传的，你可以打开看看，是不是很简单？就是这么简单，然后我们用编程的方式上传，仅此而已。
好了，下面上python上传代码，首先，按照文档，先安装一下qiniu模块。
pip install qiniu
安装好以后，先随便写一个python上传代码，看看我们实际过程中需要提供什么。
# coding:utf-8
from qiniu import Auth, put_file, etag, urlsafe_base64_encode access_key = 'access_key'
secret_key = 'secret_key' q = Auth(access_key=access_key, secret_key=secret_key) bucket_name = 'dameinv' key = 'my-test-picture.png' token = q.upload_token(bucket_name, key, 3600) print token localfile = './my-test.png' ret, info = put_file(token, key, localfile) print ret
print info
看看打印结果
hP7WNicFRHPu2Bd24MaLj5VvmElXYJbRCoZfrVs6:Fi7LRD1ufxI6GaoRRUeX9ncRk0g=:eyJzY29wZSI6ImRhbWVpbnY6bXktdGVzdC1waWN0dXJlLnBuZyIsImRlYWRsaW5lIjoxNDYyMzUwMTk3fQ==
{u'hash': u'FvSC6ud6RL3jLmARbabBuzQttbNO', u'key': u'my-test-picture.png'}
exception:None, status_code:, _ResponseInfo__response:<Response []>, text_body:{"hash":"FvSC6ud6RL3jLmARbabBuzQttbNO","key":"my-test-picture.png"}, req_id:pSEAAMKvVqF7TEsU, x_log:s.ph;s.put.tw;s.put.tr;s.put.tw;s.put.tr;s.ph;s.put.tw;s.put.tr;s.ph;PFDS;PFDS:;PFDS:;rs18_6.sel/not found;rdb.g/no such key;DBD/;v4.get:/Document not found;rs19_6.ups;qtbl.ups:;mc.s;RS:;rs.put:;rs-upload.putFile:;UP: Process finished with exit code
好了，看看实际在七牛的效果。
http://7xk6rc.com1.z0.glb.clouddn.com/my-test-picture.png
打开看看吧，这就是实际效果。
下面我们就来逐个分析一下代码，
首先，access_key和secret_key就是你的'个人面板'===>'密钥管理'里面的2个key，直接复制过来就可以了，这个key很重要，千万不能泄露哦。
其次，q = Auth(access_key=access_key, secret_key=secret_key)新建一个qiniu上传对象；bucket_name就是你的空间名，我的空间名是“dameimv”，可以建多个空间，看看我所有空间名；我用的最上面的那个；key，其实这个命名有点问题的，其实应该叫路径，至于为什么七牛文档中叫它key，就不得而知了；然后我们利用bucket_name和key，返回一个token，这个token以后就是我们主要返回给客户端的，第三个参数，就是它过期时间，我这边就随便设置1个小时过期。
最后，就是上传，其实以后，这是客户端的事，我们服务器端只要提供token和key就可以了，客户端上传成功以后，直接告诉我们路径即可。其实就是一个put_file而已。
看看返回结果，我个人就是看info的status_code，如果是200就代表上传成功。
是不是非常简单！好了，在此基础上，我们写接口吧。首先，我通常的做法是，服务器端提供token和key的接口，客户端拿到以后，自己上传图片，上传成功了，再把整个url给我，这样，服务器不会浪费任何带宽资源，而且也不会中途出错，导致其他问题。即使客户端出错，它可以自己重新上传，或者根本不上传，服务器端不需要存储任何数据，也不会出现其他意外。
import uuid
from qiniu import Auth, put_file, etag, urlsafe_base64_encode
access_key = 'access_key'
secret_key = 'secret_key'
q = Auth(access_key=access_key, secret_key=secret_key)
bucket_name = 'dameinv' @app.route('/get-qiniu-token')
def get_qiniu_token():
key = uuid.uuid4()
token = q.upload_token(bucket_name, key, 3600)
return jsonify({'code': 1, 'key': key, 'token': token}) @app.route('/set-head-picture', methods=['POST'])
@login_check
def set_head_picture():
head_picture = request.get_json().get('head_picture')
user = g.current_user
user.head_picture = head_picture
try:
db_session.commit()
except Exception as e:
print e
db_session.rollback()
return jsonify({'code': 0, 'message': '未能成功上传'})
redis_store.hset('user:%s' % user.phone_number, 'head_picture', head_picture)
return jsonify({'code': 1, 'message': '成功上传'})
我们在原来的view.py中添加如上代码，第一个get_qiniu_token是获取七牛的token和key，这边的key为了保持唯一，使用uuid，其实有2种方案，第一，你可以用这uuid，第二，你可以使用http://base_url/phone_number/time_stamp 这样的方式，其实我更倾向于第二种，这样，你就可以看到在这个用户下，有多少它上传的东西，便于直接统计。
整个上传代码就这样，照例，我们在client.py文件下，模拟一下客户端操作，看看有没有问题。
# coding:utf-8
import requests
import json
from qiniu import put_file class APITest(object):
def __init__(self, base_url):
self.base_url = base_url
self.headers = {}
self.token = None
self.qiniu_token = None
self.qiniu_key = None
self.qiniu_base_url = 'http://7xk6rc.com1.z0.glb.clouddn.com/' def login(self, phone_number, password, path='/login'):
payload = {'phone_number': phone_number, 'password': password}
self.headers = {'content-type': 'application/json'}
response = requests.post(url=self.base_url + path, data=json.dumps(payload), headers=self.headers)
response_data = json.loads(response.content)
self.token = response_data.get('token')
return response_data def user(self, path='/user'):
self.headers = {'token': self.token}
response = requests.get(url=self.base_url + path, headers=self.headers)
response_data = json.loads(response.content)
return response_data def logout(self, path='/logout'):
self.headers = {'token': self.token}
response = requests.get(url=self.base_url + path, headers=self.headers)
response_data = json.loads(response.content)
return response_data def get_qiniu_token(self, path='/get-qiniu-token'):
response = requests.get(url=self.base_url + path)
response_data = json.loads(response.content)
self.qiniu_token = response_data.get('token')
self.qiniu_key = response_data.get('key')
if self.qiniu_token and self.qiniu_key:
print '成功获取qiniu_token和qiniu_key,分别为%s和%s' % (self.qiniu_token.encode('utf-8'), self.qiniu_key.encode('utf-8'))
localfile = '/home/yudahai/PycharmProjects/blog01/app/my-test.png'
ret, info = put_file(self.qiniu_token, self.qiniu_key, localfile)
print info.status_code
if info.status_code == 200:
print '上传成功'
self.head_picture = self.qiniu_base_url + self.qiniu_key
print '其url为:' + self.head_picture.encode('utf-8')
else:
print '上传失败'
return response_data def set_head_picture(self, path='/set-head-picture'):
payload = {'head_picture': self.head_picture}
self.headers = {'token': self.token, 'content-type': 'application/json'}
response = requests.post(url=self.base_url + path, data=json.dumps(payload), headers=self.headers)
response_data = json.loads(response.content)
print response_data.get('message')
return response_data if __name__ == '__main__':
api = APITest('http://127.0.0.1:5001')
api.login('', '')
api.get_qiniu_token()
api.set_head_picture()
api.logout()
运行一下，看看结果吧。
成功获取qiniu_token和qiniu_key,分别为hP7WNicFRHPu2Bd24MaLj5VvmElXYJbRCoZfrVs6:WZLWPx0bZ04KjSU0zRYKrPitWoE=:eyJzY29wZSI6ImRhbWVpbnY6YjU2NGJlOTAtMjM2ZS00YjQzLWE1M2UtZGRjMThlNTJmYmQxIiwiZGVhZGxpbmUiOjE0NjIzNTYwOTJ9和b564be90-236e-4b43-a53e-ddc18e52fbd1 上传成功
其url为:http://7xk6rc.com1.z0.glb.clouddn.com/b564be90-236e-4b43-a53e-ddc18e52fbd1
成功上传
已经上传成功了，看看头像结果
>>> from app.model import *
>>> user = User.query.filter_by('').first()
Traceback (most recent call last):
File "<input>", line , in <module>
TypeError: filter_by() takes exactly argument ( given)
>>> user = User.query.filter_by(phone_number='').first()
>>> user.head_picture
u'http://7xk6rc.com1.z0.glb.clouddn.com/b564be90-236e-4b43-a53e-ddc18e52fbd1'
看，已经成功了。
以后几乎所有的图片都可以这么处理，在客户端需要图片之前，让他们先访问get-qiniu-token接口，拿到token和key，客户端根据token和key来上传自己的东西。每上传一次，就访问一次get-qiniu-token接口。
好了，这就是简单的七牛上传图片介绍，详细的说明，他们都有文档，文档做的非常清晰。下一章，我们利用容联云通讯来完成注册过程，也非常简单。