From fd2d9dda64e79fde00de90ed64749a5e5077c287 Mon Sep 17 00:00:00 2001 From: DingZQ Date: Fri, 4 Apr 2025 10:59:47 +0800 Subject: [PATCH] Refine --- influxdb_api.py | 2 +- main.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/influxdb_api.py b/influxdb_api.py index 163a079..c5a23bb 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -1704,7 +1704,7 @@ def query_latest_record_by_ID(ID: str, type: str, bucket: str="realtime_simulati # 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，分别以指定格式返回。 :param query_time: (str): 输入的北京时间，格式为 '2024-11-24T17:30:00+08:00'。 diff --git a/main.py b/main.py index d342268..c3ced7a 100644 --- a/main.py +++ b/main.py @@ -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: @app.get("/queryallrecordsbytime/") 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], "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) 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], "links": nodes_links[1] }