diff --git a/influxdb_api.py b/influxdb_api.py index 7b24594..bd40879 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -1359,7 +1359,7 @@ def query_all_record_by_date(query_date: str, bucket: str="realtime_simulation_r # 构建 Flux 查询语句 flux_query = f''' from(bucket: "{bucket}") - |> range(start: {str(start_time)}) + |> range(start: {start_time}) |> filter(fn: (r) => r["_measurement"] == "node" or r["_measurement"] == "link") |> filter(fn: (r) => r["date"] == "{query_date}") |> pivot(