debug

src/core/voip/asr.py

@@ -78,7 +78,7 @@ class TestSt:
         self.message_receiver = message_receiver
         self._Token = self.get_cached_token()
         self.sr = None
-        self.logger.info("开始")
+        self.logger.debug("开始")
 
     def start(self):
         self.__th.start()
@@ -88,14 +88,14 @@ class TestSt:
             if self.__ready:
                 self.sr.send_audio(audio_data)
             else:
-                self.logger.info("[%s]Sending audio data of length:%s", self.__id, len(audio_data))
-            # self.logger.info("Audio data sent.")
+                self.logger.debug("[%s]Sending audio data of length:%s", self.__id, len(audio_data))
+            # self.logger.debug("Audio data sent.")
         # if self.sr and not self.is_closed:
         #     with self.lock:
         #         try:
         #             self.sr.send_audio(audio_data)
         #         except Exception as e:
-        #             self.logger.info(f"Error sending audio: {e}")
+        #             self.logger.debug(f"Error sending audio: {e}")
         #             self.close()
     # def close(self):
     #     with self.lock:
@@ -104,16 +104,16 @@ class TestSt:
     #             try:
     #                 self.sr.stop()
     #             except Exception as e:
-    #                 self.logger.info(f"Error stopping ASR: {e}")
+    #                 self.logger.debug(f"Error stopping ASR: {e}")
 
     def close(self):
         try:
             self.sr.stop()
         except Exception as e:
-            self.logger.info(f"Error stopping ASR: {e}")
+            self.logger.debug(f"[{self.__id}]Error stopping ASR: {e}")
 
     def __test_run(self):
-        self.logger.info("Thread:%s start..",self.__id)
+        self.logger.debug("Thread:%s start..",self.__id)
         nls.enableTrace(True)
         self.sr = nls.NlsSpeechTranscriber(
             url=URL,
@@ -135,38 +135,38 @@ class TestSt:
             enable_inverse_text_normalization=True
         )
         self.sr.ctrl(ex={'max_sentence_silence': '1200ms', 'disfluency': True,'enable_words': True })
-        self.logger.info("ASR session started.")
+        self.logger.debug(f"[{self.__id}]ASR session started.")
 
     def test_on_sentence_begin(self, message, *args):
         # pass
-        self.logger.info("test_on_sentence_begin:%s", message)
+        self.logger.debug("[%s]test_on_sentence_begin:%s", message)
         if self.message_receiver:
             self.message_receiver(message, *args)
 
     def test_on_sentence_end(self, message, *args):
-        self.logger.info("test_on_sentence_end:%s", message)
+        self.logger.debug("[%s]test_on_sentence_end:%s", self.__id, message)
         if self.message_receiver:
             self.message_receiver(message, *args)
 
     def test_on_start(self, message, *args):
         self.__ready = True
-        self.logger.info("test_on_start:%s", message)
+        self.logger.debug("[%s]test_on_start:%s", self.__id, message)
         pass
 
     def test_on_error(self, message, *args):
-        # self.logger.info("on_error args=>{}".format(args))
+        # self.logger.debug("on_error args=>{}".format(args))
         if self.message_receiver:
             self.message_receiver(message, *args)
 
     def test_on_close(self, *args):
-        # self.logger.info("on_close: args=>{}".format(args))
+        # self.logger.debug("on_close: args=>{}".format(args))
         pass
 
     def test_on_result_chg(self, message, *args):
-        # self.logger.info("test_on_chg:{}".format(message))
+        # self.logger.debug("test_on_chg:{}".format(message))
         if self.message_receiver:
             self.message_receiver(message, *args)
 
     def test_on_completed(self, message, *args):
-        # self.logger.info("on_completed:args=>{} message=>{}".format(args, message))
+        # self.logger.debug("on_completed:args=>{} message=>{}".format(args, message))
         pass

src/core/voip/bot.py

@@ -81,7 +81,7 @@ class MyAudioMediaPort(pj.AudioMediaPort):
         if self.asr:  # 如果ASR实例存在，则发送音频数据
             if self.first:
                 self.first = False
-                self.call.logger.info("Received audio frame: %s %s", frame.buf, frame.size)
+                self.call.logger.debug("Received audio frame: %s, %s %s", self.call.session_id,frame.buf, frame.size)
             self.asr.send_audio(frame.buf)
 
         try: