diff --git a/main.py b/main.py index 4ac285b..aca3a75 100644 --- a/main.py +++ b/main.py @@ -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