influxdb-java 查询

influxdb-java是InfluxDB的Java客户端库，它提供了许多API来与InfluxDB进行交互。其中包括查询API，可以使用该API查询InfluxDB中存储的数据。在类似service类中开发一个方法供调用，将查询的数据封装在map中返回，可以使用以下代码实现：

public Map<String, Object> qryVal(User user, InfluxDataUtil influxDataUtil) {
    List<FluxTable> tables = influxDataUtil.query(tagValueInfoMapper.formateQueryValueFlux(user);
    Double value = null;
    Map<String, Object> map = new HashMap<>();
    if(CollectionUtil.isNotEmpty(tables)){
        for(FluxTable table : tables){
            List<FluxRecord> records = table.getRecords();
            for(FluxRecord fluxRecord : records){
                if(fluxRecord.getField().equals("value")){
                    value = (Double)fluxRecord.getValue();
                    map.put("value",value);
                    map.put("valueTime", DateUtils.InstantToDate(fluxRecord.getTime()));
                }
            }
        }
    }
    return map;
}

其中，`influxDataUtil.query()`方法用于执行查询，`FluxTable`和`FluxRecord`用于处理查询结果，`Map`用于封装查询结果并返回。