diff --git a/influxdb_api.py b/influxdb_api.py index 76d065b..0a2507e 100644 --- a/influxdb_api.py +++ b/influxdb_api.py @@ -1461,8 +1461,6 @@ def query_SCADA_data_by_device_ID_and_timerange(query_ids_list: List[str], start 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") - |> pivot(rowKey: ["_time"], columnKey: ["device_ID"], valueColumn: "_value") - |> sort(columns: ["_time"]) ''' # 执行查询,返回一个 FluxTable 列表 tables = query_api.query(flux_query)