diff --git a/influxdb_api.py b/influxdb_api.py index 689ffbd..aa672be 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -2724,8 +2724,8 @@ if __name__ == "__main__": # client.close() # 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') # 手动执行存储测试 # 示例1:store_realtime_SCADA_data_to_influxdb @@ -2764,8 +2764,8 @@ if __name__ == "__main__": # print(curve_result) # 示例4:query_SCADA_data_by_device_ID_and_time - # SCADA_result_dict = query_SCADA_data_by_device_ID_and_time(globals.variable_pump_realtime_ids, query_time='2025-02-25T23:45:00+08:00') - # print(SCADA_result_dict) + SCADA_result_dict = query_SCADA_data_by_device_ID_and_time(globals.fixed_pump_realtime_ids, query_time='2025-03-08T23:45:00+08:00') + print(SCADA_result_dict) # 示例5:query_SCADA_data_curve # SCADA_result = query_SCADA_data_curve(api_query_id='3853', start_date='2025-02-14', end_date='2025-02-16')