Node-RED, een open-source tool gebaseerd op streaming programming, biedt ontwikkelaars een flexibele visuele programmeeraanpak, waardoor IOTRouter EG Edge Computing Gateway om gemakkelijk verbinding te maken met een verscheidenheid aan gegevensbronnen voor gegevensverwerking en -conversie. De EG Edge Computing Gateway kan gegevens in real-time verzamelen en analyseren aan de rand waar de gegevens worden gegenereerd, wat de bandbreedtevereisten vermindert en de efficiëntie van de gegevensverwerking verbetert. Hij kan ook gegevens verzamelen via verschillende protocollen (bv. Modbus, MQTT, OPC UA, enz.) en de nodige conversie en opslag van gegevens uitvoeren.
I. Basisfuncties van EG Edge Computing Gateway
EG Edge Computing Gateway speelt de rol van de middelste laag van gegevensverzameling en -verwerking in het systeem en verwerkt flexibel gegevens van meerdere sensoren en apparaten voor real-time filtering en voorlopige analyse. EG Edge Computing Gateway heeft de volgende functies:
Protocolomzetting: Ondersteunt protocollen voor gegevensoverdracht tussen verschillende apparaten, zoals Modbus, OPC UA, MQTT, enz.
Lokale verwerking en analyse: Biedt rekenkracht om gegevens te filteren, converteren en eenvoudig te analyseren.
Gegevensopslag en -overdracht: Verzendt verwerkte gegevens via het netwerk naar een database in de cloud of op een lokale server.
II. Werkingsmechanisme van Node-RED
Node-RED biedt een browsergebaseerde flow editor waarmee gebruikers knooppunten kunnen slepen en neerzetten om gegevensverwerkingsstromen te creëren. Elk knooppunt heeft invoer- en uitvoerkenmerken en kan specifieke gegevensverwerkingstaken uitvoeren. Node-RED heeft uitgebreide ondersteuning voor plug-ins, zoals Modbus, MQTT, OPC UA, enz., waardoor het in staat is om meerdere gegevensbronnen te integreren.
III. Gegevensverwerving en -verwerking
Referentieproces: Verzamel regelmatig gegevens van slave-apparaten via de EG-gateway en formatteer de verzamelde gegevens in een formaat dat herkenbaar is voor de MySQL-database en upload de eigen MySQL-database van de gebruiker. Hier neemt u de verzameling van Modbus RTU-slavegegevens uploaden als voorbeeld, de bewerkingsstroom is als volgt:
1. Verbinding maken met MySQL-database
Zorg er eerst voor dat je het MySQL knooppunt installeert en voeg dan in Node-RED editor het MySQL knooppunt toe en configureer de database verbindingsparameters, inclusief host, poort, gebruikersnaam, wachtwoord en databasenaam.
Gebruik het MySQL knooppunt om de verbindingsparameters van de MySQL database van de gebruiker te configureren, de configuratie wordt voltooid en ingezet, en de weergave connected betekent dat de verbinding succesvol is.
2. Slave-gegevens verzamelen
Modbus RTU gegevensverwerving gebruiken
Configureer het hostadres en de poort van het Modbus knooppunt en geef de gegevensregisters op die moeten worden verzameld.
Maak een gegevensverzamelingsproces om het Modbus knooppunt met het MySQL knooppunt te verbinden. Stel een timer-knooppunt in om de gegevensverzamelingstaak periodiek te triggeren om realtime en nauwkeurige gegevens te garanderen.
3. Gegevensopmaak
Wanneer gegevens worden geüpload naar de MySQL database, moeten ze worden geformatteerd in de juiste SQL-instructie volgens de vereisten van MySQL. Gebruik het knooppunt Functieberekening om de gegevens te formatteren. De gegevensindeling die moet worden geconverteerd is als volgt:
| Modbus node uitgangsdataformaat | Beschrijving | MySQL SQL-indeling voor het uploaden van gegevens |
| {
"temp: 31.0, "brom": 45.5 } |
Converteert de objectgegevens van het Modbus knooppunt aan de linkerkant naar de SQL-instructie die MySQL aan de rechterkant nodig heeft. | INSERT INTO my_table (temp, hum) VALUES (25,55, 45,5); |
Voorbeeldcode:
var data = msg.payload
var sql = `INSERT INTO my_table (temp, hum) VALUES(${data.temp},${data.hum});`
msg.onderwerp = sql
msg teruggeven;
4. Gegevens uploaden
Nadat het formatteren van de gegevens is voltooid, verbindt u het knooppunt voor functieberekening en het MySQL-knooppunt en klikt u op het injectieknooppunt om het verzamelen en uploaden van gegevens te realiseren. Bij succesvol testen kunt u het injectieknooppunt zo instellen dat het periodiek wordt uitgevoerd om het verzamelen en uploaden van gegevens naar de MySQL database met regelmatige tussenpozen te realiseren.
De edge computing gateway van EG verzamelt gegevens op regelmatige tijdstippen en zet ze om in formaten die MySQL ondersteunen, een methode die real-time verwerking en langetermijnopslag van grote hoeveelheden gegevens van veldapparatuur mogelijk maakt. Het verbetert de efficiëntie van gegevensverwerking en kan een basis vormen voor latere gegevensanalyse en besluitvorming. Door de introductie van edge computing kan de eerste verwerking van gegevens dicht bij de gegevensbron worden voltooid, waardoor de afhankelijkheid van cloud computing wordt verminderd en de latentie en kosten van gegevensoverdracht worden verlaagd.
Opmerking: Als je gegevens uit de MySQL database moet halen, kun je ook een MySQL knooppunt uploaden door een SQL-verwijzing door te geven aan de msg.topic eigenschap om een verzoek voor gegevens te doen.