From edec2fe85eda80ff1e24aef30b36c7bbbb55ec2a Mon Sep 17 00:00:00 2001
From: zhifu gao <zhifu.gzf@alibaba-inc.com>
Date: 星期一, 03 七月 2023 15:08:11 +0800
Subject: [PATCH] Update SDK_tutorial_zh.md
---
funasr/runtime/python/websocket/wss_client_asr.py | 28 ++++++++++++++++++++--------
1 files changed, 20 insertions(+), 8 deletions(-)
diff --git a/funasr/runtime/python/websocket/wss_client_asr.py b/funasr/runtime/python/websocket/wss_client_asr.py
index bd9e89f..45b8ac4 100644
--- a/funasr/runtime/python/websocket/wss_client_asr.py
+++ b/funasr/runtime/python/websocket/wss_client_asr.py
@@ -40,7 +40,7 @@
help="audio_in")
parser.add_argument("--send_without_sleep",
action="store_true",
- default=False,
+ default=True,
help="if audio_in is set, send_without_sleep")
parser.add_argument("--test_thread_num",
type=int,
@@ -71,6 +71,8 @@
from queue import Queue
voices = Queue()
+offline_msg_done=False
+
ibest_writer = None
if args.output_dir is not None:
writer = DatadirWriter(args.output_dir)
@@ -158,13 +160,21 @@
message = json.dumps({"is_speaking": is_speaking})
#voices.put(message)
await websocket.send(message)
- # print("data_chunk: ", len(data_chunk))
- # print(voices.qsize())
- sleep_duration = 0.001 if args.send_without_sleep else 60 * args.chunk_size[1] / args.chunk_interval / 1000
+
+ sleep_duration = 0.001 if args.mode == "offline" else 60 * args.chunk_size[1] / args.chunk_interval / 1000
+
await asyncio.sleep(sleep_duration)
+ # when all data sent, we need to close websocket
while not voices.empty():
await asyncio.sleep(1)
await asyncio.sleep(3)
+ # offline model need to wait for message recved
+
+ if args.mode=="offline":
+ global offline_msg_done
+ while not offline_msg_done:
+ await asyncio.sleep(1)
+
await websocket.close()
@@ -173,7 +183,7 @@
async def message(id):
- global websocket,voices
+ global websocket,voices,offline_msg_done
text_print = ""
text_print_2pass_online = ""
text_print_2pass_offline = ""
@@ -183,7 +193,6 @@
meg = await websocket.recv()
meg = json.loads(meg)
wav_name = meg.get("wav_name", "demo")
- # print(wav_name)
text = meg["text"]
if ibest_writer is not None:
ibest_writer["text"][wav_name] = text
@@ -198,6 +207,7 @@
text_print = text_print[-args.words_max_print:]
os.system('clear')
print("\rpid" + str(id) + ": " + text_print)
+ offline_msg_done=True
else:
if meg["mode"] == "2pass-online":
text_print_2pass_online += "{}".format(text)
@@ -233,8 +243,10 @@
if args.audio_in is None:
chunk_begin=0
chunk_size=1
- global websocket,voices
+ global websocket,voices,offline_msg_done
+
for i in range(chunk_begin,chunk_begin+chunk_size):
+ offline_msg_done=False
voices = Queue()
if args.ssl == 1:
ssl_context = ssl.SSLContext()
@@ -251,7 +263,7 @@
else:
task = asyncio.create_task(record_microphone())
#task2 = asyncio.create_task(ws_send())
- task3 = asyncio.create_task(message(id))
+ task3 = asyncio.create_task(message(str(id)+"_"+str(i))) #processid+fileid
await asyncio.gather(task, task3)
exit(0)
--
Gitblit v1.9.1