Emonlib with MQTT

Emonlib with MQTT

I have an ESP32, a DHT11 and a ZMP101B. I'm trying to use the EmonLib library to read the voltage of the ZMP101B. I can do the voltage reading when I don't implement the MQTT part, but when I implement the MQTT part, it stops reading the voltage.. the voltage is at "0V".. the dht readings are still normal.
The same is true for other IoT platforms.
  2. #include <stdio.h>
  3. #include <WiFi.h>
  4. #include <PubSubClient.h>
  5. #include <ArduinoJson.h>
  6. #include <DHT.h>
  7. #include <EmonLib.h>

  9. #define VOLT_CAL    85             // voltage calib


  12. // MQTT definitions
  13. #define MQTT_PUB_TOPIC "tago/data/post"
  14. #define MQTT_USERNAME  "test"                                     // any value
  15. #define MQTT_PASSWORD  "66534b39-c363-41f8-b665-fd644a2423c9"     // Device Token TagoIO

  17. // WIFI
  18. const char* ssid_wifi = "AndroidAP";            // WI-FI network SSID
  19. const char* password_wifi = "cett0940";         // WI-FI network password
  20. WiFiClient espClient;     

  22. // MQTT
  23. const char* broker_mqtt = "mqtt.tago.io";       // MQTT broker URL
  24. int broker_port = 1883;                         // MQTT broker port
  25. PubSubClient MQTT(espClient); 


  28. DHT dht(25, DHT11);                             // (pin, type DHT)
  29. EnergyMonitor emon5;                            // instance emon

  31. //Prototypes
  32. void init_wifi(void);
  33. void init_MQTT(void);
  34. void connect_MQTT(void);
  35. void connect_wifi(void);
  36. void send_data_iot_platform(void);

  38. unsigned long millis_Time = millis();
  39. float temperature_read;
  40. float humidity_read;
  41. double voltage_read;

  43. void setup() {
  44.     
  45.     Serial.begin(115200);            
  46.     dht.begin();                          // init DHT
  47.     init_wifi();                          // func init wifi
  48.     init_MQTT();                          // func init mqtt
  49.     connect_MQTT();                       // func connect mqtt
  50.     emon5.voltage(26, VOLT_CAL, 1.7);     // voltage (pin analóg, calib, fase change)
  51.     
  52.     delay(500);
  53. }

  55. void loop() {
  56.     connect_wifi();                   // verify wi-fi
  57.     connect_MQTT();                   // verify MQTT
  58.     send_data_iot_platform();         // send data to TagoIO)
  59.    
  60. }


  63. // Func init wi-fi
  64. void init_wifi(void)  {
  65.     delay(10);
  66.     Serial.println();
  67.     Serial.println("------ WI-FI -----");
  68.     Serial.print("Connecting to Wifi: ");
  69.     Serial.println(ssid_wifi);
  70.     connect_wifi();
  71. }

  73. // Func connect to wifi
  74. void connect_wifi(void){
  75.     if (WiFi.status() == WL_CONNECTED)
  76.         return;
  77.     WiFi.begin(ssid_wifi, password_wifi);
  78.     while (WiFi.status() != WL_CONNECTED){
  79.         WiFi.begin(ssid_wifi, password_wifi);
  80.         delay(3000);
  81.         Serial.print(".");
  82.     }
  83.   
  84.     Serial.println();
  85.     Serial.print("Successful connection to Wifi network: ");
  86.     Serial.println(ssid_wifi);
  87.     Serial.print("IP: ");
  88.     Serial.println(WiFi.localIP());
  89.     Serial.println("---------------");
  90. }

  92. // Func init MQTT
  93. void init_MQTT(void)  {
  94.     MQTT.setServer(broker_mqtt, broker_port);
  95. }

  97. // Func conect to MQTT
  98. void connect_MQTT(void){
  99.     char mqtt_id_randomico[5] = {0};
  100.     while (!MQTT.connected()){
  101.         Serial.print("Connecting to MQTT: ");
  102.         Serial.println(broker_mqtt);

  104.         /* id mqtt random */
  105.         randomSeed(random(9999));
  106.         sprintf(mqtt_id_randomico, "%ld", random(9999));
  107.         
  108.         if (MQTT.connect(mqtt_id_randomico, MQTT_USERNAME, MQTT_PASSWORD)){
  109.             Serial.println("Successful connection to MQTT");
  110.             Serial.println("----------");
  111.         } 
  112.         else{
  113.             Serial.println("Failed to connect to MQTT...");
  114.             Serial.println("Retry in 5s...");
  115.             delay(5000);
  116.         }
  117.     }
  118. }


  121. // Func send data to TagoIO (MQTT)
  122. void send_data_iot_platform(void){


  125.     temperature_read = dht.readTemperature();
  126.     humidity_read = dht.readHumidity();
  127.     emon5.calcVI(10,100);
  128.     voltage_read = emon5.Vrms;
  129.     //voltage_read = 127;

  131. if((millis() - millis_Time) > 3000) {
  132.   
  133.     Serial.print("Temp: ");
  134.     Serial.print(temperature_read,1);
  135.     Serial.print("°C;\t");
  136.     Serial.print("Humidity: ");
  137.     Serial.print(humidity_read,0);
  138.     Serial.print("%\t");
  139.     Serial.print("Voltage: ");
  140.     Serial.print(voltage_read,1);
  141.     Serial.println("V");
  142.  
  143.  

  145.     // send temperature 
  146.     char temperature[250] = {0};
  147.     StaticJsonDocument <250> tago_json_temperature;
  148.     tago_json_temperature["variable"] = "temperature";
  149.     tago_json_temperature["unit"] = "C";
  150.     tago_json_temperature["value"] = temperature_read;
  151.     memset(temperature, 0, sizeof(temperature));
  152.     serializeJson(tago_json_temperature, temperature);
  153.     MQTT.publish(MQTT_PUB_TOPIC, temperature);

  155.     // send humidity
  156.     char humidity[250] = {0};
  157.     StaticJsonDocument <250> tago_json_humidity;
  158.     tago_json_humidity["variable"] = "humidity";
  159.     tago_json_humidity["unit"] = "%";
  160.     tago_json_humidity["value"] = humidity_read;
  161.     memset(humidity, 0, sizeof(humidity));
  162.     serializeJson(tago_json_humidity, humidity);
  163.     MQTT.publish(MQTT_PUB_TOPIC, humidity);


  166.     // send voltage
  167.     char voltage[250] = {0};
  168.     StaticJsonDocument <250> tago_json_voltage;
  169.     tago_json_voltage["variable"] = "voltage";
  170.     tago_json_voltage["unit"] = "V";
  171.     tago_json_voltage["value"] = voltage_read;
  172.     memset(voltage, 0, sizeof(voltage));
  173.     serializeJson(tago_json_voltage, voltage);
  174.     MQTT.publish(MQTT_PUB_TOPIC, voltage);
  175.    
  176.     millis_Time = millis();
  177.   }   
  178. }