diff --git a/influxdb_api.py b/influxdb_api.py index aa672be..37845c1 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -2738,7 +2738,7 @@ if __name__ == "__main__": # download_history_data_manually(begin_time='2025-02-25T00:00:00+08:00', end_time='2025-02-26T00:00:00+08:00') # step3: 查询测试示例 - # with InfluxDBClient(url=url, token=token, org=org_name) as client: + with InfluxDBClient(url=url, token=token, org=org_name) as client: # # 示例1:query_latest_record_by_ID # bucket_name = "realtime_simulation_result" # 数据存储的 bucket 名称 @@ -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.fixed_pump_realtime_ids, query_time='2025-03-08T23: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')