学习 InfluxDB(三):Java Client

InfluxDB 的 Java 客户端由 InfluxDB 母公司 InfluxData 提供。

GitHub 地址:https://github.com/influxdata/influxdb-java

编写 pom.xml 文件,添加依赖:

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

代码示例:

try (InfluxDB influxDB = InfluxDBFactory.connect("http://localnode4:8086", "admin", "admin")) {  
    influxDB.setDatabase("test");

    // 写入数据
    influxDB.write(Point.measurement("friends")
            .time(System.currentTimeMillis(), TimeUnit.MILLISECONDS)
            .tag("username", "lily")
            .addField("age", 20)
            .build());
    influxDB.write(Point.measurement("friends")
            .time(System.currentTimeMillis(), TimeUnit.MILLISECONDS)
            .tag("username", "lucy")
            .addField("age", 21)
            .build());

    // 查询
    Query query = new Query("SELECT * from test");
    QueryResult rs = influxDB.query(query);
}

基于 InfluxDB 1.7