docker stop influxdb &&
docker rm influxdb &&
docker run -dit --name influxdb
-p 8085:8086
-v /var/influxdb:/var/lib/influxdb
-e DOCKER_INFLUXDB_INIT_MODE=setup
-e DOCKER_INFLUXDB_INIT_USERNAME=stallonely
-e DOCKER_INFLUXDB_INIT_PASSWORD=stallonely
-e DOCKER_INFLUXDB_INIT_ORG=kxy
-e DOCKER_INFLUXDB_INIT_BUCKET=ecg
-e TZ=Asia/Shanghai
–restart always --privileged=true influxdb:latest

参考文档：https://www.jianshu.com/p/268fca65f10e

    SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss'Z'");

    String flux = "from(bucket: \"ecg\")\n" +
            "  |> range(start: " + simpleDateFormat.format(diagnose.getStartTime()) + ",stop:" + simpleDateFormat.format(diagnose.getEndTime()) + ")\n" +
            "  |> filter(fn:(r)=>(r._measurement==\"ecg_data\"))\n" +
            "  |> filter(fn:(r)=>(r.diagnoseId==\"" + diagnose.getId() + "\"))";

// // 异步查询
// influxDBClient.getQueryApi().query(flux, ECGData.class,
// (cancellable, fluxRecord) -> {
// System.out.println(“Query Data===>” + fluxRecord);
// },
// throwable -> {
// System.out.println(“Query Data Error”);
// },
// () -> {
// System.out.println(“Query Data complete”);
// });

    System.out.println("start===>" + DateUtil.formatTime(new Date()));
    // 同步查询
    List<ECGData> ecgDatas = influxDBClient.getQueryApi().query(flux, ECGData.class);
    System.out.println("end===>" + DateUtil.formatTime(new Date()));

Q.E.D.