Conexión con plataformas IoT: ThingsBoard, Blynk, Node-RED

#include <WiFi.h>
#include <ThingsBoard.h>
#include <DHT.h>

// Configuración WiFi
const char* ssid = "TU_WIFI";
const char* password = "TU_PASSWORD";

// Configuración ThingsBoard
const char* tb_server = "thingsboard.cloud";
const char* token = "TU_DEVICE_TOKEN";

// Configuración del sensor DHT22
#define DHT_PIN 4
#define DHT_TYPE DHT22
DHT dht(DHT_PIN, DHT_TYPE);

// Cliente ThingsBoard
WiFiClient espClient;
ThingsBoard tb(espClient);

void setup() {
  Serial.begin(115200);
  dht.begin();
  
  // Conectar a WiFi
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(1000);
    Serial.println("Conectando a WiFi...");
  }
  Serial.println("WiFi conectado");
  
  // Conectar a ThingsBoard
  if (tb.connect(tb_server, token)) {
    Serial.println("Conectado a ThingsBoard");
  }
}

void loop() {
  // Verificar conexión
  if (!tb.connected()) {
    tb.connect(tb_server, token);
  }
  
  // Leer sensores
  float temperatura = dht.readTemperature();
  float humedad = dht.readHumidity();
  
  if (!isnan(temperatura) && !isnan(humedad)) {
    // Enviar telemetría
    tb.sendTelemetryFloat("temperatura", temperatura);
    tb.sendTelemetryFloat("humedad", humedad);
    tb.sendTelemetryInt("timestamp", millis());
    
    Serial.printf("Datos enviados - T: %.2f°C, H: %.2f%%\n", 
                  temperatura, humedad);
  }
  
  tb.loop();
  delay(5000); // Enviar cada 5 segundos
}

#define BLYNK_TEMPLATE_ID "TU_TEMPLATE_ID"
#define BLYNK_TEMPLATE_NAME "ESP32 Sensor Node"
#define BLYNK_AUTH_TOKEN "TU_AUTH_TOKEN"

#include <WiFi.h>
#include <BlynkSimpleEsp32.h>
#include <DHT.h>

// Credenciales
const char* ssid = "TU_WIFI";
const char* password = "TU_PASSWORD";

// Configuración del sensor
#define DHT_PIN 4
#define DHT_TYPE DHT22
#define LED_PIN 2

DHT dht(DHT_PIN, DHT_TYPE);
BlynkTimer timer;

void setup() {
  Serial.begin(115200);
  dht.begin();
  pinMode(LED_PIN, OUTPUT);
  
  // Conectar a Blynk
  Blynk.begin(BLYNK_AUTH_TOKEN, ssid, password);
  
  // Timer para enviar datos cada 10 segundos
  timer.setInterval(10000L, sendSensorData);
}

void loop() {
  Blynk.run();
  timer.run();
}

// Función para enviar datos del sensor
void sendSensorData() {
  float temperatura = dht.readTemperature();
  float humedad = dht.readHumidity();
  
  if (!isnan(temperatura) && !isnan(humedad)) {
    // Enviar a pines virtuales
    Blynk.virtualWrite(V0, temperatura);
    Blynk.virtualWrite(V1, humedad);
    
    Serial.printf("Datos enviados a Blynk - T: %.2f°C, H: %.2f%%\n", 
                  temperatura, humedad);
  }
}

// Control de LED desde Blynk
BLYNK_WRITE(V2) {
  int ledState = param.asInt();
  digitalWrite(LED_PIN, ledState);
  Serial.printf("LED %s desde Blynk\n", ledState ? "ENCENDIDO" : "APAGADO");
}

// Sincronización al conectar
BLYNK_CONNECTED() {
  Serial.println("Conectado a Blynk");
  Blynk.syncVirtual(V2); // Sincronizar estado del LED
}

# Instalar Node.js y npm
sudo apt update && sudo apt install nodejs npm

# Instalar Node-RED globalmente
sudo npm install -g node-red

# Ejecutar Node-RED
node-red

# Acceder a http://localhost:1880

#include <WiFi.h>
#include <PubSubClient.h>
#include <DHT.h>
#include <ArduinoJson.h>

// Configuración WiFi
const char* ssid = "TU_WIFI";
const char* password = "TU_PASSWORD";

// Configuración MQTT (Broker local o HiveMQ)
const char* mqtt_server = "192.168.1.100"; // IP de tu servidor Node-RED
const int mqtt_port = 1883;
const char* mqtt_user = ""; // Usuario MQTT (opcional)
const char* mqtt_password = ""; // Password MQTT (opcional)

// Tópicos MQTT
const char* topic_data = "esp32/sensores";
const char* topic_control = "esp32/control";

// Configuración del sensor
#define DHT_PIN 4
#define DHT_TYPE DHT22
#define LED_PIN 2

DHT dht(DHT_PIN, DHT_TYPE);
WiFiClient espClient;
PubSubClient client(espClient);

void setup() {
  Serial.begin(115200);
  dht.begin();
  pinMode(LED_PIN, OUTPUT);
  
  // Conectar WiFi
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(1000);
    Serial.println("Conectando a WiFi...");
  }
  
  // Configurar MQTT
  client.setServer(mqtt_server, mqtt_port);
  client.setCallback(onMqttMessage);
  
  Serial.println("Sistema iniciado");
}

void loop() {
  if (!client.connected()) {
    reconnectMQTT();
  }
  client.loop();
  
  // Enviar datos cada 10 segundos
  static unsigned long lastSend = 0;
  if (millis() - lastSend > 10000) {
    sendSensorData();
    lastSend = millis();
  }
}

void sendSensorData() {
  float temperatura = dht.readTemperature();
  float humedad = dht.readHumidity();
  
  if (!isnan(temperatura) && !isnan(humedad)) {
    // Crear JSON
    StaticJsonDocument<200> doc;
    doc["dispositivo"] = "ESP32-001";
    doc["temperatura"] = temperatura;
    doc["humedad"] = humedad;
    doc["timestamp"] = millis();
    
    char buffer[256];
    serializeJson(doc, buffer);
    
    // Publicar datos
    client.publish(topic_data, buffer);
    Serial.printf("Datos enviados: %s\n", buffer);
  }
}

void onMqttMessage(char* topic, byte* payload, unsigned int length) {
  String message = "";
  for (int i = 0; i < length; i++) {
    message += (char)payload[i];
  }
  
  Serial.printf("Mensaje recibido [%s]: %s\n", topic, message.c_str());
  
  // Control del LED
  if (String(topic) == topic_control) {
    if (message == "LED_ON") {
      digitalWrite(LED_PIN, HIGH);
      Serial.println("LED encendido");
    } else if (message == "LED_OFF") {
      digitalWrite(LED_PIN, LOW);
      Serial.println("LED apagado");
    }
  }
}

void reconnectMQTT() {
  while (!client.connected()) {
    Serial.print("Conectando a MQTT...");
    
    String clientId = "ESP32Client-" + String(random(0xffff), HEX);
    
    if (client.connect(clientId.c_str(), mqtt_user, mqtt_password)) {
      Serial.println("conectado");
      client.subscribe(topic_control);
    } else {
      Serial.printf("falló, rc=%d, reintentando en 5 segundos\n", client.state());
      delay(5000);
    }
  }
}