diff --git a/influxdb_api.py b/influxdb_api.py index 0227a07..1a036b4 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -1355,12 +1355,10 @@ def query_all_record_by_date(query_date: str, bucket: str="realtime_simulation_r utc_time = time_api.to_utc_time(query_date + "T00:00:00+08:00") start_time = time_api.get_utc_beginning(utc_time) print(start_time) - stop_time = time_api.get_utc_after(start_time, hours=1) - print(stop_time) # 构建 Flux 查询语句 flux_query = f''' from(bucket: "{bucket}") - |> range(start: {str(start_time)}, stop: {str(stop_time)}) + |> range(start: {str(start_time)}) |> filter(fn: (r) => r["_measurement"] == "node" or r["_measurement"] == "link") |> filter(fn: (r) => r["date"] == "{query_date}") |> pivot(