ESP32接入InfluxDB：JSON存储的Bucket与Token配置生效问题

核心问题排查方向 #

先从这几个最容易踩坑的点检查：

• SPIFFS挂载/文件读取失败：很多时候是SPIFFS没挂载成功，或者配置文件压根没创建出来
• JSON解析错误：键名写错、内存分配不够，都会导致读不出正确的Bucket和Token
• 变量作用域问题：如果存配置的变量是局部的，InfluxDB客户端初始化时根本拿不到值
• 初始化顺序错误：在没读到配置前就初始化InfluxDB客户端，自然用的是空值或默认值

修复后的完整代码 #

#include <WiFiManager.h>
#include <SPIFFS.h>
#include <ArduinoJson.h>
#include <InfluxDbClient.h>
#include <InfluxDbCloud.h>

// 全局变量存InfluxDB配置，确保全代码可访问
String influxBucket;
String influxToken;
// 如果Org和URL也需要配置，直接加到JSON里就行
const char* influxOrg = "你的组织名";
const char* influxUrl = "你的InfluxDB地址";

// 用指针延迟初始化InfluxDB客户端，避免提前创建空配置实例
InfluxDBClient* influxClient = nullptr;

void setup() {
  Serial.begin(115200);

  // 初始化SPIFFS，true表示挂载失败时自动格式化（第一次运行必备）
  if (!SPIFFS.begin(true)) {
    Serial.println("SPIFFS挂载失败，尝试格式化...");
    if (!SPIFFS.begin()) {
      Serial.println("格式化后还是挂不上，程序终止");
      while(1);
    }
  }

  // 先读配置，再启动WiFi配网
  readInfluxConfig();

  // 配置WiFiManager自定义参数
  WiFiManager wm;
  WiFiManagerParameter custom_bucket("bucket", "InfluxDB Bucket", influxBucket.c_str(), 64);
  WiFiManagerParameter custom_token("token", "InfluxDB Token", influxToken.c_str(), 256);
  wm.addParameter(&custom_bucket);
  wm.addParameter(&custom_token);

  // 自动连WiFi，失败则开配网热点
  if (!wm.autoConnect("ESP32-Influx-Setup")) {
    Serial.println("WiFi连不上，重启重试");
    ESP.restart();
    delay(1000);
  }

  // 配网后检查配置是否变化，有变化才保存（减少SPIFFS写入次数）
  String newBucket = custom_bucket.getValue();
  String newToken = custom_token.getValue();
  if (newBucket != influxBucket || newToken != influxToken) {
    influxBucket = newBucket;
    influxToken = newToken;
    saveInfluxConfig();
  }

  // 现在有了正确配置，初始化InfluxDB客户端
  initInfluxClient();

  // 验证InfluxDB连接状态
  if (influxClient->validateConnection()) {
    Serial.print("InfluxDB连成功了！组织名：");
    Serial.println(influxOrg);
  } else {
    Serial.print("InfluxDB连不上，错误信息：");
    Serial.println(influxClient->getLastErrorMessage());
  }
}

void loop() {
  // 这里写你的数据上传逻辑，先判断客户端是否初始化成功
  if (influxClient) {
    Point point("sensor_data");
    point.addField("value", random(0, 100)); // 示例数据
    if (!influxClient->writePoint(point)) {
      Serial.print("数据上传失败：");
      Serial.println(influxClient->getLastErrorMessage());
    }
  }
  delay(5000);
}

// 从SPIFFS读InfluxDB配置
void readInfluxConfig() {
  File file = SPIFFS.open("/influx_config.json", "r");
  if (!file) {
    Serial.println("没找到配置文件，用默认值");
    influxBucket = "默认Bucket名";
    influxToken = "默认Token";
    return;
  }

  StaticJsonDocument<512> doc;
  DeserializationError error = deserializeJson(doc, file);
  if (error) {
    Serial.print("JSON解析出错：");
    Serial.println(error.c_str());
    influxBucket = "默认Bucket名";
    influxToken = "默认Token";
    file.close();
    return;
  }

  // 把JSON里的值赋值给全局变量
  influxBucket = doc["bucket"].as<String>();
  influxToken = doc["token"].as<String>();
  file.close();
  Serial.println("配置读取成功");
}

// 把配置写到SPIFFS
void saveInfluxConfig() {
  File file = SPIFFS.open("/influx_config.json", "w");
  if (!file) {
    Serial.println("打不开配置文件，保存失败");
    return;
  }

  StaticJsonDocument<512> doc;
  doc["bucket"] = influxBucket;
  doc["token"] = influxToken;

  if (serializeJson(doc, file) == 0) {
    Serial.println("配置写入失败");
  } else {
    Serial.println("配置保存成功");
  }
  file.close();
}

// 初始化InfluxDB客户端
void initInfluxClient() {
  // 如果之前有实例，先删掉避免内存泄漏
  if (influxClient) {
    delete influxClient;
  }
  // 用读取到的全局配置创建客户端
  influxClient = new InfluxDBClient(influxUrl, influxOrg, influxBucket, influxToken);
  // 可选：设置连接超时
  influxClient->setConnectionTimeout(10000);
}

关键修改说明 #

1. 全局变量存储配置：把influxBucket和influxToken设为全局，确保后续初始化InfluxDB客户端时能拿到值
2. 延迟初始化客户端：用指针influxClient，等配置读取完成后再创建实例，避免用空配置初始化
3. SPIFFS异常处理：增加挂载失败、文件不存在、JSON解析错误的处理逻辑，给默认值保证程序能跑
4. 配置变更检查：只有配网时修改了配置才写入SPIFFS，减少闪存写入次数，延长寿命
5. 连接验证：增加validateConnection()检查，方便快速排查InfluxDB连接问题

内容的提问来源于stack exchange，提问作者ndeegan