From 9180b9c5cf33948e1303658376933bbe2c75a220 Mon Sep 17 00:00:00 2001 From: DingZQ Date: Sat, 19 Apr 2025 17:36:26 +0800 Subject: [PATCH] Add fastapi querycleanedscadadatabydeviceidandtimerange --- main.py | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/main.py b/main.py index 1b9b2cf..2b67d5a 100644 --- a/main.py +++ b/main.py @@ -2500,6 +2500,18 @@ async def fastapi_query_scada_data_by_device_id_and_time_range(ids: str, startti query_ids = ids.split(',') return influxdb_api.query_SCADA_data_by_device_ID_and_timerange(query_ids_list=query_ids, start_time=starttime, end_time=endtime) +# 查询指定时间范围内，多个SCADA设备的清洗后的数据 +# DingZQ, 2025-04-19 +@app.get("/querycleanedscadadatabydeviceidandtimerange/") +async def fastapi_query_cleaned_scada_data_by_device_id_and_time_range(ids: str, starttime: str, endtime: str): + + print(f"query_ids: {ids}, starttime: {starttime}, endtime: {endtime}") + + query_ids = ids.split(',') + return influxdb_api.query_cleaned_SCADA_data_by_device_ID_and_timerange(query_ids_list=query_ids, start_time=starttime, end_time=endtime) + + + @app.get("/queryscadadatabydeviceidanddate/") async def fastapi_query_scada_data_by_device_id_and_date(ids: str, querydate: str): query_ids = ids.split(',')