From 4eea6929d762c7010837a24f727d2680315fdf3f Mon Sep 17 00:00:00 2001 From: wuaho Date: Thu, 21 Oct 2021 10:32:00 +0800 Subject: [PATCH] add unique id --- app.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/app.py b/app.py index 61911d6..d50ea77 100644 --- a/app.py +++ b/app.py @@ -41,6 +41,8 @@ class XProcess(Process): del data['#type'] ts = int(time.time()) data['properties']['unique_id'] = f'{msg.topic}-{msg.partition}-{msg.offset}' + if msg.topic == 'debug': + self.log.info(data) if 'user' in type_: # continue