|
@@ -4,6 +4,8 @@
|
|
import os
|
|
import os
|
|
import json
|
|
import json
|
|
import threading
|
|
import threading
|
|
|
|
+import traceback
|
|
|
|
+
|
|
import nls # 引入阿里云语音识别库
|
|
import nls # 引入阿里云语音识别库
|
|
from aliyunsdkcore.client import AcsClient
|
|
from aliyunsdkcore.client import AcsClient
|
|
from aliyunsdkcore.request import CommonRequest
|
|
from aliyunsdkcore.request import CommonRequest
|
|
@@ -126,7 +128,6 @@ class TestSt:
|
|
count = count + 1
|
|
count = count + 1
|
|
|
|
|
|
def test_on_sentence_begin(self, message, *args):
|
|
def test_on_sentence_begin(self, message, *args):
|
|
- # pass
|
|
|
|
self.logger.debug("[%s]test_on_sentence_begin:%s", self.__id, message)
|
|
self.logger.debug("[%s]test_on_sentence_begin:%s", self.__id, message)
|
|
if self.message_receiver:
|
|
if self.message_receiver:
|
|
self.message_receiver(message, *args)
|
|
self.message_receiver(message, *args)
|
|
@@ -142,12 +143,16 @@ class TestSt:
|
|
pass
|
|
pass
|
|
|
|
|
|
def test_on_error(self, message, *args):
|
|
def test_on_error(self, message, *args):
|
|
- # self.logger.debug("on_error args=>{}".format(args))
|
|
|
|
|
|
+ self.logger.debug("on_error args=>%s", args)
|
|
|
|
+ if not self.__event.is_set():
|
|
|
|
+ self.__event.set()
|
|
if self.message_receiver:
|
|
if self.message_receiver:
|
|
self.message_receiver(message, *args)
|
|
self.message_receiver(message, *args)
|
|
|
|
|
|
def test_on_close(self, *args):
|
|
def test_on_close(self, *args):
|
|
- # self.logger.debug("on_close: args=>{}".format(args))
|
|
|
|
|
|
+ self.logger.debug("on_close: args=>%s", args)
|
|
|
|
+ if not self.__event.is_set():
|
|
|
|
+ self.__event.set()
|
|
pass
|
|
pass
|
|
|
|
|
|
def test_on_result_chg(self, message, *args):
|
|
def test_on_result_chg(self, message, *args):
|