From f95e5bdb0b6fc4af441e5e3fc2ea51327dca1573 Mon Sep 17 00:00:00 2001 From: wuaho Date: Mon, 26 Jul 2021 23:38:27 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- single_process.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/single_process.py b/single_process.py index a2a042a..0da2b00 100644 --- a/single_process.py +++ b/single_process.py @@ -23,8 +23,8 @@ def run(): handler_event = HandlerEvent(db_client, settings.GAME, ipsearch) handler_user = HandlerUser(db_client, settings.GAME) transmitter = Transmitter(db_client, settings.GAME, sketch, logger, lock, event_attr) - transmitter.add_source(handler_event, 10000, 60) - transmitter.add_source(handler_user, 1000, 60) + transmitter.add_source(handler_event, 1, 1) + transmitter.add_source(handler_user, 1, 1) last_ts = int(time.time()) consumer = create_consumer(-1)