diff --git a/influxdb_api.py b/influxdb_api.py
index 44100f8..70b3d9f 100644
--- a/influxdb_api.py
+++ b/influxdb_api.py
@@ -3379,20 +3379,20 @@ if __name__ == "__main__":
     token = influxdb_info.token
     org_name = influxdb_info.org
 
-    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}")
+    # 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}")
 
 
     # step2: 先查询pg数据库中scada_info的信息，然后存储SCADA数据到SCADA_data这个bucket里
-    query_pg_scada_info_realtime('bb')
-    query_pg_scada_info_non_realtime('bb')
+    # query_pg_scada_info_realtime('bb')
+    # query_pg_scada_info_non_realtime('bb')
 
-    query_corresponding_query_id_and_element_id('bb')
+    # query_corresponding_query_id_and_element_id('bb')
 
 
 
@@ -3501,7 +3501,7 @@ if __name__ == "__main__":
     # print(leakage)
 
     # 示例：upload_cleaned_SCADA_data_to_influxdb
-    # upload_cleaned_SCADA_data_to_influxdb(file_path='./标准cleaned_demand_data.csv')
+    upload_cleaned_SCADA_data_to_influxdb(file_path='./标准cleaned_demand_data.csv')
 
     # 示例：query_cleaned_SCADA_data_by_device_ID_and_timerange
     # result = query_cleaned_SCADA_data_by_device_ID_and_timerange(query_ids_list=['9485'], start_time='2024-03-24T00:00:00+08:00',