1<dependency>
2  <groupId>com.influxdb</groupId>
3  <artifactId>influxdb3-java</artifactId>
4  <version>1.10.0</version>
5</dependency>

1implementation 'com.influxdb:influxdb3-java:1.10.0'

1import com.influxdb.v3.client.InfluxDBClient;
2import com.influxdb.v3.client.config.ClientConfig;
3
4import java.util.Map;
5import java.util.stream.Stream;
6
7public final class TsdbExample {
8    private TsdbExample() {
9    }
10
11    public static void main(String[] args) throws Exception {
12        ClientConfig config = new ClientConfig.Builder()
13                .host(System.getenv("TSDB_HOST_URL"))
14                .token(System.getenv("TSDB_AUTH_TOKEN").toCharArray())
15                .authScheme("Bearer")
16                .database(System.getenv("TSDB_DATABASE_NAME"))
17                .writeUseV2Api(false)
18                .build();
19
20        try (InfluxDBClient client = InfluxDBClient.getInstance(config)) {
21            client.writeRecord("cpu,host=server01 usage=42.5");
22
23            // 首次写入创建 Table 后，等待新表可查询。
24            Thread.sleep(5_000);
25
26            String sql = "SELECT time, host, usage FROM cpu "
27                    + "WHERE host = 'server01' ORDER BY time DESC LIMIT 1";
28            try (Stream<Map<String, Object>> rows = client.queryRows(sql)) {
29                rows.forEach(System.out::println);
30            }
31        }
32    }
33}