from pot_libs.mysql_util.mysql_util import MysqlUtil async def change_sensor_record_by_location_id(location_id): """根据location_id查询change_sensor_record表""" sql = 'select sid,field from change_sensor_record where location_id=%s ' \ 'order by start_time desc limit 1' async with MysqlUtil() as conn: change_sensor_dic = await conn.fetchone(sql, args=(location_id,)) return change_sensor_dic