leguadmin/to_ck
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

减少批量

Browse Source
This commit is contained in:
wuaho 2021-07-28 20:19:22 +08:00
parent 3b1e73937d
commit f96f5da864
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app.py
View File

@ -24,8 +24,8 @@ class XProcess(Process):
handler_user = HandlerUser(db_client, settings.GAME) handler_user = HandlerUser(db_client, settings.GAME)
transmitter = Transmitter(db_client, settings.GAME, sketch, self.log, self.lock, self.event_attr, transmitter = Transmitter(db_client, settings.GAME, sketch, self.log, self.lock, self.event_attr,
self.partition) self.partition)
transmitter.add_source(handler_event, 2000, 60) transmitter.add_source(handler_event, 5000, 60)
transmitter.add_source(handler_user, 99, 60) transmitter.add_source(handler_user, 500, 60)
last_ts = int(time.time()) last_ts = int(time.time())
consumer = create_consumer(self.partition) consumer = create_consumer(self.partition)