from peewee import *

mysql_db = MySQLDatabase(
    "vps", user="dmy", password="abc123+_", host="192.168.1.130", port=3306
)


def get_latest_speed():
    cursor =mysql_db.execute_sql(
        "select distinct server from vps_download_speed where datetime between date_sub(now(),INTERVAL 2 day) and now()"
    )
    all_servers=cursor.fetchall()
    server_latest_speed_dic={}
    for server in all_servers[0]:
        cursor = mysql_db.execute_sql(
            "select speed from vps_download_speed where server='{server}'order by id DESC limit 1".format(server=server)
        )
        server_latest_speed_dic[server]={}
        speed_dic=server_latest_speed_dic[server]
        speed_dic['speed']=cursor.fetchone()[0]
    return server_latest_speed_dic


if __name__=='__main__':
    print(get_latest_speed())