async def upload_doc(ns): msg = "sql error, please check your sql" resp = { "status": False, "msg": msg } data = {} try: data['title'] = ns['title'] data['file_path'] = ns['file_path'] data['file_type'] = ns['file_type'] data['user_name'] = ns['user_name'] except Exception as e: resp['status'] = False resp['msg'] = f"get key error, please check key:{str(e)}" return resp db = DBPools() async with db.sqlorContext('kboss') as sor: data['id'] = uuid() try: await sor.C("doc_detail", data) resp['status'] = True resp['msg'] = "success" return resp except Exception as e: resp['status'] = False resp['msg'] = f"insert error, please check your sql:{str(e)}" return resp return resp ret = await upload_doc(params_kw) return ret