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:09:38 +08:00
parent 0c32b60534
commit 26c0ab7d90
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
influxdb_api.py
View File

@@ -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: