Add API to query all records by date

This commit is contained in:
DingZQ
2025-02-23 09:39:52 +08:00
parent 13acaf2572
commit 86e894e783

12
main.py
View File

@@ -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):