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

修复数据索引类型错误

Browse Source
This commit is contained in:
JIANG
2025-12-22 10:33:43 +08:00
parent 787fbb5983
commit f10b9fac7f
2 changed files with 19 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
run_server.py
View File

@@ -13,6 +13,6 @@ if __name__ == "__main__":
"main:app",
host="0.0.0.0",
port=8000,
# workers=2, # 这里可以设置多进程
workers=2, # 这里可以设置多进程
loop="asyncio",
)

29
timescaledb/schemas/scheme.py
View File

@@ -160,7 +160,9 @@ class SchemeRepository:
query, (scheme_type, scheme_name, start_time, end_time, link_id)
)
rows = await cur.fetchall()
return [{"time": row["time"].isoformat(), "value": row[field]} for row in rows]
return [
{"time": row["time"].isoformat(), "value": row[field]} for row in rows
]
@staticmethod
async def get_links_field_by_scheme_and_time_range(
@@ -194,10 +196,9 @@ class SchemeRepository:
rows = await cur.fetchall()
result = defaultdict(list)
for row in rows:
result[row["id"]].append({
"time": row["time"].isoformat(),
"value": row[field]
})
result[row["id"]].append(
{"time": row["time"].isoformat(), "value": row[field]}
)
return dict(result)
@staticmethod
@@ -375,7 +376,9 @@ class SchemeRepository:
query, (scheme_type, scheme_name, start_time, end_time, node_id)
)
rows = await cur.fetchall()
return [{"time": row["time"].isoformat(), "value": row[field]} for row in rows]
return [
{"time": row["time"].isoformat(), "value": row[field]} for row in rows
]
@staticmethod
async def get_nodes_field_by_scheme_and_time_range(
@@ -400,10 +403,9 @@ class SchemeRepository:
rows = await cur.fetchall()
result = defaultdict(list)
for row in rows:
result[row["id"]].append({
"time": row["time"].isoformat(),
"value": row[field]
})
result[row["id"]].append(
{"time": row["time"].isoformat(), "value": row[field]}
)
return dict(result)
@staticmethod
@@ -695,7 +697,12 @@ class SchemeRepository:
raise ValueError(f"Invalid type: {type}. Must be 'node' or 'link'")
# Format the results
return [{"ID": item["id"], "value": item["value"]} for item in data]
# Format the results
result = []
for id, items in data.items():
for item in items:
result.append({"ID": id, "value": item["value"]})
return result
@staticmethod
async def query_scheme_simulation_result_by_id_time(