OrgTJWater/TJWaterServer
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add fastapi querycleanedscadadatabydeviceidandtimerange

Browse Source
This commit is contained in:
DingZQ
2025-04-19 17:36:26 +08:00
parent b15a7fa3ed
commit 9180b9c5cf
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
main.py
View File

@@ -2500,6 +2500,18 @@ async def fastapi_query_scada_data_by_device_id_and_time_range(ids: str, startti
query_ids = ids.split(',') 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) 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/") @app.get("/queryscadadatabydeviceidanddate/")
async def fastapi_query_scada_data_by_device_id_and_date(ids: str, querydate: str): async def fastapi_query_scada_data_by_device_id_and_date(ids: str, querydate: str):
query_ids = ids.split(',') query_ids = ids.split(',')