From e33a22d1d4a68820850592d15ba5d657bc155dea Mon Sep 17 00:00:00 2001
From: wuaho <wuaho@legu.cc>
Date: Tue, 26 Oct 2021 21:14:30 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E4=B8=BA=E6=89=8B=E5=8A=A8=E6=8F=90?=
 =?UTF-8?q?=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app.py | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/app.py b/app.py
index 33ef189..c725ea6 100644
--- a/app.py
+++ b/app.py
@@ -40,7 +40,11 @@ class XProcess(Process):
             type_ = data['#type']
             del data['#type']
             ts = int(time.time())
-            data['properties']['unique_id'] = f'{msg.topic}-{msg.partition}-{msg.offset}'
+            try:
+                data['properties']['unique_id'] = f'{msg.topic}-{msg.partition}-{msg.offset}'
+            except:
+                pass
+
             if msg.topic == 'debug':
                 self.log.info(data)