У меня есть проблема
У меня есть 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"""