wuhao/xlegudata_consumer
1
0
Fork 0
Code Issues Pull Requests Releases 1 Wiki Activity

update

Browse Source
This commit is contained in:
wuhao 2020-11-13 18:23:32 +08:00
parent ce92bd68dc
commit 12f80d3ef2
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
handler/__init__.py
View File

@ -1,3 +1,5 @@
from loguru import logger
from .handle_event import HandlerEvent from .handle_event import HandlerEvent
from .handle_paylist import HandlerPaylist from .handle_paylist import HandlerPaylist
from .handle_user import HandlerUser from .handle_user import HandlerUser
@ -11,5 +13,8 @@ HANDLER_DICT = {
def handle_factory(data): def handle_factory(data):
type_ = data['type'] type_ = data['type']
obj = HANDLER_DICT[type_](data) obj = HANDLER_DICT.get(type_)
return obj if not obj:
logger.warning(f'未知类型{type_}')
return
return obj(data)

2
main.py
View File

@ -36,6 +36,8 @@ def main():
st = time.time() * 1000 st = time.time() * 1000
data = msg.value data = msg.value
obj = handle_factory(data) obj = handle_factory(data)
if not obj:
continue
obj.run() obj.run()
logger.debug(time.time() * 1000 - st) logger.debug(time.time() * 1000 - st)