【Follow me第二季第2期】传感器数据上传到HA

qzc飘曳

【Follow me第二季第2期】传感器数据上传到HA [复制链接]

咱们已经实现了开发板和HA之间的程序，接下来我们就要实现传感器数据的采集，本次一共采购了两个传感器，也就是光照和环境传感器。

实际上两个扩展任务基本上是一致，也就是说模式都是采集传感器数据然后传输到HA，由于传感器的不同，我们需要再建立一个光照数据的设备和实体：

homeassistant/sensor/sensorLTR-329/config

{
    "name":"LTR-329",
    "state_topic":"homeassistant/sensor/sensorLTR-329/state",
"value_template":"{{ value_json.LTR}}",
    "unique_id":"LTR-329",
    "device":{
        "identifiers":[
            "LTR-329"
        ],
        "name":"LTR-329-Sensor",
        "manufacturer": "Arduino",
        "model": "UNO R4 WiFi"
    }
}

接下来实现传感器数据的采集，并通过串口打印：

这里我们需要安装两个库文件及其依赖的基础库：

#include "Adafruit_SHT4x.h"
#include "Adafruit_LTR329_LTR303.h"
Adafruit_SHT4x sht4;
Adafruit_LTR329 ltr = Adafruit_LTR329();
void setup() {
  // put your setup code here, to run once:
  Serial.begin(115200);
  while (!Serial) {
    ; // wait for serial port to connect. Needed for native USB port only
  }
  if ( ! ltr.begin(&Wire1) ) {
    Serial.println("Couldn't find LTR sensor!");
    while (1) delay(10);
  }
  Serial.println("Found LTR sensor!");
  ltr.setGain(LTR3XX_GAIN_2);
  Serial.print("Gain : ");
  switch (ltr.getGain()) {
    case LTR3XX_GAIN_1: Serial.println(1); break;
    case LTR3XX_GAIN_2: Serial.println(2); break;
    case LTR3XX_GAIN_4: Serial.println(4); break;
    case LTR3XX_GAIN_8: Serial.println(8); break;
    case LTR3XX_GAIN_48: Serial.println(48); break;
    case LTR3XX_GAIN_96: Serial.println(96); break;
  }
  ltr.setIntegrationTime(LTR3XX_INTEGTIME_100);
  Serial.print("Integration Time (ms): ");
  switch (ltr.getIntegrationTime()) {
    case LTR3XX_INTEGTIME_50: Serial.println(50); break;
    case LTR3XX_INTEGTIME_100: Serial.println(100); break;
    case LTR3XX_INTEGTIME_150: Serial.println(150); break;
    case LTR3XX_INTEGTIME_200: Serial.println(200); break;
    case LTR3XX_INTEGTIME_250: Serial.println(250); break;
    case LTR3XX_INTEGTIME_300: Serial.println(300); break;
    case LTR3XX_INTEGTIME_350: Serial.println(350); break;
    case LTR3XX_INTEGTIME_400: Serial.println(400); break;
  }
  ltr.setMeasurementRate(LTR3XX_MEASRATE_200);
  Serial.print("Measurement Rate (ms): ");
  switch (ltr.getMeasurementRate()) {
    case LTR3XX_MEASRATE_50: Serial.println(50); break;
    case LTR3XX_MEASRATE_100: Serial.println(100); break;
    case LTR3XX_MEASRATE_200: Serial.println(200); break;
    case LTR3XX_MEASRATE_500: Serial.println(500); break;
    case LTR3XX_MEASRATE_1000: Serial.println(1000); break;
    case LTR3XX_MEASRATE_2000: Serial.println(2000); break;
  }
  sht4.setPrecision(SHT4X_HIGH_PRECISION);
  switch (sht4.getPrecision()) {
     case SHT4X_HIGH_PRECISION:
       Serial.println(F("SHT40 set to High precision"));
       break;
     case SHT4X_MED_PRECISION:
       Serial.println(F("SHT40 set to Medium precision"));
       break;
     case SHT4X_LOW_PRECISION:
       Serial.println(F("SHT40 set to Low precision"));
       break;
  }
  sht4.setHeater(SHT4X_NO_HEATER);
  switch (sht4.getHeater()) {
     case SHT4X_NO_HEATER:
       Serial.println(F("SHT40 Heater turned OFF"));
       break;
     case SHT4X_HIGH_HEATER_1S:
       Serial.println(F("SHT40 Heater: High heat for 1 second"));
       break;
     case SHT4X_HIGH_HEATER_100MS:
       Serial.println(F("SHT40 Heater: High heat for 0.1 second"));
       break;
     case SHT4X_MED_HEATER_1S:
       Serial.println(F("SHT40 Heater: Medium heat for 1 second"));
       break;
     case SHT4X_MED_HEATER_100MS:
       Serial.println(F("SHT40 Heater: Medium heat for 0.1 second"));
       break;
     case SHT4X_LOW_HEATER_1S:
       Serial.println(F("SHT40 Heater: Low heat for 1 second"));
       break;
     case SHT4X_LOW_HEATER_100MS:
       Serial.println(F("SHT40 Heater: Low heat for 0.1 second"));
       break;
  }  
  if (! sht4.begin(&Wire1)) {
    Serial.println(F("SHT40 sensor not found!"));
    while (1) ;
  }
   else
  {
    Serial.print(F("SHT40 detected!\t"));
    Serial.print(F("Serial number:\t"));
    Serial.println(sht4.readSerial(), HEX);    
  }
}
void loop() {
  // put your main code here, to run repeatedly:
  bool valid;
  uint16_t visible_plus_ir, infrared;
  if (ltr.newDataAvailable()) {
    valid = ltr.readBothChannels(visible_plus_ir, infrared);
    if (valid) {
      Serial.print("CH0 Visible + IR: ");
      Serial.print(visible_plus_ir);
      Serial.print("\t\tCH1 Infrared: ");
      Serial.println(infrared);
    }
  }
  sensors_event_t humidity, temp;
  sht4.getEvent(&humidity, &temp);// populate temp and humidity objects with fresh data
  float tem = temp.temperature;
  Serial.println("Temp *C = " + String(tem));
  float hum = humidity.relative_humidity;
  Serial.println("Hum. % = " + String(hum));
  delay(1000);
}

可以看到结果如下：

接下来将数据与物联网HA系统进行融合显示：

 dataObj["cnt"] = count;
    dataObj["hum"] = hum;
    dataObj["tem"] = tem;
    String jsonString1 = JSON.stringify(dataObj);
    mqttClient.beginMessage(state_topic1);
    mqttClient.print(jsonString1);
    mqttClient.endMessage();
    dataObj["LTR"] = visible_plus_ir;
    String jsonString2 = JSON.stringify(dataObj);
    mqttClient.beginMessage(state_topic2);
    mqttClient.print(jsonString2);
    mqttClient.endMessage();

效果可以查看最终的效果展示视频的扩展任务部分。

最终的视频展示：

https://training.eeworld.com.cn/course/68650/learn?preview=1#lesson/41079

得捷电子Follow Me第二季第2期视频展示