From e74afd7e454c6745f533e3a86c0b9aab723e6c6f Mon Sep 17 00:00:00 2001
From: wuaho <wuaho@legu.cc>
Date: Thu, 10 Jun 2021 09:34:12 +0800
Subject: [PATCH] 1

---
 single_process.py | 2 ++
 v2/transmitter.py | 4 ++--
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/single_process.py b/single_process.py
index cdd4a4a..a2a042a 100644
--- a/single_process.py
+++ b/single_process.py
@@ -31,6 +31,8 @@ def run():
     for topic, msg in consumer():
         # print(msg)
         type_ = msg['#type']
+        if msg['#app_id']!='c3e0409ac18341149877b08f087db640':
+            print(msg)
         del msg['#type']
         ts = int(time.time())
 
diff --git a/v2/transmitter.py b/v2/transmitter.py
index b54cf5f..606e4e8 100644
--- a/v2/transmitter.py
+++ b/v2/transmitter.py
@@ -63,7 +63,7 @@ class Transmitter:
             else:
                 # pass
                 msg = traceback.format_exc()
-                self.log.eror(msg)
+                self.log.error(msg)
         finally:
             pass
             # print(f' {os.getpid()} 释放锁')
@@ -104,5 +104,5 @@ class Transmitter:
                 self.set_event_attr(self.db_name, tb, data)
                 self.__send(self.db_name, tb, [json.dumps(item) for item in data])
             except Exception as e:
-                self.log.eror(e)
+                self.log.error(e)
             buffer.clear()