From 0c32b60534e68c9b586c59a2acffa0d1c2c7a3f2 Mon Sep 17 00:00:00 2001 From: DingZQ Date: Fri, 4 Apr 2025 14:05:07 +0800 Subject: [PATCH] Refine --- influxdb_api.py | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/influxdb_api.py b/influxdb_api.py index fb11730..a900d4b 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -1473,13 +1473,23 @@ def query_SCADA_data_by_device_ID_and_timerange(query_ids_list: List[str], start print("{} -- Failed to connect to InfluxDB.".format(datetime.now().strftime('%Y-%m-%d %H:%M:%S'))) query_api = client.query_api() + + print('start_time', start_time) + print('end_time', end_time) + # 将北京时间转换为 UTC 时间 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) - print(utc_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) - print(utc_end_time) + print('utc_end_time', utc_end_time) + SCADA_dict = {} for device_id in query_ids_list: flux_query = f'''