influxDB2.2( 二 ) _生活百科

@InfluxColumn为自定义注解，用于拼接查询语句构造map函数使用
@Retention(RetentionPolicy.RUNTIME)@Target(ElementType.FIELD)public @interface InfluxColumn { String value();}@Datapublic class MonDataDTO { // tag1名称 @InfluxColumn("pointName") private String pointName; // tag2名称 @InfluxColumn("indexName") private String indexName; // 时间片开始时间 @InfluxColumn("_start") private String start; // 时间片结束时间 @InfluxColumn("_stop") private String stop; // 数据产生时间 @InfluxColumn("_time") private String time; // 值 @InfluxColumn("_value") private String value;}@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( 二 )

经验总结扩展阅读

鸡油能吃吗平时能不能食用鸡油？

宁静演卫子夫的电视剧叫什么名字?

如何申请滴滴司机

去黑头不伤脸的最佳方法

晚安墨然|人到中年，异性之间关系不纯洁，都是从这些小事开始的

跪跳起主要练什么,练跆拳道时候，跪姿下，然后小腿用力弹跳起来。。。怎么回事~~~为什么我做不到这个动作?小腿没力怎么练？

牌匾用什么颜色招财

17岁孩子叛逆怎么管

电脑屏幕闪动是什么原因?

肌肤如何抗氧化揪出肌肤氧化4大元凶时刻年轻

芝麻分550可以借充电宝吗

烟草局夫妻透露工资！年收入近80，让人羡慕

水泵冻了怎么解冻

ctrl加什么是切换界面

爷孙属相相冲怎么办应该如何化解祖孙相冲

led声控吸顶灯怎么安装 led声控吸顶灯安装方法【详解】

约会|懂得“索取”的女人，男人反而会爱得更深

2023年11月财神方位查询 2023年11月每日发财财神方位表

一位在澳华人的内心独白：我很爱祖国，但我不想回去

电热水袋可以灌自来水吗