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

Refine

Browse Source
This commit is contained in:
DingZQ
2025-04-04 10:59:47 +08:00
parent b8deadbd11
commit fd2d9dda64
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
influxdb_api.py
View File

@@ -1704,7 +1704,7 @@ def query_latest_record_by_ID(ID: str, type: str, bucket: str="realtime_simulati
# 2025/02/01 # 2025/02/01
def query_all_record_by_time(query_time: str, bucket: str="realtime_simulation_result") -> tuple: def query_all_records_by_time(query_time: str, bucket: str="realtime_simulation_result") -> tuple:
""" """
查询指定北京时间的所有记录，包括 'node' 和 'link' measurement，分别以指定格式返回。 查询指定北京时间的所有记录，包括 'node' 和 'link' measurement，分别以指定格式返回。
:param query_time: (str): 输入的北京时间，格式为 '2024-11-24T17:30:00+08:00'。 :param query_time: (str): 输入的北京时间，格式为 '2024-11-24T17:30:00+08:00'。

4
main.py
View File

@@ -2315,7 +2315,7 @@ async def fastapi_query_scada_latest_record_by_id(id: str):
# def query_all_record_by_time(query_time: str, bucket: str="realtime_data", client: InfluxDBClient=client) -> tuple: # def query_all_record_by_time(query_time: str, bucket: str="realtime_data", client: InfluxDBClient=client) -> tuple:
@app.get("/queryallrecordsbytime/") @app.get("/queryallrecordsbytime/")
async def fastapi_query_all_records_by_time(querytime: str) -> dict[str, list]: async def fastapi_query_all_records_by_time(querytime: str) -> dict[str, list]:
results: tuple = influxdb_api.query_all_record_by_time(query_time=querytime) results: tuple = influxdb_api.query_all_records_by_time(query_time=querytime)
return { "nodes": results[0], return { "nodes": results[0],
"links": results[1] } "links": results[1] }
@@ -2331,7 +2331,7 @@ async def fastapi_query_all_records_by_date(querydate: str) -> dict[str, list]:
loaded_dict = msgpack.unpackb(data, object_hook=decode_datetime) loaded_dict = msgpack.unpackb(data, object_hook=decode_datetime)
return loaded_dict return loaded_dict
nodes_links: tuple = influxdb_api.query_all_record_by_date(query_date=querydate) nodes_links: tuple = influxdb_api.query_all_records_by_date(query_date=querydate)
results = { "nodes": nodes_links[0], results = { "nodes": nodes_links[0],
"links": nodes_links[1] } "links": nodes_links[1] }