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

Refine

Browse Source
This commit is contained in:
DingZQ
2025-02-14 21:59:27 +08:00
parent 65c61ac35c
commit 60ae213d15
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
main.py
View File

@@ -2123,8 +2123,13 @@ async def query_link_curve_by_id_property_daterange(id: str, prop: str, startdat
# 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("/queryscadadatabydeviceidsandtime/")
async def query_scada_data_by_device_ids_and_time(ids: list[str], querytime: str):
logger.info(ids)
logger.info(querytime)
return influxdb_api.query_SCADA_data_by_device_ID_and_time(query_ids_list=ids, query_time=querytime, client=influx_client)
@app.get("/queryscadadatabydeviceidandtime/")
async def query_scada_data_by_device_id_and_time(id: str, querytime: str):
return influxdb_api.query_SCADA_data_by_device_ID_and_time(query_ids_list=[id], query_time=querytime, client=influx_client)