Refine

2025-03-15 17:16:29 +08:00
parent 6f1a0ec694
commit 40bc1491cc
1 changed files with 1 additions and 1 deletions
--- a/influxdb_api.py
+++ b/influxdb_api.py
@@ -1913,7 +1913,7 @@ def query_all_records_by_date_with_type(query_date: str, query_type: str, bucket
    # 构建 Flux 查询语句
    flux_query = f'''
    from(bucket: "{bucket}")
-      |> range(start: {utc_start_time} stop: {utc_stop_time})
+      |> range(start: {utc_start_time}, stop: {utc_stop_time})
      |> filter(fn: (r) => r["_measurement"] == "{query_type}" and r["date"] == "{query_date}")
      |> pivot(
          rowKey:["_time"],