From f4f6bc559ca80d8b261d7861e72f77d1feda2063 Mon Sep 17 00:00:00 2001 From: DingZQ Date: Sat, 15 Mar 2025 17:19:20 +0800 Subject: [PATCH] Refine --- influxdb_api.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/influxdb_api.py b/influxdb_api.py index c9f9e61..553da9a 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -1908,12 +1908,15 @@ def query_all_records_by_date_with_type(query_date: str, query_type: str, bucket print('utc_start_time', utc_start_time) print('utc_stop_time', utc_stop_time) + print('utc_start_time.isoformat', utc_start_time.isoformat()) + print('utc_stop_time.isoformat', utc_stop_time.isoformat()) + print('measurement', query_type) # 构建 Flux 查询语句 flux_query = f''' from(bucket: "{bucket}") - |> range(start: {utc_start_time}, stop: {utc_stop_time}) + |> range(start: {utc_start_time.isoformat()}, stop: {utc_stop_time.isoformat()}) |> filter(fn: (r) => r["_measurement"] == "{query_type}" and r["date"] == "{query_date}") |> pivot( rowKey:["_time"],