讯飞asr测试,debug

src/core/voip/asr.py

@@ -14,10 +14,10 @@ import time
 import hashlib
 import hmac
 import base64
-from socket import *
-import json, time, threading
+# from socket import *
+# import json, time, threading
 from websocket import create_connection
-import websocket
+# import websocket
 from urllib.parse import quote
 
 # 定义实时转写类
@@ -209,23 +209,23 @@ class XfAsr:
     def start(self):
         self.trecv.start()
 
-    def send(self, file_path):
-        file_object = open(file_path, 'rb')
-        try:
-            index = 1
-            while True:
-                chunk = file_object.read(1280)
-                if not chunk:
-                    break
-                self.ws.send(chunk)
-
-                index += 1
-                time.sleep(0.04)
-        finally:
-            file_object.close()
-
-        self.ws.send(bytes(self.end_tag.encode('utf-8')))
-        print("send end tag success")
+    # def send(self, file_path):
+    #     file_object = open(file_path, 'rb')
+    #     try:
+    #         index = 1
+    #         while True:
+    #             chunk = file_object.read(1280)
+    #             if not chunk:
+    #                 break
+    #             self.ws.send(chunk)
+    #
+    #             index += 1
+    #             time.sleep(0.04)
+    #     finally:
+    #         file_object.close()
+    #
+    #     self.ws.send(bytes(self.end_tag.encode('utf-8')))
+    #     print("send end tag success")
 
     def send_audio(self, chunk):
         self.ws.send(chunk)
@@ -258,5 +258,6 @@ class XfAsr:
                     print("rtasr error: " + result)
                     self.ws.close()
                     return
-        except websocket.WebSocketConnectionClosedException:
-            print("receive result end")
+        except Exception as e:
+            traceback.print_exc()
+            print("receive result end", e)