diff --git a/main.py b/main.py index 2607d86..81df32a 100644 --- a/main.py +++ b/main.py @@ -2124,12 +2124,20 @@ async def query_scada_latest_record_by_id(id: str): # 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]: +@app.get("/queryallrecordsbytime/") +async def query_all_records_by_time(querytime: str) -> dict[str, list]: results: tuple = influxdb_api.query_all_record_by_time(query_time=querytime, client=influx_client) return { "nodes": results[0], "links": results[1] } +#def query_all_record_by_date(query_date: str, bucket: str="realtime_simulation_result", client: InfluxDBClient=client) -> tuple: +@app.get("/queryallrecordsbydate/") +async def query_all_records_by_time(querydate: str) -> dict[str, list]: + results: tuple = influxdb_api.query_all_record_by_date(query_date=querydate, client=influx_client) + return { "nodes": results[0], + "links": results[1] } + + # def query_curve_by_ID_property_daterange(ID: str, type: str, property: str, start_date: str, end_date: str, bucket: str="realtime_data", client: InfluxDBClient=client) -> list: @app.get("/querynodecurvebyidpropertydaterange/") async def query_node_curve_by_id_property_daterange(id: str, prop: str, startdate: str, enddate: str):