influxDB2.2( 二 ) _生活百科

@Datapublic class SearchParams<T> { // 查询时间范围开始时间 private String start; // 时间戳字段排序规则，true：降序 private Boolean sortRule = true; // 查询时间范围结束时间 private String end; // 时间间隔 private String every; // 筛选条件 private List<String> filterList; // map构造的目标类对象 private Class<? extends T> mapClazz;}功能类@Repository@Slf4jpublic class InfluxRepository { @Autowired private WriteApi writeApi; @Autowired private QueryApi queryApi; @Autowired private InfluxdbConfigProp influxdbConfigProp; /** * 向influx写入数据 * * @param data 写入数据实体 */ public <T> void writeData(T data) { writeApi.writeMeasurement( influxdbConfigProp.getBucket(), influxdbConfigProp.getOrg(), WritePrecision.MS, data); } /** * 查询数据 * * @param params 查询参数 */ public <T> List<FluxTable> findMonitoringData(SearchParams<T> params) { StringBuffer queryBuffer = new StringBuffer(); // BUCKET queryBuffer.append("from(bucket: \""); queryBuffer.append(influxdbConfigProp.getBucket()); // 时间范围条件 queryBuffer.append("\") \n|> range(start: "); queryBuffer.append(params.getStart()); queryBuffer.append(", stop: "); queryBuffer.append(params.getEnd()); queryBuffer.append(")\n"); List<String> filterList = params.getFilterList(); if (!CollectionUtils.isEmpty(filterList)) { queryBuffer.append(" |> filter(fn: (r) => "); // 拼接查询条件 for (int i = 0; i < filterList.size(); i++) { String[] filters = filterList.get(i).split(">"); queryBuffer.append("r[\""); queryBuffer.append(filters[0]); queryBuffer.append("\"]"); queryBuffer.append(filters[1]); if (i < filterList.size() - 1) queryBuffer.append(" and "); } queryBuffer.append(")\n"); } // aggregateWindow函数 queryBuffer.append(" |> aggregateWindow(every: "); queryBuffer.append(params.getEvery()); queryBuffer.append(",fn: first, createEmpty: true)\n"); // 为查询结果添加排序 queryBuffer.append(" |> sort(columns: [\"_time\"], desc: "); queryBuffer.append(params.getSortRule().booleanValue()); queryBuffer.append(")\n"); // map函数语句拼接 Class<? extends T> mapClazz = params.getMapClazz(); if (!ObjectUtils.isEmpty(mapClazz)) { queryBuffer.append(" |> map("); queryBuffer.append(" fn:(r) => { \n"); queryBuffer.append(" return {\n"); Field[] fields = mapClazz.getDeclaredFields(); // 目标实体字段和influx查询结果字段的映射 Map<String, String> fieldMap = new HashMap<>(); for (Field field : fields) { InfluxColumn influxColumn = field.getAnnotation(InfluxColumn.class); if (influxColumn != null) { fieldMap.put(field.getName(), influxColumn.value()); } } // 若有需要映射的字段则构建语句 if (!CollectionUtils.isEmpty(fieldMap)) { for (String key : fieldMap.keySet()) { queryBuffer.append(key); queryBuffer.append(": r[\""); queryBuffer.append(fieldMap.get(key)); queryBuffer.append("\"],\n"); } queryBuffer.append("}})\n"); } } String influxQl = queryBuffer.toString(); log.info("查询语句, {}", influxQl); List<FluxTable> queryData = queryApi.query(influxQl, influxdbConfigProp.getOrg()); return queryData; }}

influxDB2.2( 二 )

推荐阅读

陕西宝鸡高风险地地区去珠海要几次核酸

神将三国诸葛亮阵容搭配详解,诸葛亮阵容怎么搭配,新发布的哦

关于青岛公交703路简述青岛公交703路

如何提高照片饱和度

请求会起名字的高人帮忙给单位同事的女儿起个好名字:姓王,属兔,1999年12月出生

痉挛性斜颈能针灸好吗

黑色大衣搭配什么颜色的围巾三种搭配最好看

武汉一手房公积金贷款条件是什么

qq靓名大全

关于现代中医基础理论简述现代中医基础理论

幼字组词又字组词

干香菇泡发好了能放几天干香菇泡发好了可以放几天

儿子像隔壁老王的说说儿子像隔壁老王

干铁皮石斛的吃法石斛的吃法

南海区人才房 2023南海人才购房券什么时候发放

Gw250磨合期多少公里换机油豪爵GW250摩托车性能如何

今日散水聚醚价格表今日散水聚醚价格

决明子菊花枸杞的功效决明子菊花枸杞有什么功效

羊绒衫第一次怎么洗如何洗羊绒衫

孕妇不可以睡凉席吗夏天孕妇可以睡凉席吗