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-03-15 21:45:06 +08:00
parent 89f87aa63c
commit 4058ddaed7
2 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
get_data.py
View File

@@ -4,6 +4,8 @@ import pytz
from typing import List, Dict, Union, Optional from typing import List, Dict, Union, Optional
import csv import csv
# get_data 是用来获取 历史数据，也就是非实时数据的接口
# get_realtime 是用来获取 实时数据
def convert_timestamp_to_beijing_time(timestamp: Union[int, float]) -> datetime: def convert_timestamp_to_beijing_time(timestamp: Union[int, float]) -> datetime:
# 将毫秒级时间戳转换为秒级时间戳 # 将毫秒级时间戳转换为秒级时间戳

11
influxdb_api.py
View File

@@ -2087,11 +2087,9 @@ def store_scheme_simulation_result_to_influxdb(node_result_list: List[Dict[str,
:param client: (InfluxDBClient): 已初始化的 InfluxDBClient 实例。 :param client: (InfluxDBClient): 已初始化的 InfluxDBClient 实例。
:return: :return:
""" """
if client.ping(): if not client.ping():
pass print("{} -- Failed to connect to InfluxDB.".format(datetime.now().strftime('%Y-%m-%d %H:%M:%S')))
else:
print("{} -- Failed to connect to InfluxDB.".format(
datetime.now().strftime('%Y-%m-%d %H:%M:%S')))
try: try:
write_options = WriteOptions( write_options = WriteOptions(
jitter_interval=200, # 添加抖动以避免同时写入 jitter_interval=200, # 添加抖动以避免同时写入
@@ -2377,8 +2375,7 @@ def query_scheme_all_record_by_time(scheme_Type: str, scheme_Name: str, query_ti
if client.ping(): if client.ping():
pass pass
else: else:
print("{} -- Failed to connect to InfluxDB.".format( print("{} -- Failed to connect to InfluxDB.".format(datetime.now().strftime('%Y-%m-%d %H:%M:%S')))
datetime.now().strftime('%Y-%m-%d %H:%M:%S')))
query_api = client.query_api() query_api = client.query_api()
# 将北京时间转换为 UTC 时间 # 将北京时间转换为 UTC 时间
beijing_time = datetime.fromisoformat(query_time) beijing_time = datetime.fromisoformat(query_time)