接口写入redis,另一个脚本将REDIS数据写入数数

This commit is contained in:
pengtao 2019-09-24 19:42:02 +08:00
parent cbf285a6ce
commit 0ee1159892
2 changed files with 7 additions and 4 deletions

View File

@ -167,6 +167,5 @@ https://spread-test.kingsome.cn/webapp/index.php?c=Ops&a=upJumpRecording
##### 返回示例 ##### 返回示例
{ {
"errcode": 0, "errcode": 0,
"errmsg": "", "errmsg": ""
"message": ""
} }

View File

@ -51,11 +51,15 @@ class DispatchHandler(tornado.web.RequestHandler):
post_data = self.request.body.decode('utf-8') post_data = self.request.body.decode('utf-8')
post_data = json.loads(post_data) post_data = json.loads(post_data)
redis_key = f"ad::jumpRecording" redis_key = f"ad::jumpRecording"
my_redis.lpush(redis_key, post_data) try:
return self.write({'errcode': 0, "errmsg": '', "message": ""}) my_redis.lpush(redis_key, json.dumps(post_data))
return self.write({'errcode': 0, "errmsg": ''})
except:
return self.write({'errcode': 1, "errmsg": 'Failed'})
except Exception as e: except Exception as e:
result = {'errcode': 2, "errmsg": f"get args failed,{str(e)}"} result = {'errcode': 2, "errmsg": f"get args failed,{str(e)}"}
log.error(result) log.error(result)
return self.write({'errcode': 2, "errmsg": 'Failed'})
def _selfGetLocation(self): def _selfGetLocation(self):