spring boot使用InfluxDB超简单三步搞定 -

yinjl

浏览: 12386 次
性别:
来自: 长沙

最近访客更多访客>>

flame1149

johnsmith9th

dlzdy

whaosoft

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

spring boot使用InfluxDB超简单三步搞定

博客分类：

influxdb

influxdb springboot

InfluxDB和IotDB介绍与性能对比

Centos MacBook Docker离线安装InfluxDB超级简单

maven依赖InfluxDB

<dependency>
<groupId>org.influxdb</groupId>
<artifactId>influxdb-java</artifactId>
<version>2.14</version>
</dependency>

InfluxDB配置

spring:
influx:
url: http://192.168.1.5:8086
user: admin
password: abcd_2021
database: demo

InfluxDB配置类

package com.beyond.data.config;
import org.influxdb.InfluxDB;
import org.influxdb.InfluxDBFactory;
import org.influxdb.dto.BatchPoints;
import org.influxdb.dto.Point;
import org.influxdb.dto.Query;
import org.influxdb.dto.QueryResult;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;
import org.springframework.stereotype.Component;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;
@Component
@Configuration
publicclassInfluxDBConfig{
@Value("${spring.influx.user}")
privateString userName;
@Value("${spring.influx.password}")
privateString password;
@Value("${spring.influx.url}")
privateString url;
//数据库
@Value("${spring.influx.database}")
privateString database;
//保留策略
privateString retentionPolicy;
privateInfluxDB influxDB;
publicInfluxDBConfig(){}
publicInfluxDBConfig(String userName,String password,String url,String database){
this.userName = userName;
this.password = password;
this.url = url;
this.database = database;
// autogen默认的数据保存策略
this.retentionPolicy = retentionPolicy ==null||"".equals(retentionPolicy)?"autogen": retentionPolicy;
this.influxDB = influxDbBuild();
}
/**
* 设置数据保存策略 defalut 策略名 /database 数据库名/ 30d 数据保存时限30天/ 1 副本个数为1/ 结尾DEFAULT
* 表示设为默认的策略
*/
publicvoid createRetentionPolicy(){
String command =String.format("CREATE RETENTION POLICY \"%s\" ON \"%s\" DURATION %s REPLICATION %s DEFAULT",
"defalut", database,"30d",1);
this.query(command);
}
/**
* 连接时序数据库；获得InfluxDB
**/
privateInfluxDB influxDbBuild(){
if(influxDB ==null){
influxDB =InfluxDBFactory.connect(url, userName, password);
influxDB.setDatabase(database);
}
return influxDB;
}
/**
* 插入
* @param measurement 表
* @param tags 标签
* @param fields 字段
*/
publicvoid insert(String measurement,Map<String,String> tags,Map<String,Object> fields){
influxDbBuild();
Point.Builder builder =Point.measurement(measurement);
builder.time(System.currentTimeMillis(),TimeUnit.MILLISECONDS);
builder.tag(tags);
builder.fields(fields);
influxDB.write(database,"", builder.build());
}
/**
* @desc 插入,带时间time
* @date 2021/3/27
*@param measurement
*@param time
*@param tags
*@param fields
* @return void
*/
publicvoid insert(String measurement,long time,Map<String,String> tags,Map<String,Object> fields){
influxDbBuild();
Point.Builder builder =Point.measurement(measurement);
builder.time(time,TimeUnit.MILLISECONDS);
builder.tag(tags);
builder.fields(fields);
influxDB.write(database,"", builder.build());
}
/**
* @desc influxDB开启UDP功能,默认端口:8089,默认数据库:udp,没提供代码传数据库功能接口
* @date 2021/3/13
*@param measurement
*@param time
*@param tags
*@param fields
* @return void
*/
publicvoid insertUDP(String measurement,long time,Map<String,String> tags,Map<String,Object> fields){
influxDbBuild();
Point.Builder builder =Point.measurement(measurement);
builder.time(time,TimeUnit.MILLISECONDS);
builder.tag(tags);
builder.fields(fields);
int udpPort =8089;
influxDB.write(udpPort, builder.build());
}
/**
* 查询
* @param command 查询语句
* @return
*/
publicQueryResult query(String command){
influxDbBuild();
return influxDB.query(newQuery(command, database));
}
/**
* @desc 查询结果处理
* @date 2021/5/12
*@param queryResult
*/
publicList<Map<String,Object>> queryResultProcess(QueryResult queryResult){
List<Map<String,Object>> mapList =newArrayList<>();
List<QueryResult.Result> resultList = queryResult.getResults();
//把查询出的结果集转换成对应的实体对象，聚合成list
for(QueryResult.Result query : resultList){
List<QueryResult.Series> seriesList = query.getSeries();
if(seriesList !=null&& seriesList.size()!=0){
for(QueryResult.Series series : seriesList){
List<String> columns = series.getColumns();
String[] keys = columns.toArray(newString[columns.size()]);
List<List<Object>> values = series.getValues();
if(values !=null&& values.size()!=0){
for(List<Object> value : values){
Map<String,Object> map =newHashMap(keys.length);
for(int i =0; i < keys.length; i++){
map.put(keys[i], value.get(i));
}
mapList.add(map);
}
}
}
}
}
return mapList;
}
/**
* @desc InfluxDB 查询 count总条数
* @date 2021/4/8
*/
publiclong countResultProcess(QueryResult queryResult){
long count =0;
List<Map<String,Object>> list = queryResultProcess(queryResult);
if(list !=null&& list.size()!=0){
Map<String,Object> map = list.get(0);
double num =(Double)map.get("count");
count =newDouble(num).longValue();
}
return count;
}
/**
* 查询
* @param dbName 创建数据库
* @return
*/
publicvoid createDB(String dbName){
influxDbBuild();
influxDB.createDatabase(dbName);
}
/**
* 批量写入测点
*
* @param batchPoints
*/
publicvoid batchInsert(BatchPoints batchPoints){
influxDbBuild();
influxDB.write(batchPoints);
}
/**
* 批量写入数据
*
* @param database
* 数据库
* @param retentionPolicy
* 保存策略
* @param consistency
* 一致性
* @param records
* 要保存的数据（调用BatchPoints.lineProtocol()可得到一条record）
*/
publicvoid batchInsert(finalString database,finalString retentionPolicy,
finalInfluxDB.ConsistencyLevel consistency,finalList<String> records){
influxDbBuild();
influxDB.write(database, retentionPolicy, consistency, records);
}
/**
* @desc 批量写入数据
* @date 2021/3/19
*@param consistency
*@param records
*/
publicvoid batchInsert(finalInfluxDB.ConsistencyLevel consistency,finalList<String> records){
influxDbBuild();
influxDB.write(database,"", consistency, records);
}
publicString getUserName(){
return userName;
}
publicvoid setUserName(String userName){
this.userName = userName;
}
publicString getPassword(){
return password;
}
publicvoid setPassword(String password){
this.password = password;
}
publicString getUrl(){
return url;
}
publicvoid setUrl(String url){
this.url = url;
}
publicString getDatabase(){
return database;
}
publicvoid setDatabase(String database){
this.database = database;
}
publicString getRetentionPolicy(){
return retentionPolicy;
}
publicvoid setRetentionPolicy(String retentionPolicy){
this.retentionPolicy = retentionPolicy;
}
publicInfluxDB getInfluxDB(){
return influxDB;
}
publicvoid setInfluxDB(InfluxDB influxDB){
this.influxDB = influxDB;
}
}

调用

@Autowired
privateInfluxDBConfig influxDBConfig;
......
influxDBConfig.insert(measurement, tags, fields);

分享到：

树莓派4B raspberrypi在线安装Docker | Centos离线安装RabbitMQ并开启MQTT

2022-08-19 18:49
浏览 459
评论(0)
分类:编程语言
查看更多

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论

spring boot使用InfluxDB超简单三步搞定

maven依赖InfluxDB

InfluxDB配置

InfluxDB配置类

调用

评论

发表评论

相关推荐

最近访客 更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论

spring boot使用InfluxDB超简单三步搞定

maven依赖InfluxDB

InfluxDB配置

InfluxDB配置类

调用

评论

发表评论

相关推荐

Centos MacBook Docker离线安装InfluxDB超级简单

InfluxDB和IotDB介绍与性能对比

最近访客更多访客>>