diff --git a/influxdb_api.py b/influxdb_api.py index a900d4b..638267f 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -1481,13 +1481,13 @@ def query_SCADA_data_by_device_ID_and_timerange(query_ids_list: List[str], start beijing_start_time = datetime.fromisoformat(start_time) print('beijing_start_time', beijing_start_time) - utc_start_time = beijing_start_time.astimezone(timezone.utc) - timedelta(seconds=1) + utc_start_time = time_api.to_utc_time(beijing_start_time) print('utc_start_time', utc_start_time) beijing_end_time = datetime.fromisoformat(end_time) print('beijing_end_time', beijing_end_time) - utc_end_time = beijing_end_time.astimezone(timezone.utc) + timedelta(seconds=1) + utc_end_time = time_api.to_utc_time(beijing_end_time) print('utc_end_time', utc_end_time) SCADA_dict = {} @@ -1501,6 +1501,7 @@ def query_SCADA_data_by_device_ID_and_timerange(query_ids_list: List[str], start ''' # 执行查询,返回一个 FluxTable 列表 tables = query_api.query(flux_query) + records_list = [] for table in tables: for record in table.records: