funasr_server_http.py

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)