From 86a5a6594ca8d8665b862a7b0695e9ab438415d3 Mon Sep 17 00:00:00 2001 From: wuaho Date: Tue, 8 Jun 2021 20:13:21 +0800 Subject: [PATCH] 1 --- app.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/app.py b/app.py index e803e22..ea077f4 100644 --- a/app.py +++ b/app.py @@ -23,8 +23,8 @@ class XProcess(Process): handler_event = HandlerEvent(db_client, settings.GAME, self.ipsearch) handler_user = HandlerUser(db_client, settings.GAME) transmitter = Transmitter(db_client, settings.GAME, sketch, self.log, self.lock, self.event_attr) - transmitter.add_source(handler_event, 10000, 60) - transmitter.add_source(handler_user, 1000, 60) + transmitter.add_source(handler_event, 2000, 60) + transmitter.add_source(handler_user, 500, 60) last_ts = int(time.time()) consumer = create_consumer(self.partition)