OrgTJWater/TJWaterServerBinary
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

更新 get_scada 方法查询字段

Browse Source
This commit is contained in:
JIANG
2025-12-05 14:29:42 +08:00
parent 0dc057dad7
commit 97ea829f6d
2 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
postgresql/scada_info.py
View File

@@ -5,7 +5,7 @@ from psycopg import AsyncConnection
class ScadaRepository: class ScadaRepository:
@staticmethod @staticmethod
async def get_scadas_info(conn: AsyncConnection) -> List[dict]: async def get_scadas(conn: AsyncConnection) -> List[dict]:
""" """
查询pg数据库中,scada_info 的所有记录 查询pg数据库中,scada_info 的所有记录
:param conn: 异步数据库连接 :param conn: 异步数据库连接
@@ -14,7 +14,7 @@ class ScadaRepository:
async with conn.cursor() as cur: async with conn.cursor() as cur:
await cur.execute( 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 FROM public.scada_info
""" """
) )
@@ -26,9 +26,10 @@ class ScadaRepository:
record_dict = { record_dict = {
"id": record[0], "id": record[0],
"type": record[1], "type": record[1],
"transmission_mode": record[2], "associated_element_id": record[2],
"transmission_frequency": record[3], "transmission_mode": record[3],
"reliability": record[4], "transmission_frequency": record[4],
"reliability": record[5],
} }
records_list.append(record_dict) records_list.append(record_dict)

0
timescaledb/composite_queries.py Normal file
View File