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

Set influxdb client timeout to 100 seconds

Browse Source
This commit is contained in:
DingZQ
2025-02-10 22:03:14 +08:00
parent a17a0b3a89
commit 4bf2ef12aa
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
main.py
View File

@@ -65,7 +65,7 @@ redis_client = redis.Redis(host="localhost", port=6379, db=0)
influx_url = influxdb_info.url
influx_token = influxdb_info.token
influx_org_name = influxdb_info.org
influx_client = InfluxDBClient(url=influx_url, token=influx_token, org=influx_org_name)
influx_client = InfluxDBClient(url=influx_url, token=influx_token, org=influx_org_name, timeout=100*1000) # 100 seconds
# 配置日志记录器
logging.basicConfig(
@@ -2103,18 +2103,18 @@ async def query_link_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]:
results: tuple = influxdb_api.query_all_record_by_time(query_time=querytime, client=influx_client);
results: tuple = influxdb_api.query_all_record_by_time(query_time=querytime, 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("/querynodecurvebyidpropertydatarage/")
async def query_node_curve_by_id_property_datarage(id: str, prop: str, startdate: str, enddate: str):
return influxdb_api.query_curve_by_ID_property_daterange(id, type='node', property=prop, start_date=startdate, end_date=enddate, client=influx_client);
return influxdb_api.query_curve_by_ID_property_daterange(id, type='node', property=prop, start_date=startdate, end_date=enddate, client=influx_client)
@app.get("/querylinkcurvebyidpropertydatarage/")
async def query_link_curve_by_id_property_datarage(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);
return influxdb_api.query_curve_by_ID_property_daterange(id, type='link', property=prop, start_date=startdate, end_date=enddate, client=influx_client)
# DingZQ, 2024-12-31, generate openapi.json