This commit is contained in:
xtkuang 2025-08-25 11:42:16 +08:00
parent acf29efa4c
commit e05f5c978c
3 changed files with 17 additions and 15 deletions

View File

@ -16,7 +16,7 @@ WakeWordRunner:
threshold: 0.3
cooldown_sec: 1.5
reset_sec: 3.0
url: http://xxx.xxx.xxx.xxx:xxxx/xx/xx/xx
url: http://192.168.1.10:13080/kws/wake
ASRRunner:
asr_model: paraformer-zh-streaming
@ -27,4 +27,4 @@ ASRRunner:
decoder_chunk_look_back: 1
max_duration: 20
max_empty_txt_count: 3
url: http://xxx.xxx.xxx.xxx:xxxx/xx/xx/xx
url: http://192.168.1.10:13080/kws/execute

View File

@ -103,13 +103,13 @@ class ASRRunner:
for r in res:
data += r['text']
print(data)
# try:
# data_json= json.dumps({'text': data})
# response = requests.post(self.url, data = data_json)
# # if response.result != "OK":
# # print("request Failed")
# except Exception as e:
# print("ASRRunner send request failed: ", e)
try:
data_json= json.dumps({'msg': data})
response = requests.get(self.url, data = data_json)
if response.status_code != 200:
print(f"ASRRunner send request failed: status code={response.status_code}")
except Exception as e:
print("ASRRunner send request failed: ", e)
def switch(self):
asr_flag.clear()

View File

@ -55,10 +55,12 @@ class WakeWordRunner:
if score >= self.threshold:
print(f"WordScores: {scores}")
self.last_trigger_time = now
asr_flag.set()
# try:
# data_json = json.dump({"msg": "wakeup"})
# requests.post(self.url, data=data_json)
# self.last_trigger_time = now
# except Exception as e:
# print("WakeWordRunner send request failed: ", e)
try:
data_json = json.dumps({"msg": "wakeup"})
response = requests.get(self.url, data=data_json)
if response.status_code != 200:
print(f"WordScores: send wake up request failed, status={response.status_code}")
except Exception as e:
print("WakeWordRunner send request failed: ", e)