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

Merge branch 'dingsu/shadell2' into TencentServer2

Browse Source
This commit is contained in:
DingZQ
2025-03-08 12:27:24 +08:00
parent acba5ef8c2 5133b93c1f
commit ec1dde7d43
1 changed files with 7 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
influxdb_api.py
View File

@@ -1864,12 +1864,11 @@ def query_all_record_by_date_property(query_date: str, type: str, property: str,
# 将 start_date 的北京时间转换为 UTC 时间 # 将 start_date 的北京时间转换为 UTC 时间
# start_time = (datetime.strptime(query_date, "%Y-%m-%d") - timedelta(days=1)).replace(hour=16, minute=0, second=0, tzinfo=timezone.utc).isoformat() # start_time = (datetime.strptime(query_date, "%Y-%m-%d") - timedelta(days=1)).replace(hour=16, minute=0, second=0, tzinfo=timezone.utc).isoformat()
start_time = (datetime.strptime(query_date, "%Y-%m-%d") - timedelta(days=1)).replace(hour=16, minute=0, second=0, tzinfo=timezone.utc).isoformat() bg_start_time, bg_end_time = time_api.parse_beijing_date_range(query_date)
print(start_time) utc_start_time = time_api.to_utc_time(bg_start_time)
stop_time = (datetime.strptime(query_date, "%Y-%m-%d")).replace(hour=16, minute=0, second=0, tzinfo=timezone.utc).isoformat() utc_end_time = time_api.to_utc_time(bg_end_time)
print(stop_time)
print(f"now time: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}") print(f"utc_start_time: {utc_start_time}, utc_end_time: {utc_end_time}")
# 构建 Flux 查询语句 # 构建 Flux 查询语句
print("before query influxdb") print("before query influxdb")
@@ -1877,13 +1876,11 @@ def query_all_record_by_date_property(query_date: str, type: str, property: str,
# 构建 Flux 查询语句 # 构建 Flux 查询语句
flux_query = f''' flux_query = f'''
from(bucket: "{bucket}") from(bucket: "{bucket}")
|> range(start: {start_time}, stop: {stop_time}) |> range(start: {utc_start_time.isoformat()}, stop: {utc_end_time.isoformat()})
|> filter(fn: (r) => |> filter(fn: (r) =>
r._measurement == "{measurement}" and r._measurement == "{measurement}" and
r._field == "{property}" r._field == "{property}"
) )
|> group(columns: ["date"])
|> filter(fn: (r) => r.date == "{query_date}")
|> keep(columns: ["ID", "_time", "_value"]) |> keep(columns: ["ID", "_time", "_value"])
''' '''
# 执行查询 # 执行查询
@@ -1900,7 +1897,7 @@ def query_all_record_by_date_property(query_date: str, type: str, property: str,
result_records.append({ result_records.append({
"time": record["_time"], "time": record["_time"],
"ID": record["ID"], "ID": record["ID"],
"value": record["_value"] property: record["_value"]
}) })
return result_records return result_records