关于influxDB

<dependency>
    <groupId>com.influxdb</groupId>
    <artifactId>influxdb-client-java</artifactId>
    <version>3.3.0</version>
</dependency>

package example;


import java.time.Instant;
import java.util.List;
import com.influxdb.annotations.Column;
import com.influxdb.annotations.Measurement;
import com.influxdb.client.InfluxDBClient;
import com.influxdb.client.InfluxDBClientFactory;
import com.influxdb.client.WriteApiBlocking;
import com.influxdb.client.domain.WritePrecision;
import com.influxdb.client.write.Point;
import com.influxdb.query.FluxRecord;
import com.influxdb.query.FluxTable;


public class InfluxDB2Example {


    public static void main(final String[] args) {
        // You can generate an API token from the "API Tokens Tab" in the UI
        String token = "mewoGaqs7zFmrd5mnaXTuIAVc0QGPXXXX==";
        String bucket = "buck";
        String org = "orgName";


        InfluxDBClient client = InfluxDBClientFactory.create("http://localhost:8086", token.toCharArray());
        //InfluxDBClient influxDBClient = InfluxDBClientFactory.create("http://localhost:8086", token.toCharArray(), org, bucket);
        //writeApi.writeMeasurement(WritePrecision.NS, temperature);


        //写入数据
        //Option 1: Use InfluxDB Line Protocol to write data
      /* String data = "mem,host=host1 used_percent=23.43234543";
        WriteApiBlocking writeApi = client.getWriteApiBlocking();
        writeApi.writeRecord(bucket, org, WritePrecision.NS, data);
        System.out.println("写入成功");*/
        //Option 2: Use a Data Point to write data  推荐使用
        Point point = Point.measurement("temperature")
                .addTag("location", "west")
                .addField("value", 55D)
                .time(Instant.now(), WritePrecision.NS);
        //WriteOptions writeOptions = WriteOptions.builder()
          //    .batchSize(5000)
          //    .flushInterval(1000)
          //    .bufferLimit(10000)
          //    .jitterInterval(1000)
          //    .retryInterval(5000)
          //    .build();
        //WriteApi writeApi=client.getWriteApi(writeOptions);
        WriteApiBlocking writeApi = client.getWriteApiBlocking();
        writeApi.writePoint(bucket, org, point);
        System.out.println("写入成功");
        //Option 3: Use POJO and corresponding class to write data
        /*Temperature temperature = new Temperature();
        temperature.location = "west";
        temperature.value = 77D;
        temperature.value2=123D;
        temperature.mytime = Instant.now();
        WriteApiBlocking writeApi = client.getWriteApiBlocking();
        writeApi.writeMeasurement(bucket, org, WritePrecision.NS, temperature);
        System.out.println("写入成功");*/


        //查询数据
        /**
        * 查询语法说明
        * 1、bucket 桶
        * 2、range 指定起始时间段
        *    range有两个参数start，stop，stop不设置默认为当前。
        *    range可以是相对的（使用负持续时间）或绝对（使用时间段）
        * 3、filter 过滤条件查询 _measurement 表  _field 字段
        * 4、yield()函数作为查询结果输出过滤的tables。
        */
        //String query = "from(bucket: \"eiss\") |> range(start: -3h)";
        /*String query = "from(bucket: \"eiss\") |> range(start:2022-07-26T02:25:19.060Z, stop:2022-07-26T08:25:19.060Z)" +" |> filter(fn: (r) => r[\"_measurement\"] == \"temperature\")" +" |> filter(fn: (r) => r[\"_field\"] == \"value2\")";
        List<FluxTable> tables =client.getQueryApi().query(query,org);
        for (FluxTable table : tables) {
            for (FluxRecord record : table.getRecords()) {
                if("temperature".equals(record.getMeasurement())){
                    System.out.println(record.getMeasurement());//temperature
                    System.out.println(record.getField());//value2
                    System.out.println(record.getTable());//1
                    System.out.println(record.getValue());//222.0
                    System.out.println(record.getStart());//2022-07-26T02:25:19.060Z
                    System.out.println(record.getStop());//2022-07-26T08:25:19.060Z
                    System.out.println(record);//FluxRecord[table=1, values=9]
                }
            }
        }*/
        //释放资源
        client.close();
    }


    @Measurement(name = "temperature")
    private static class Temperature {
        @Column(tag = true)
        String location;
        @Column
        Double value;
        @Column
        Double value2;
        @Column(timestamp = true)
        Instant mytime;
    }
}

<dependency>
      <groupId>com.influxdb</groupId>
      <artifactId>flux-dsl</artifactId>
      <version>4.2.0</version>
    </dependency>