From 5b18ec816e3a940da611f48ac9e18bbd5ddaa8fb Mon Sep 17 00:00:00 2001 From: DingZQ Date: Fri, 14 Feb 2025 21:43:51 +0800 Subject: [PATCH] Add API queryscadadatabydeviceidandtime --- main.py | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/main.py b/main.py index b47bb0c..b3ff3d7 100644 --- a/main.py +++ b/main.py @@ -2091,6 +2091,8 @@ async def get_simulationresult(): data = [random.randint(0, 100) for _ in range(100)] return data +# 下面几个query 函数，都是从 influxdb 中查询的，不与 network 绑定，用固定的network 名字 + # DingZQ 2025-01-31 # def query_latest_record_by_ID(ID: str, type: str, bucket: str="realtime_data", client: InfluxDBClient=client) -> dict: @app.get("/querynodelatestrecordbyid/") @@ -2117,6 +2119,13 @@ async def query_node_curve_by_id_property_daterange(id: str, prop: str, startdat async def query_link_curve_by_id_property_daterange(id: str, prop: str, startdate: str, enddate: str): return influxdb_api.query_curve_by_ID_property_daterange(id, type='link', property=prop, start_date=startdate, end_date=enddate, client=influx_client) +# def query_SCADA_data_by_device_ID_and_time(query_ids_list: List[str], query_time: str, bucket: str="SCADA_data", client: InfluxDBClient=client) -> Dict[str, float]: +@app.get("/queryscadadatabydeviceidandtime/") +async def query_scada_data_by_device_id_and_time(ids: list[str], querytime: str): + return influxdb_api.query_SCADA_data_by_device_ID_and_time(query_ids_list=ids, query_time=querytime, client=influx_client) + + + # DingZQ, 2024-12-31, generate openapi.json def generate_openapi_json():