讯飞asr测试,debug

src/core/voip/asr.py

@@ -192,6 +192,8 @@ class TestSt:
             final_result['result'] = ''
             self.logger.info(f"Status is not {message['header']['status']}")
             registry.ASR_ERRORS.labels(message['header']['status']).inc()
+
+        self.logger.error("aliyun.Asr.recv: call_id:%s, final_result: %s", self.__id, final_result)
         return final_result
 
 
@@ -288,7 +290,7 @@ class XfAsr:
                     self.logger.info("xunfei.Asr.recv: receive result end")
                     break
 
-                self.logger.info("xunfei.Asr.recv: message :%s", message)
+                # self.logger.info("xunfei.Asr.recv: message :%s", message)
                 if self.message_receiver:
                     self.message_receiver(self.convert_message(message))
 
@@ -330,14 +332,17 @@ class XfAsr:
                     final_result['name'] = 'SentenceEnd'
                 final_result['result'] = ''.join(cw["w"] for item in rt for ws in item["ws"] for cw in ws["cw"])
             elif result_dict["action"] == "error":
+                self.logger.error("xunfei.Asr.recv: call_id: %s, action is error: %s", self.tid, message)
                 final_result['name'] = 'TranscriptionResultError'
                 final_result['result'] = message
                 if self.ws:
                     self.ws.close()
         else:
+            self.logger.error("xunfei.Asr.recv: call_id: %s, Status is not: %s", self.tid, result_dict["code"])
             final_result['name'] = 'TranscriptionResultError'
             final_result['status'] = result_dict["code"]
+            registry.ASR_ERRORS.labels(result_dict["code"]).inc()
             if self.ws:
                 self.ws.close()
-        self.logger.error("xunfei.Asr.recv: final_result: %s", final_result)
+        self.logger.error("xunfei.Asr.recv: call_id: %s, final_result: %s", self.tid, final_result)
         return final_result

src/core/voip/bot.py

@@ -348,7 +348,7 @@ class MyCall(pj.Call):
         # 判断是否播放完成 否则不记录用户说的内容
         if not self.is_play_complete():
             return
-        self.logger.info("on_receiver_asr_result:message: %s", message)
+        # self.logger.info("on_receiver_asr_result:message: %s", message)
         if message["name"] == "SentenceEnd":
             self.user_asr_text_queue.put(message["result"])
         elif message["name"] == "TranscriptionResultChanged":