diff --git a/influxdb_api.py b/influxdb_api.py index 0680602..67dd02c 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -3507,9 +3507,9 @@ if __name__ == "__main__": # step2: 先查询pg数据库中scada_info的信息,然后存储SCADA数据到SCADA_data这个bucket里 - query_pg_scada_info_realtime('bb') - query_pg_scada_info_non_realtime('bb') - query_corresponding_query_id_and_element_id('bb') + # query_pg_scada_info_realtime('bb') + # query_pg_scada_info_non_realtime('bb') + # query_corresponding_query_id_and_element_id('bb') # 手动执行存储测试 @@ -3521,7 +3521,7 @@ if __name__ == "__main__": # 示例3:download_history_data_manually # download_history_data_manually(begin_time='2025-04-16T00:00:00+08:00', end_time='2025-04-16T23:59:00+08:00') - download_history_data_manually(begin_time='2025-05-04T00:00:00+08:00', end_time='2025-05-04T23:59:00+08:00') + # download_history_data_manually(begin_time='2025-05-04T00:00:00+08:00', end_time='2025-05-04T23:59:00+08:00') # step3: 查询测试示例 @@ -3618,7 +3618,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',