ops/datacollect
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'master' of http://git.kingsome.cn/ops/datacollect

Browse Source
This commit is contained in:
pengtao 2019-08-14 15:43:01 +08:00
commit e3e5ca21c0
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
data_collect_interface.py
View File

@ -21,7 +21,7 @@ from urllib.parse import unquote
from config import * from config import *
#sched = TornadoScheduler() #sched = TornadoScheduler()
define_logger("/data/logs/report_interface.log") define_logger("/data/logs/data_collect_interface.log")
log = logging.getLogger(__name__) log = logging.getLogger(__name__)
tornado.options.define("port", default=5022, type=int, help="run server on the given port.") tornado.options.define("port", default=5022, type=int, help="run server on the given port.")
@ -109,7 +109,7 @@ class DispatchHandler(tornado.web.RequestHandler):
try: try:
all = self._get_dailyreport_data(gameid, times, channel, methods) all = self._get_dailyreport_data(gameid, times, channel, methods)
return self.write({'errcode': 0, "errmsg": "", "result": json.dumps(all, ensure_ascii=False)}) return self.write({'errcode': 0, "errmsg": "", "result": all})
except Exception: except Exception:
log.error(f"run self._get_tap_data(**kwargs) failed", exc_info=True) log.error(f"run self._get_tap_data(**kwargs) failed", exc_info=True)
return self.write({'errcode': 2, "errmsg": "get data failed`"}) return self.write({'errcode': 2, "errmsg": "get data failed`"})
@ -117,7 +117,7 @@ class DispatchHandler(tornado.web.RequestHandler):
def _get_dailyreport_data(self, gameid, times, channel, methods): def _get_dailyreport_data(self, gameid, times, channel, methods):
sql = f"""SELECT result FROM v_event_{self.suffix} where "$part_event"='rep_{methods}'and date='{times}' sql = f"""SELECT result FROM v_event_{self.suffix} where "$part_event"='rep_{methods}'and date='{times}'
and "gameid"={gameid} and channelid={channel} """ and "gameid"='{gameid}' and channelid={channel} """
data = self.tga.get_data(sql) data = self.tga.get_data(sql)
print(f"sql={sql}") print(f"sql={sql}")
all = [] all = []