import argparse
|
import base64
|
import io
|
import soundfile as sf
|
import uvicorn
|
from fastapi import FastAPI, Body
|
|
app = FastAPI()
|
|
from funasr_onnx import Paraformer
|
|
model_dir = "damo/speech_paraformer-large_asr_nat-zh-cn-16k-common-vocab8404-onnx"
|
model = Paraformer(model_dir, batch_size=1, quantize=True)
|
|
|
async def recognition_onnx(waveform):
|
result = model(waveform)[0]["preds"][0]
|
return result
|
|
|
@app.post("/api/asr")
|
async def asr(item: dict = Body(...)):
|
try:
|
audio_bytes = base64.b64decode(bytes(item["wav_base64"], "utf-8"))
|
waveform, _ = sf.read(io.BytesIO(audio_bytes))
|
result = await recognition_onnx(waveform)
|
ret = {"results": result, "code": 0}
|
except:
|
print("请求出错，这里是处理出错的")
|
ret = {"results": "", "code": 1}
|
return ret
|
|
|
if __name__ == "__main__":
|
parser = argparse.ArgumentParser(description="API Service")
|
parser.add_argument("--listen", default="0.0.0.0", type=str, help="the network to listen")
|
parser.add_argument("--port", default=8888, type=int, help="the port to listen")
|
args = parser.parse_args()
|
|
print("start...")
|
print("server on:", args)
|
|
uvicorn.run(app, host=args.listen, port=args.port)
|
