У меня есть пользовательский аутентифицированный декоратор и добавьте каждый метод get и post для аутентификации и после проверки подлинности, выполните некоторые db-запрос и обновление, но когда я дам update(), используя двигатель, бросок не может писать после финиша() ошибкаtornado throw can 'write() after finish()
счета/utils.py:
def authentication(fun):
"""
decorator for authenticating whether a user is logged in or not
:param fun:
:return:
"""
@tornado.gen.coroutine
def wrapper(self, *args, **kwargs):
db = self.application.settings['db']
if kwargs['token'] != None:
session = yield db.session.find_one({'token': kwargs['token']},{'uid'})
if session != None:
kwargs['uid'] = session['uid']
raise gen.Return(fun(self, *args, **kwargs))
else:
self.write({'status':0,'message':'请登录',"data":{}})
else:
self.write({'status':0, 'message':'请登录', 'data':{}})
return wrapper
wall.handlers.py:
@account.utils.authentication
@gen.coroutine
def post(self, *args, **kwargs):
"""
post a new kuolie card
:param args:
:param kwargs:
:return:
"""
print('sss')
db = self.settings['db']
up = upyun.UpYun('kuolie-img', username='jinpeng', password='jinpengjinpeng')
uid = kwargs['uid']
request_data = json.loads(self.request.body)
user_docs = dict(
)
if 'nickname' in request_data.keys():
user_docs['nickname'] = request_data['nickname']
if 'qq' in request_data.keys():
user_docs['qq'] = request_data['qq']
if 'phone' in request_data.keys():
user_docs['phone'] = request_data['phone']
if 'weibo' in request_data.keys():
user_docs['weibo'] = request_data['weibo']
if 'weixin' in request_data.keys():
user_docs['weixin'] = request_data['weixin']
if 'level' in request_data.keys():
user_docs['level'] = request_data['level']
if 'meta' in request_data.keys():
user_docs['meta'] = request_data['meta']
if 'avatar' in request_data.keys():
user_docs['avatar'] = request_data['avatar']
if 'gender' in request_data.keys():
user_docs['gender'] = request_data['gender']
if 'kuolietext' in request_data.keys():
user_docs['kuolietext'] = request_data['kuolietext']
if 'kuolieimage' in request_data.keys():
user_docs['kuolieimage'] = request_data['kuolieimage']
if 'kuolieaudio' in request_data.keys():
user_docs['kuolieaudio'] = request_data['kuolieaudio']
user_docs['time'] = int(time.time())
result = yield db.user.update({'uid': uid}, {'$set': user_docs })
print result
if result['updatedExisting'] == True:
print('true')
self.write({'status':1,'message':'添加成功','data':{}})
при поступлении запроса после декоратор подлинности пользователь, если auth enticated, затем сделать обновление, но есть ошибка:
[E 160503 17:16:00 concurrent:124] Future exception was never retrieved: Traceback (most recent call last): File "/Users/moonmoonbird/Documents/kuolie/lib/python2.7/site-packages/tornado/gen.py", line 1017, in run yielded = self.gen.send(value) File "/Users/moonmoonbird/Documents/kuolie/kuolie/wall/handlers.py", line 65, in get self.write({'status':1,'message':'认证通过',"data":{"a":'b'}}) File "/Users/moonmoonbird/Documents/kuolie/lib/python2.7/site-packages/tornado/web.py", line 685, in write raise RuntimeError("Cannot write() after finish()") RuntimeError: Cannot write() after finish()
я делаю неправильно, кто-то может мне помочь, спасибо заранее.
Использование ** raise gen.Return (yield fun (self, * args, ** kwargs)) ** Бросок ошибки: какая-то вещь, как ожидаемое выражение или конец ожидаемого утверждения, но ** дать удовольствие (self, * args, ** kwargs) ** работал. и вторая работала также, благодаря кучу –