请求模式转为异步
This commit is contained in:
parent
7e23607511
commit
25f785452b
@ -12,6 +12,7 @@ from config import mysql_promotion_config
|
|||||||
from log.mylog import define_logger
|
from log.mylog import define_logger
|
||||||
import logging
|
import logging
|
||||||
from config import BEGIN, END, ad_list_interface_port
|
from config import BEGIN, END, ad_list_interface_port
|
||||||
|
from tornado import gen
|
||||||
import pdb
|
import pdb
|
||||||
|
|
||||||
|
|
||||||
@ -106,17 +107,17 @@ def send_cache_data():
|
|||||||
|
|
||||||
|
|
||||||
class DispatchHandler(tornado.web.RequestHandler):
|
class DispatchHandler(tornado.web.RequestHandler):
|
||||||
@tornado.web.asynchronous
|
@gen.coroutine
|
||||||
def get(self):
|
def get(self):
|
||||||
if self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'selfChecking':
|
if self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'selfChecking':
|
||||||
self._selfCheckingHandler()
|
self._selfCheckingHandler()
|
||||||
elif self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'getAdList':
|
elif self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'getAdList':
|
||||||
self._selfGetAdList()
|
yield self._selfGetAdList()
|
||||||
elif self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'upAdRecording':
|
elif self.get_query_argument('c') == 'Ops' and self.get_query_argument('a') == 'upAdRecording':
|
||||||
self._upAdRecording()
|
yield self._upAdRecording()
|
||||||
else:
|
else:
|
||||||
self.write("pls check args!")
|
self.write("pls check args!")
|
||||||
self.finish()
|
|
||||||
|
|
||||||
def _upAdRecording(self):
|
def _upAdRecording(self):
|
||||||
try:
|
try:
|
||||||
|
Loading…
x
Reference in New Issue
Block a user