diff --git a/influxdb_api.py b/influxdb_api.py index e71d9f7..5e3bd80 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -1741,6 +1741,8 @@ def store_realtime_simulation_result_to_influxdb(node_result_list: List[Dict[str if not client.ping(): print("{} -- Failed to connect to InfluxDB.".format(datetime.now().strftime('%Y-%m-%d %H:%M:%S'))) + print("store_realtime_simulation_result_to_influxdb : result_start_time ", result_start_time) + # 本地变量,用于记录成功写入的数据点数量 points_written = 0 lock = threading.Lock()