- InfluxDB实现历史数据、实时数据的读取存储。
- 统一管理tag变量，快速脚手架。
- 支持多种接口服务。
<dependency>
<groupId>org.influxdb</groupId>
<artifactId>influxdb-java</artifactId>
<version>2.9</version>
</dependency>
InfluxDB influxDB = InfluxDBFactory.connect(URL, USER, PASSWORD);
Builder builder = Point.measurement("table_test")
.tag("tag1", "www").tag("tag2", "22")
.tag("tag3", "man");
Point point = builder .addField("value1", 66).addField("value2", 22).build();
influxDB.write(INFLUXDB_DBNAME, "autogen", point ); String sql = "select * from result";
Query query = new Query(sql, INFLUXDB_DBNAME);
QueryResult result = influxDB.query(query);
if (result.getResults().get(0).getSeries() != null) {
List<String> columns = result.getResults().get(0).getSeries().get(0).getColumns();
List<Object> resval = result.getResults().get(0).getSeries().get(0).getValues().get(0);
double qpsdata = (Double) resval.get(columns.indexOf("value1"));
System.out.println(qpsdata);
}查询最近10条记录：
select * from "/ros" order by time desc limit 10查询top 10的记录：
select top(cpu, 100) from "/ros" 查询最小的10条记录
select bottom(cpu, 10) from "/ros"