diff --git a/main.py b/main.py index f700262..e93747a 100644 --- a/main.py +++ b/main.py @@ -2103,6 +2103,13 @@ async def query_node_latest_record_by_id(id: str): async def query_link_latest_record_by_id(id: str): return influxdb_api.query_latest_record_by_ID(id, type='link', client=influx_client) +# query scada +@app.get("/queryscadalatestrecordbyid/") +async def query_scada_latest_record_by_id(id: str): + return influxdb_api.query_latest_record_by_ID(id, type='scada', client=influx_client) + + + # def query_all_record_by_time(query_time: str, bucket: str="realtime_data", client: InfluxDBClient=client) -> tuple: @app.get("/queryallrecordbytime/") async def query_all_record_by_time(querytime: str) -> dict[str, list]: