diff --git a/influxdb_api.py b/influxdb_api.py index 008df5c..66d245e 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -1331,6 +1331,7 @@ def query_all_record_by_time(query_time: str, bucket: str="realtime_simulation_r "reaction": record["reaction"], "friction": record["friction"] }) + break return node_records, link_records @@ -2127,7 +2128,7 @@ if __name__ == "__main__": token = influxdb_info.token org_name = influxdb_info.org - client = InfluxDBClient(url=url, token=token) + # client = InfluxDBClient(url=url, token=token) # step1: 检查连接状态,初始化influxdb的buckets # try: