diff --git a/influxdb_api.py b/influxdb_api.py index 6e2f1c1..f5db75a 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -1494,10 +1494,10 @@ def query_SCADA_data_by_device_ID_and_timerange(query_ids_list: List[str], start for device_id in query_ids_list: flux_query = f''' from(bucket: "{bucket}") - |> range(start: {utc_start_time.isoformat()}, stop: {utc_end_time.isoformat()}) |> filter(fn: (r) => r["device_ID"] = {device_id} and r["_field"] == "monitored_value") |> sort(columns: ["_time"]) ''' + #|> range(start: {utc_start_time.isoformat()}, stop: {utc_end_time.isoformat()}) # 执行查询,返回一个 FluxTable 列表 tables = query_api.query(flux_query)