From 21a6c54f58b81e44c6902957bd467b5879ce0e60 Mon Sep 17 00:00:00 2001 From: DingZQ Date: Fri, 14 Feb 2025 22:22:28 +0800 Subject: [PATCH] Add api to query scada --- main.py | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/main.py b/main.py index f700262..e93747a 100644 --- a/main.py +++ b/main.py @@ -2103,6 +2103,13 @@ async def query_node_latest_record_by_id(id: str): async def query_link_latest_record_by_id(id: str): return influxdb_api.query_latest_record_by_ID(id, type='link', client=influx_client) +# query scada +@app.get("/queryscadalatestrecordbyid/") +async def query_scada_latest_record_by_id(id: str): + return influxdb_api.query_latest_record_by_ID(id, type='scada', client=influx_client) + + + # def query_all_record_by_time(query_time: str, bucket: str="realtime_data", client: InfluxDBClient=client) -> tuple: @app.get("/queryallrecordbytime/") async def query_all_record_by_time(querytime: str) -> dict[str, list]: