Refine

2025-04-19 18:03:19 +08:00
parent 5501049938
commit ad3a4d9461
1 changed files with 5 additions and 5 deletions
--- a/influxdb_api.py
+++ b/influxdb_api.py
@@ -3356,11 +3356,11 @@ if __name__ == "__main__":

    client = InfluxDBClient(url=url, token=token)
    # step1: 检查连接状态，初始化influxdb的buckets
-    try:
-        # delete_buckets(org_name)
-        create_and_initialize_buckets(org_name)
-    except Exception as e:
-        print(f"连接失败: {e}")
+    # try:
+    #     # delete_buckets(org_name)
+    #     create_and_initialize_buckets(org_name)
+    # except Exception as e:
+    #     print(f"连接失败: {e}")


    # step2: 先查询pg数据库中scada_info的信息，然后存储SCADA数据到SCADA_data这个bucket里