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-02-10 22:05:06 +08:00
parent 4bf2ef12aa
commit 4872772165
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
influxdb_api.py
View File

@@ -1186,8 +1186,9 @@ def query_all_record_by_time(query_time: str, bucket: str="realtime_simulation_r
# 将北京时间转换为 UTC 时间 # 将北京时间转换为 UTC 时间
beijing_time = datetime.fromisoformat(query_time) beijing_time = datetime.fromisoformat(query_time)
utc_time = beijing_time.astimezone(timezone.utc) utc_time = beijing_time.astimezone(timezone.utc)
utc_start_time = utc_time - timedelta(seconds=1) # DingZQ, 2025-02-10, set delta time to 15, original is 1
utc_stop_time = utc_time + timedelta(seconds=1) utc_start_time = utc_time - timedelta(seconds=15)
utc_stop_time = utc_time + timedelta(seconds=15)
# 构建 Flux 查询语句 # 构建 Flux 查询语句
flux_query = f''' flux_query = f'''
@@ -1336,7 +1337,7 @@ if __name__ == "__main__":
# latest_record = query_latest_record_by_ID(ID=node_id, type="node", bucket=bucket_name, client=client) # latest_record = query_latest_record_by_ID(ID=node_id, type="node", bucket=bucket_name, client=client)
# latest_record = query_latest_record_by_ID(ID=link_id, type="link", bucket=bucket_name, client=client) # latest_record = query_latest_record_by_ID(ID=link_id, type="link", bucket=bucket_name, client=client)
latest_record = query_all_record_by_time('2025-02-09T17:30:00+08:00') all_records = query_all_record_by_time('2025-02-09T17:30:00+08:00')
if latest_record: if latest_record:
print("最新记录：", latest_record) print("最新记录：", latest_record)