Refine

2025-02-23 10:16:54 +08:00
parent b48e67b47e
commit 575c7b9dc9
1 changed files with 2 additions and 1 deletions
--- 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: