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

add unique id

Browse Source
This commit is contained in:
wuaho 2021-10-21 10:32:00 +08:00
parent 3b9ed0c98f
commit 4eea6929d7
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app.py
View File

@ -41,6 +41,8 @@ class XProcess(Process):
del data['#type'] del data['#type']
ts = int(time.time()) ts = int(time.time())
data['properties']['unique_id'] = f'{msg.topic}-{msg.partition}-{msg.offset}' data['properties']['unique_id'] = f'{msg.topic}-{msg.partition}-{msg.offset}'
if msg.topic == 'debug':
self.log.info(data)
if 'user' in type_: if 'user' in type_:
# continue # continue