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

1

Browse Source
This commit is contained in:
wuaho 2021-06-10 09:34:12 +08:00
parent 5c863cbf5f
commit e74afd7e45
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
single_process.py
View File

@ -31,6 +31,8 @@ def run():
for topic, msg in consumer(): for topic, msg in consumer():
# print(msg) # print(msg)
type_ = msg['#type'] type_ = msg['#type']
if msg['#app_id']!='c3e0409ac18341149877b08f087db640':
print(msg)
del msg['#type'] del msg['#type']
ts = int(time.time()) ts = int(time.time())

4
v2/transmitter.py
View File

@ -63,7 +63,7 @@ class Transmitter:
else: else:
# pass # pass
msg = traceback.format_exc() msg = traceback.format_exc()
self.log.eror(msg) self.log.error(msg)
finally: finally:
pass pass
# print(f' {os.getpid()} 释放锁') # print(f' {os.getpid()} 释放锁')
@ -104,5 +104,5 @@ class Transmitter:
self.set_event_attr(self.db_name, tb, data) self.set_event_attr(self.db_name, tb, data)
self.__send(self.db_name, tb, [json.dumps(item) for item in data]) self.__send(self.db_name, tb, [json.dumps(item) for item in data])
except Exception as e: except Exception as e:
self.log.eror(e) self.log.error(e)
buffer.clear() buffer.clear()