From 97ea829f6d3451a1ec2a23ce16d225d4232efaaa Mon Sep 17 00:00:00 2001 From: JIANG Date: Fri, 5 Dec 2025 14:29:42 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=20get=5Fscada=20=E6=96=B9?= =?UTF-8?q?=E6=B3=95=E6=9F=A5=E8=AF=A2=E5=AD=97=E6=AE=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- postgresql/scada_info.py | 11 ++++++----- timescaledb/composite_queries.py | 0 2 files changed, 6 insertions(+), 5 deletions(-) create mode 100644 timescaledb/composite_queries.py diff --git a/postgresql/scada_info.py b/postgresql/scada_info.py index b96af6b..26ed2d6 100644 --- a/postgresql/scada_info.py +++ b/postgresql/scada_info.py @@ -5,7 +5,7 @@ from psycopg import AsyncConnection class ScadaRepository: @staticmethod - async def get_scadas_info(conn: AsyncConnection) -> List[dict]: + async def get_scadas(conn: AsyncConnection) -> List[dict]: """ 查询pg数据库中,scada_info 的所有记录 :param conn: 异步数据库连接 @@ -14,7 +14,7 @@ class ScadaRepository: async with conn.cursor() as cur: await cur.execute( """ - SELECT id, type, transmission_mode, transmission_frequency, reliability + SELECT id, type, associated_element_id, transmission_mode, transmission_frequency, reliability FROM public.scada_info """ ) @@ -26,9 +26,10 @@ class ScadaRepository: record_dict = { "id": record[0], "type": record[1], - "transmission_mode": record[2], - "transmission_frequency": record[3], - "reliability": record[4], + "associated_element_id": record[2], + "transmission_mode": record[3], + "transmission_frequency": record[4], + "reliability": record[5], } records_list.append(record_dict) diff --git a/timescaledb/composite_queries.py b/timescaledb/composite_queries.py new file mode 100644 index 0000000..e69de29