# InfluxDB 獨(dú)立配置
influxdb:
  url: http://192.168.1.1xx:28086/  # InfluxDB 服務(wù)器地址
  token: _7FZlXGJJcd8Ayox-F-hVBDdXb_a5SI3530x1DdFKZfQ65uOhnpQciJWHpd7ULhpAOcgj5oV2JsR-Xf0qTtAxg==
  org: xxx     # 組織名稱(chēng)
  bucket: xxx  # 存儲(chǔ)桶名稱(chēng)
  # InfluxDB 客戶端日志級(jí)別
  # ERROR: 僅記錄錯(cuò)誤日志
  # WARN: 記錄警告和錯(cuò)誤日志
  # INFO: 記錄普通信息、警告和錯(cuò)誤日志
  # DEBUG: 記錄調(diào)試級(jí)別的詳細(xì)日志
  # BODY: 記錄完整的 HTTP 請(qǐng)求和響應(yīng)主體
  # TRACE: 記錄極其詳細(xì)的跟蹤日志
  # ALL: 記錄所有日志級(jí)別（視客戶端而定）
  logLevel: BODY

import com.influxdb.client.InfluxDBClient;
import com.influxdb.client.InfluxDBClientFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
@Configuration
public class InfluxDBConfig {
 
    @Value("${influxdb.url}")
    private String url;
 
    @Value("${influxdb.token}")
    private String token;
 
    @Value("${influxdb.org}")
    private String org;
 
    @Value("${influxdb.bucket}")
    private String bucket;
 
    @Bean
    public InfluxDBClient influxDBClient() {
        return InfluxDBClientFactory.create(url, token.toCharArray(), org, bucket);
    }
}

public void writeSingleData(TemperatureDTO temperatureDTO) {
    WriteApiBlocking writeApi = influxDBClient.getWriteApiBlocking();
    
    Point point = Point.measurement("temperature")
            .addTag("location", temperatureDTO.getLocation()) // 添加標(biāo)簽（索引）
            .addField("value", temperatureDTO.getValue()) // 添加字段（數(shù)據(jù)）
            .time(Instant.now(), WritePrecision.NS); // 記錄當(dāng)前時(shí)間戳
 
    writeApi.writePoint(point);
}

public void writeBatchData(List<TemperatureDTO> temperatureDTOs) {
    WriteApi writeApi = influxDBClient.makeWriteApi(); // 獲取異步 API
 
    List<Point> points = temperatureDTOs.stream()
            .map(dto -> Point.measurement("temperature")
                    .addTag("location", dto.getLocation())
                    .addField("value", dto.getValue())
                    .time(Instant.now(), WritePrecision.NS))
            .collect(Collectors.toList());
 
    CompletableFuture<Void> future = CompletableFuture.runAsync(() -> writeApi.writePoints(points));
    future.whenComplete((result, error) -> {
        if (error != null) {
            System.err.println("?? 寫(xiě)入失敗：" + error.getMessage());
        } else {
            writeApi.close();  // 關(guān)閉 API 避免資源泄露
            log.info("? 批量數(shù)據(jù)寫(xiě)入成功（異步）");
        }
    });
}

public List<TemperatureVO> queryTemperatureData() {
    String query = "from(bucket: \"test\") |> range(start: -1h)";
    QueryApi queryApi = influxDBClient.getQueryApi();
 
    return queryApi.query(query)
            .stream()
            .flatMap(fluxTable -> fluxTable.getRecords().stream()) // 遍歷 FluxTable
            .map(record -> {
                TemperatureVO vo = new TemperatureVO();
                vo.setLocation((String) record.getValueByKey("location")); // 獲取標(biāo)簽信息
                Object valueObj = record.getValueByKey("_value");
                vo.setValue(valueObj != null ? ((Number) valueObj).doubleValue() : 0.0);
                vo.setTimestamp(record.getTime().toString());
                return vo;
            })
            .collect(Collectors.toList());
}

@RestController
@RequestMapping("/api/influxdb")
public class InfluxDBController {
 
    @Autowired
    private TestService influxDBService;
 
    @PostMapping("/write")
    public String writeData(@RequestBody TemperatureDTO temperatureDTO) {
        influxDBService.writeSingleData(temperatureDTO);
        return "? 單條數(shù)據(jù)寫(xiě)入成功！";
    }
 
    @PostMapping("/write-batch")
    public String writeBatchData() {
        List<TemperatureDTO> data = generateTestData(10000);
        influxDBService.writeBatchData(data);
        return "? 10,000 條數(shù)據(jù)成功寫(xiě)入！";
    }
 
    @GetMapping("/query")
    public List<TemperatureVO> queryTemperatureData() {
        return influxDBService.queryTemperatureData();
    }
 
    private List<TemperatureDTO> generateTestData(int count) {
        List<TemperatureDTO> dataList = new ArrayList<>();
        Random random = new Random();
        for (int i = 0; i < count; i++) {
            TemperatureDTO dto = new TemperatureDTO();
            dto.setLocation("office-" + (random.nextInt(1000) + 1));
            dto.setValue(15 + (random.nextDouble() * 10));
            dataList.add(dto);
        }
        return dataList;
    }
}

mvn spring-boot:run 

{
  "location": "office-1",
  "value": 22.5
}