MYSQL соединение не выбирает вновь принятые данные - PullRequest
1 голос
/ 13 июня 2019

У меня есть проблема

У меня есть RasperryPi, добавляющий данные в базу данных MySQL, и на своем рабочем компьютере я получаю эти данные, чтобы отобразить данные датчика в реальном времени, но мне нужно закрывать и открывать соединение каждый циклчтобы иметь возможность получать новые данные, которые малина отправила в SQL, похоже, что данные, которые считывает рабочий компьютер, представляют собой изображение того, что было там при событии подключения, и никакие новые данные не могут быть прочитаны.

это можно сделать, и как я могу получить новые данные, не закрывая соединение каждый раз?

def data():
    mydb = mysql.connector.connect(
        host="xxx.xxx.x.xxx",
        user="xxx",
        passwd="xxx",
        database="AMS")

    sql_select_query = "SELECT Clock, ActivePower_pos from AMS.Data where
       Clock > '{}' ".format(str((datetime.datetime.now() - 
       datetime.timedelta(minutes=1440)).strftime("%Y-%m-%d %H:%M:%S")))
    df = pd.read_sql(sql_select_query, con=mydb)

    df.dropna(inplace=True)
    df = df.set_index("Clock")

    mydb.close()

    return df"""
...