diff --git a/influxdb_api.py b/influxdb_api.py index f5db75a..d7aae55 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -1492,12 +1492,17 @@ def query_SCADA_data_by_device_ID_and_timerange(query_ids_list: List[str], start SCADA_dict = {} for device_id in query_ids_list: + + print('device_id', device_id) + print('utc_start_time', utc_start_time.isoformat()) + print('utc_end_time', utc_end_time.isoformat()) + 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)