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(',')