Node-RED + ChirpStack: LoRaWAN-Flows über MQTT bauen

In der ChirpStack-Applikation unter Integrations die MQTT-Integration mit Marshaler auf JSON aktivieren. Jeder Uplink wird dann veröffentlicht auf:

application/{ApplicationID}/device/{DevEUI}/event/up

Der Nachrichtenkörper ist dasselbe v4-Event, das du auch anderswohin weiterleiten würdest. Mit funktionierendem Codec auf dem Device-Profile stehen die dekodierten Werte im Feld object:

{
  "deviceInfo": {
    "applicationId": "00372e31-0620-4671-8270-237632a4e227",
    "applicationName": "cold-chain",
    "deviceProfileName": "EM300-TH",
    "deviceName": "coldroom-01",
    "devEui": "24e124136b502217"
  },
  "fPort": 85,
  "fCnt": 128,
  "data": "AXVkA2etAARoSw==",
  "object": { "battery": 100, "temperature": 17.3, "humidity": 57.5 },
  "rxInfo": [{ "gatewayId": "24e124fffef54092", "rssi": -51, "snr": 13.8 }],
  "txInfo": { "frequency": 868100000 }
}

Verdrahte die mqtt-in-Node in eine Function-Node. Die dekodierten Sensorwerte stehen in msg.payload.object, die Geräteidentität in msg.payload.deviceInfo. Forme die Nachricht für das, was als Nächstes kommt:

// mqtt in -> function: ChirpStack-v4-Uplink ist bereits zu einem Objekt geparst
var p = msg.payload;
var o = p.object || {};                 // decodierte Werte aus dem Codec

// Frueh abbrechen, wenn kein Codec lief (nur rohes Base64 in p.data)
if (!p.object) {
    node.warn("Kein decodiertes object - liegt ein Codec auf dem Device-Profile?");
    return null;
}

msg.devEui = p.deviceInfo.devEui;        // stabiler, eindeutiger Schluessel
msg.topic  = p.deviceInfo.deviceName;    // lesbares Label fuer Dashboards

msg.payload = {
    devEui: p.deviceInfo.devEui,
    name: p.deviceInfo.deviceName,
    profile: p.deviceInfo.deviceProfileName,
    ts: new Date(p.time || Date.now()).toISOString(),
    temperature: o.temperature,
    humidity: o.humidity,
    battery: o.battery,
    rssi: (p.rxInfo && p.rxInfo[0]) ? p.rxInfo[0].rssi : null
};

return msg;

Von hier aus fächerst du auf: eine influxdb out- oder postgres-Node zur Speicherung, eine ui_gauge-Node fürs Dashboard oder eine switch-Node, die einen Alarm auslöst, wenn temperature eine Schwelle überschreitet.

Um ein Gerät zu steuern (ein Relais, ein Ventil, einen Thermostat), veröffentlichst du mit einer mqtt-out-Node ein JSON-Kommando auf dem Downlink-Topic. Baue das Kommando in einer Function-Node:

// function -> mqtt out: einen ChirpStack-Downlink einreihen
var appId  = "00372e31-0620-4671-8270-237632a4e227";
var devEui = "24e124136b502217";

msg.topic = "application/" + appId + "/device/" + devEui + "/command/down";
msg.payload = {
    devEui: devEui,        // muss zur DevEUI im Topic passen
    confirmed: false,
    fPort: 85,             // muss groesser 0 sein
    data: "AQ=="           // Base64-Befehl; ChirpStack verschluesselt vor dem Senden
};
return msg;

Stelle die Ausgabe der mqtt-out-Node auf JSON (oder serialisiere den Payload selbst per JSON.stringify). Sitzt ein Codec mit encodeDownlink-Funktion auf dem Device-Profile, kannst du statt data ein Feld object mit lesbaren Werten senden. Bei Class-A-Geräten wird das Kommando im RX-Fenster nach dem nächsten Uplink zugestellt, bei Class-C-Geräten nahezu sofort.

Node-RED eignet sich ideal für Prototyping, leichtes Routing und das Überbrücken eigenwilliger Protokolle. Für langfristige Speicherung und richtige Dashboards leitest du die geformten Daten an einen Time-Series-Store mit Grafana weiter oder an ThingsBoard, siehe ChirpStack zu ThingsBoard. Wir betreiben Broker, Flows und Backups für dich als Node-RED Managed Hosting neben dem ChirpStack-Hosting, sodass die von dir gebauten Flows dir gehören.