OrgTJWater/TJWaterServer
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Refine

Browse Source
This commit is contained in:
DingZQ
2025-04-04 14:05:07 +08:00
parent 30e1587565
commit 0c32b60534
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
influxdb_api.py
View File

@@ -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'))) print("{} -- Failed to connect to InfluxDB.".format(datetime.now().strftime('%Y-%m-%d %H:%M:%S')))
query_api = client.query_api() query_api = client.query_api()
print('start_time', start_time)
print('end_time', end_time)
# 将北京时间转换为 UTC 时间 # 将北京时间转换为 UTC 时间
beijing_start_time = datetime.fromisoformat(start_time) 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 = 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) 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 = beijing_end_time.astimezone(timezone.utc) + timedelta(seconds=1)
print(utc_end_time) print('utc_end_time', utc_end_time)
SCADA_dict = {} SCADA_dict = {}
for device_id in query_ids_list: for device_id in query_ids_list:
flux_query = f''' flux_query = f'''