def check_lease_data(ns={}): check_key = [ "store_name", ] if ns.get("field", "") not in check_key: return f"get key is not correct, please check key" return "" async def get_server_data(ns={}): """ 获取数据库数据 :param ns: :return: """ f = check_lease_data(ns) if f: return {"status": False, "msg": f} db = DBPools() async with db.sqlorContext('kboss') as sor: sql = f"SELECT distinct {ns['field']} FROM lease_server_data WHERE del_flg = 0" data = await sor.sqlPaging(sql, {"field": ns["field"]}) return {"status": True, "data": data} ret = await get_server_data(params_kw) return ret