Dashboard Monitoring Real-time: Node-RED + Grafana + MQTT

# Update repository
sudo apt update

# Instal Mosquitto broker dan client
sudo apt install -y mosquitto mosquitto-cliences

# Verifikasi versi
mosquitto -v

# Konfigurasi Mosquitto Broker
# /etc/mosquitto/mosquitto.conf

# Listener MQTT (tanpa TLS)
listener 1883

# Listener MQTTS (dengan TLS)
listener 8883
certfile /etc/mosquitto/certs/server.crt
keyfile /etc/mosquitto/certs/server.key
cafile /etc/mosquitto/certs/ca.crt

# Otentikasi (WAJIB untuk produksi)
allow_anonymous false
password_file /etc/mosquitto/passwd

# Persistence untuk message retain
persistence true
persistence_location /var/lib/mosquitto/

# Interval autosave (detik)
autosave_interval 300

# Logging
log_dest syslog
log_type error
log_type warning
log_type notice
log_type information
connection_messages true
log_timestamp true

# Buat file password (jika belum ada)
sudo mosquitto_passwd -c /etc/mosquitto/passwd iotuser

# Tambah user tambahan
sudo mosquitto_passwd -b /etc/mosquitto/passwd iotadmin admin123

# Restart Mosquitto
sudo systemctl restart mosquitto

# Cek status
sudo systemctl status mosquitto

# Subscribe ke topik sensor
mosquitto_sub -h localhost -t "iot/sensor/+" -u iotuser -P iotpass

# Subscribe dengan verbose output
mosquitto_sub -h localhost -t "iot/#" -v -u iotuser -P iotpass

# Publish data suhu
mosquitto_pub -h localhost -t "iot/sensor/suhu_ruang1" \
  -m '{"suhu":28.5,"kelembaban":72.0,"ts":1718800000}' \
  -u iotuser -P iotpass

# Instalasi Node-RED (global)
sudo npm install -g --unsafe-perm node-red

# Install flow untuk InfluxDB
cd ~/.node-red
npm install node-red-contrib-influxdb

# Jalankan Node-RED
node-red

[
    {
        "id": "mqtt_in_suhu",
        "type": "mqtt in",
        "name": "MQTT: Sensor Suhu",
        "topic": "iot/sensor/+",
        "qos": "1",
        "datatype": "json",
        "broker": "mqtt_broker_01",
        "wires": [["parse_json"]]
    },
    {
        "id": "parse_json",
        "type": "function",
        "name": "Parse & Validasi Data",
        "func": "var data = msg.payload;\n\n// Validasi field wajib\nif (!data.suhu || !data.kelembaban) {\n    node.warn('Data tidak lengkap: ' + JSON.stringify(data));\n    return null;\n}\n\n// Parse topik untuk device_id\nvar parts = msg.topic.split('/');\nvar deviceId = parts[parts.length - 1];\n\n// Buat payload untuk InfluxDB\nmsg.payload = [\n    {\n        measurement: 'sensor_reading',\n        tags: {\n            device_id: deviceId,\n            location: 'ruang_server'\n        },\n        fields: {\n            suhu: parseFloat(data.suhu),\n            kelembaban: parseFloat(data.kelembaban),\n            wifi_rssi: parseInt(data.wifi_rssi) || 0\n        }\n    }\n];\n\nmsg.topic = '';\nreturn msg;",
        "wires": [["influx_out"]]
    },
    {
        "id": "influx_out",
        "type": "influxdb out",
        "name": "Tulis ke InfluxDB",
        "influxdb": "influxdb_config",
        "precision": "",
        "retentionPolicy": "",
        "database": "",
        "precision": "ms",
        "retentionPolicy": "",
        "wires": []
    },
    {
        "id": "influxdb_config",
        "type": "influxdb",
        "hostname": "127.0.0.1",
        "port": "8086",
        "protocol": "http",
        "dbname": "",
        "name": "InfluxDB Local",
        "usetls": false,
        "tls": "",
        "influxdbVersion": "2.0",
        "url": "http://127.0.0.1:8086",
        "rejectUnauthorized": true
    },
    {
        "id": "mqtt_broker_01",
        "type": "mqtt-broker",
        "name": "Mosquitto Local",
        "broker": "127.0.0.1",
        "port": "1883",
        "clientid": "nodered_client",
        "autoConnect": true,
        "usetls": false,
        "keepalive": "60",
        "cleansession": true,
        "autoUnsubscribe": true,
        "birthTopic": "nodered/status",
        "birthQos": "0",
        "birthPayload": "online",
        "closeTopic": "",
        "closeQos": "0",
        "closePayload": "",
        "willTopic": "nodered/status",
        "willQos": "0",
        "willPayload": "offline",
        "sessionExpiry": ""
    }
]

# Import GPG key
curl https://repos.influxdata.com/influxdata-archive_compat.key | \
  gpg --dearmor | \
  sudo tee /etc/apt/trusted.gpg.d/influxdata-archive_compat.gpg > /dev/null

# Tambah repository
echo "deb [signed-by=/etc/apt/trusted.gpg.d/influxdata-archive_compat.gpg] \
  https://repos.influxdata.com/debian stable main" | \
  sudo tee /etc/apt/sources.list.d/influxdata.list

sudo apt update
sudo apt install -y influxdb2

# Jalankan InfluxDB
sudo systemctl enable influxdb
sudo systemctl start influxdb

# Setup awal InfluxDB
influx setup \
  --username admin \
  --password MySecurePass123! \
  --org iotlab \
  --bucket iot_sensors \
  --retention 720h \
  --force

# Simpan token (ganti dengan token dari setup)
influx auth create \
  --org iotlab \
  --description "Node-RED write access" \
  --write-bucket iot_sensors

// Query rata-rata suhu 1 jam terakhir
from(bucket: "iot_sensors")
  |> range(start: -1h)
  |> filter(fn: (r) => r._measurement == "sensor_reading")
  |> filter(fn: (r) => r._field == "suhu")
  |> aggregateWindow(every: 5m, fn: mean)
  |> yield(name: "avg_suhu")

// Query suhu maksimum hari ini
from(bucket: "iot_sensors")
  |> range(start: -24h)
  |> filter(fn: (r) => r._measurement == "sensor_reading")
  |> filter(fn: (r) => r._field == "suhu")
  |> max()

// Query jumlah data per device
from(bucket: "iot_sensors")
  |> range(start: -1h)
  |> filter(fn: (r) => r._measurement == "sensor_reading")
  |> group(columns: ["device_id"])
  |> count()

# Tambah repository Grafana
sudo apt-get install -y apt-transport-https software-properties-common
wget -q -O - https://apt.grafana.com/gpg.key | sudo apt-key add -
echo "deb [signed-by=/usr/share/keyrings/grafana.gpg] \
  https://apt.grafana.com stable main" | \
  sudo tee /etc/apt/sources.list.d/grafana.list

sudo apt update
sudo apt install -y grafana

# Jalankan Grafana
sudo systemctl enable grafana-server
sudo systemctl start grafana-server

// Panel: Grafik Suhu Real-time (6 jam terakhir)
from(bucket: "iot_sensors")
  |> range(start: -6h)
  |> filter(fn: (r) => r._measurement == "sensor_reading")
  |> filter(fn: (r) => r._field == "suhu")
  |> aggregateWindow(every: 5m, fn: mean, createEmpty: false)
  |> yield(name: "suhu_trend")

// Panel: Gauge Suhu Terkini
from(bucket: "iot_sensors")
  |> range(start: -1h)
  |> filter(fn: (r) => r._measurement == "sensor_reading")
  |> filter(fn: (r) => r._field == "suhu")
  |> last()
  |> yield(name: "suhu_current")

// Panel: Tabel Status Semua Device
from(bucket: "iot_sensors")
  |> range(start: -1h)
  |> filter(fn: (r) => r._measurement == "sensor_reading")
  |> last()
  |> pivot(rowKey: ["_time"], columnKey: ["_field"], valueColumn: "_value")
  |> keep(columns: ["device_id", "suhu", "kelembaban", "_time"])

#include "WiFi.h"
#include "PubSubClient.h"
#include "DHT.h"

#define DHT_PIN 4
#define DHT_TYPE DHT22

const char* WIFI_SSID = "NamaWiFi";
const char* WIFI_PASS = "PasswordWiFi";
const char* MQTT_SERVER = "192.168.1.100";
const int   MQTT_PORT = 1883;
const char* MQTT_TOPIC = "iot/sensor/esp32_01";

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

void setup() {
  Serial.begin(115200);
  dht.begin();
  WiFi.begin(WIFI_SSID, WIFI_PASS);
  while (WiFi.status() != WL_CONNECTED) delay(500);
  mqtt.setServer(MQTT_SERVER, MQTT_PORT);
}

void loop() {
  if (!mqtt.connected()) {
    mqtt.connect("esp32_01", "iotuser", "iotpass");
  }
  mqtt.loop();

  float suhu = dht.readTemperature();
  float rh = dht.readHumidity();
  if (!isnan(suhu) && !isnan(rh)) {
    char payload[128];
    snprintf(payload, sizeof(payload),
      "{\"suhu\":%.1f,\"kelembaban\":%.1f,\"rssi\":%d}",
      suhu, rh, WiFi.RSSI());
    mqtt.publish(MQTT_TOPIC, payload);
    Serial.println(payload);
  }
  delay(10000);
}

[
    {
        "id": "dashboard_flow",
        "type": "tab",
        "label": "IoT Dashboard Flow",
        "disabled": false,
        "info": "Flow lengkap untuk dashboard monitoring IoT"
    },
    {
        "id": "mqtt_in_all",
        "type": "mqtt in",
        "z": "dashboard_flow",
        "name": "All Sensor Data",
        "topic": "iot/sensor/+",
        "qos": "1",
        "datatype": "auto",
        "broker": "mosquitto_local",
        "nl": false,
        "rap": true,
        "rh": 0,
        "inputs": 0,
        "wires": [["func_validate", "debug_raw"]]
    },
    {
        "id": "func_validate",
        "type": "function",
        "z": "dashboard_flow",
        "name": "Validate & Transform",
        "func": "// Extract device ID dari topik\nvar deviceId = msg.topic.split('/').pop();\nvar data = msg.payload;\n\n// Validasi data\nif (!data.suhu || !data.kelembaban) {\n    node.warn('Invalid data dari ' + deviceId);\n    return null;\n}\n\n// Siapkan untuk InfluxDB\nmsg.payload = [{\n    measurement: 'sensor_reading',\n    tags: { device_id: deviceId },\n    fields: {\n        suhu: parseFloat(data.suhu),\n        kelembaban: parseFloat(data.kelembaban)\n    }\n}];\nmsg.topic = '';\n\n// Duplikat untuk threshold check\nvar msg2 = {\n    payload: data,\n    device_id: deviceId\n};\n\nreturn [msg, msg2];",
        "outputs": 2,
        "timeout": "",
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "wires": [["influx_write", "func_threshold"]]
    },
    {
        "id": "influx_write",
        "type": "influxdb out",
        "z": "dashboard_flow",
        "influxdb": "influxdb_01",
        "name": "Write InfluxDB",
        "precision": "ms",
        "retentionPolicy": "",
        "database": "",
        "precision": "ms",
        "retentionPolicy": "",
        "wires": []
    },
    {
        "id": "func_threshold",
        "type": "function",
        "z": "dashboard_flow",
        "name": "Threshold Check",
        "func": "var data = msg.payload;\nif (data.suhu > 35) {\n    node.warn('ALERT: Suhu ' + data.suhu + '°C dari ' + msg.device_id);\n    msg.payload = {\n        alert: 'HIGH_TEMPERATURE',\n        suhu: data.suhu,\n        device: msg.device_id,\n        timestamp: new Date().toISOString()\n    };\n    return msg;\n}\nreturn null;",
        "outputs": 1,
        "wires": [["mqtt_alert_out"]]
    },
    {
        "id": "mqtt_alert_out",
        "type": "mqtt out",
        "z": "dashboard_flow",
        "name": "Publish Alert",
        "topic": "iot/alert",
        "qos": "0",
        "retain": "false",
        "broker": "mosquitto_local",
        "wires": []
    },
    {
        "id": "mosquitto_local",
        "type": "mqtt-broker",
        "name": "Mosquitto",
        "broker": "127.0.0.1",
        "port": "1883",
        "clientid": "nodered",
        "autoConnect": true,
        "usetls": false,
        "keepalive": "60",
        "cleansession": true,
        "birthTopic": "nodered/status",
        "birthQos": "0",
        "birthPayload": "online",
        "willTopic": "nodered/status",
        "willQos": "0",
        "willPayload": "offline"
    },
    {
        "id": "influxdb_01",
        "type": "influxdb",
        "hostname": "127.0.0.1",
        "port": "8086",
        "protocol": "http",
        "dbname": "",
        "name": "InfluxDB IoT",
        "influxdbVersion": "2.0",
        "url": "http://127.0.0.1:8086",
        "rejectUnauthorized": true
    }
]

{
  "title": "IoT Monitoring Dashboard",
  "tags": ["iot", "sensor", "suhu"],
  "timezone": "Asia/Jakarta",
  "panels": [
    {
      "title": "Suhu Saat Ini",
      "type": "gauge",
      "fieldConfig": {
        "defaults": {
          "thresholds": {
            "steps": [
              {"color": "green", "value": null},
              {"color": "yellow", "value": 30},
              {"color": "red", "value": 35}
            ]
          },
          "unit": "celsius",
          "min": 15,
          "max": 50
        }
      },
      "targets": [{
        "query": "from(bucket:\"iot_sensors\") |> range(start:-1h) |> filter(fn:(r) => r._measurement==\"sensor_reading\") |> filter(fn:(r) => r._field==\"suhu\") |> last()"
      }]
    },
    {
      "title": "Grafik Suhu 24 Jam",
      "type": "timeseries",
      "fieldConfig": {
        "defaults": {
          "unit": "celsius",
          "custom": {"drawStyle": "line", "fillOpacity": 10}
        }
      },
      "targets": [{
        "query": "from(bucket:\"iot_sensors\") |> range(start:-24h) |> filter(fn:(r) => r._measurement==\"sensor_reading\") |> filter(fn:(r) => r._field==\"suhu\") |> aggregateWindow(every:5m, fn:mean)"
      }]
    },
    {
      "title": "Kelembaban Saat Ini",
      "type": "stat",
      "fieldConfig": {
        "defaults": {
          "unit": "percent",
          "thresholds": {
            "steps": [
              {"color": "yellow", "value": null},
              {"color": "green", "value": 40},
              {"color": "red", "value": 80}
            ]
          }
        }
      },
      "targets": [{
        "query": "from(bucket:\"iot_sensors\") |> range(start:-1h) |> filter(fn:(r) => r._measurement==\"sensor_reading\") |> filter(fn:(r) => r._field==\"kelembaban\") |> last()"
      }]
    },
    {
      "title": "Status Device",
      "type": "table",
      "targets": [{
        "query": "from(bucket:\"iot_sensors\") |> range(start:-1h) |> filter(fn:(r) => r._measurement==\"sensor_reading\") |> last() |> pivot(rowKey:[\"_time\"], columnKey:[\"_field\"], valueColumn:\"_value\")"
      }]
    }
  ],
  "time": {"from": "now-24h", "to": "now"},
  "refresh": "30s"
}

# Backup InfluxDB (via cron daily)
influx backup /backups/influxdb_$(date +%Y%m%d) --org iotlab

# Cleanup backup lama (hapus backup > 7 hari)
find /backups -name "influxdb_*" -mtime +7 -exec rm -rf {} \;

# Monitor disk usage
df -h /var/lib/influxdb

# Cek log errors
sudo journalctl -u mosquitto --since "1 hour ago" --priority=3
sudo journalctl -u influxdb --since "1 hour ago" --priority=3
sudo journalctl -u grafana-server --since "1 hour ago" --priority=3

# Cek status semua service
echo "=== Mosquitto ===" && sudo systemctl is-active mosquitto
echo "=== InfluxDB ===" && sudo systemctl is-active influxdb
echo "=== Grafana  ===" && sudo systemctl is-active grafana-server
echo "=== Node-RED ===" && systemctl --user is-active nodered

# Restart semua service
sudo systemctl restart mosquitto influxdb grafana-server
systemctl --user restart nodered

# Auto-restart (sudah default di systemd, tapi pastikan):
# Edit /lib/systemd/system/mosquitto.service
# Tambahkan: Restart=always, RestartSec=10