From 65c61ac35cc3a10a42170a855cdae578b10ee532 Mon Sep 17 00:00:00 2001 From: DingZQ Date: Fri, 14 Feb 2025 21:49:57 +0800 Subject: [PATCH] Add API a single id --- main.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/main.py b/main.py index b3ff3d7..dfc1778 100644 --- a/main.py +++ b/main.py @@ -2119,11 +2119,15 @@ async def query_node_curve_by_id_property_daterange(id: str, prop: str, startdat async def query_link_curve_by_id_property_daterange(id: str, prop: str, startdate: str, enddate: str): return influxdb_api.query_curve_by_ID_property_daterange(id, type='link', property=prop, start_date=startdate, end_date=enddate, client=influx_client) +# 返回 { 'id': value1, 'id2': value2 } # 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("/queryscadadatabydeviceidandtime/") -async def query_scada_data_by_device_id_and_time(ids: list[str], querytime: str): +@app.get("/queryscadadatabydeviceidsandtime/") +async def query_scada_data_by_device_ids_and_time(ids: list[str], querytime: str): 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)