1

app.py

@@ -68,3 +68,7 @@ class XProcess(Process):
                 continue
 
             transmitter.run()
+
+        while True:
+            time.sleep(5)
+            print(f'进程{self.partition} 已结束。。。')

v2/transmitter.py

@@ -137,5 +137,5 @@ class Transmitter:
                 self.collect_event(self.db_name, tb, data)
                 self.__send(self.db_name, tb, [json.dumps(item) for item in data])
             except Exception as e:
-                self.log.error(e)
+                self.log.error(traceback.format_exc())
             buffer.clear()