Невозможно обновить приложение Taipy, подключенное к базе данных Postgres, только старые данные сеанса продолжают отобра ⇐ Python

[Anonymous]

Структура моей папки приложений - «Data_visulization», которая представляет собой базовую папку, внутреннюю папку Data_visulization Существует main.py, а другие папки - это данные и страницы. Папка данных имеет папку get_data.py и внутренних страниц init .py и root.py, а другие папки являются анализом и обзором для страницы Analys.py и Operview.py. Main.py предназначен только для всех страниц. root.py предназначен для отображения заголовка страницы KPI, а данные получают с помощью Call get_data.py для страницы KPI, а для анализа и обзорной страницы get_data.py называется отдельно. Как сделать это приложение автоматически и вручную обновлять данные базы данных, предоставив кнопку «Обновить сейчас» на странице заголовка root.py. Ниже приведен код, который я пробовал, но не смог обновить данные.# data/get_data.py
import psycopg2
import pandas as pd
from datetime import datetime, timedelta

DB_HOST = "localhost"
DB_PORT = "5432"
DB_NAME = "test"
DB_USER = "pg_db"
DB_PASS = "Admin"

data = None # Shared variable for all pages
filtered_df = None

def fetch_data():
conn = psycopg2.connect(
host=DB_HOST,
port=DB_PORT,
dbname=DB_NAME,
user=DB_USER,
password=DB_PASS
)
query = "SELECT * FROM prod_db"
data = pd.read_sql(query, conn)
data['date'] = pd.to_datetime(data['date'])
data.columns = ['Date', 'Location', 'Tower Name', 'Zone', 'Stage Label', 'Class Stage Label']
# Get yesterday's date
yesterday = (datetime.now() - timedelta(days=1)).date()

# Filter rows where date equals yesterday
filtered_df = data[data['Date'].dt.date == yesterday]
filtered_df = filtered_df.sort_values(by='Class Stage Label', ascending=False)
conn.close()
return data , filtered_df

def update_data(state=None):
global data , filtered_df
data , filtered_df = fetch_data()
if state: # For Taipy refresh calls
state.data = data
state.filtered_df = filtered_df

main.py
from taipy.gui import Gui
import threading
import time
from data.get_data import update_data
from pages import root
from Analysis import analysis
from Overview import overview

# Auto-refresh loop
def auto_refresh(state):
while True:
time.sleep(300) # every 5 minutes
update_data(state)

# Start auto-refresh when GUI initializes
def start_auto_refresh(state):
update_data(state) # load initial data
threading.Thread(target=auto_refresh, args=(state,), daemon=True).start()

pages = {
"/": root_page,
"Analysis": analysis_page,
"Overview": overview_page
}

Gui(pages=pages).run(on_init=start_auto_refresh)

root.py
from data.get_data import filtered_df, update_data
import taipy.gui.builder as tgb

with tgb.Page() as root_page:
tgb.text('## Performance Insights', mode='md')
tgb.button('Refresh Now', on_action = update_data)
with tgb.layout("1 1 1 1 1 1"):
with tgb.part():
tgb.text('### Date', mode='md')
tgb.text("#### {','.join(filtered_df['Date'].dt.strftime('%Y-%m-%d').unique())}", mode='md')

with tgb.part():
tgb.text('### Total', mode='md')
tgb.text("#### {int(filtered_df['Class Stage Label'].count())}", mode='md')

with tgb.part():
tgb.text('### Normal Stage', mode='md')
tgb.text("#### {int(filtered_df[filtered_df['Class Stage Label']=='Normal'].shape[0])}", mode='md')

with tgb.part():
tgb.text('### Stage One', mode='md')
tgb.text("#### {int(filtered_df[filtered_df['Class Stage Label']=='Stage1'].shape[0])}", mode='md')

with tgb.part():
tgb.text('### Stage Two', mode='md')
tgb.text("#### {int(filtered_df[filtered_df['Class Stage Label']=='Stage2'].shape[0])}", class_name="lblink", mode='md')

with tgb.part():
tgb.text('### Stage Three', mode='md')
tgb.text("#### {int(filtered_df[filtered_df['Class Stage Label']=='Stage3'].shape[0])}", class_name="blink", mode='md')

tgb.navbar()

with tgb.expandable(title ='Data', expanded=False):
tgb.table("{filtered_df}")


Подробнее здесь: https://stackoverflow.com/questions/797 ... ase-only-o