Node-RED, un outil open-source basé sur la programmation en continu, offre aux développeurs une approche de programmation visuelle flexible, permettant de IOTRouteur Passerelle Edge Computing EG pour se connecter facilement à une variété de sources de données pour le traitement et la conversion des données. La passerelle EG Edge Computing Gateway est capable de collecter et d'analyser les données en temps réel à l'endroit où elles sont générées, ce qui réduit les besoins en bande passante et améliore l'efficacité du traitement des données. Elle peut également collecter des données par le biais de divers protocoles (par exemple Modbus, MQTT, OPC UA, etc.) et effectuer la conversion et le stockage nécessaires des données.
I. Fonctions de base de la passerelle EG Edge Computing
La passerelle EG Edge Computing joue le rôle de couche intermédiaire de collecte et de traitement des données dans le système, et traite de manière flexible les données provenant de multiples capteurs et dispositifs pour un filtrage en temps réel et une analyse préliminaire. Passerelle Edge Computing EG a les fonctions suivantes :
Conversion du protocole : Prise en charge des protocoles de transmission de données entre différents appareils, tels que Modbus, OPC UA, MQTT, etc.
Traitement et analyse au niveau local : Fournit la puissance de calcul nécessaire pour filtrer, convertir et simplement analyser les données.
Stockage et transmission des données : Transmet les données traitées via le réseau à une base de données dans le nuage ou sur un serveur local.
II. Mécanisme de fonctionnement du nœud-RED
Node-RED fournit un éditeur de flux basé sur un navigateur qui permet aux utilisateurs de glisser-déposer des nœuds pour créer des flux de traitement de données. Chaque nœud possède des caractéristiques d'entrée et de sortie et est capable d'effectuer des tâches de traitement de données spécifiques. Node-RED dispose d'un support de plug-in riche, tel que Modbus, MQTT, OPC UA, etc., ce qui le rend capable d'intégrer de multiples sources de données.
III. Acquisition et traitement des données
Processus de référence : collecter régulièrement les données des dispositifs esclaves via la passerelle EG, formater les données collectées dans un format reconnaissable par la base de données MySQL et télécharger la base de données MySQL de l'utilisateur. Prenons l'exemple de la collecte des données de l'esclave Modbus RTU, le déroulement de l'opération est le suivant :
1. Se connecter à la base de données MySQL
Assurez-vous d'abord d'installer le nœud MySQL, puis dans l'éditeur Node-RED, ajoutez le nœud MySQL et configurez les paramètres de connexion à la base de données, y compris l'hôte, le port, le nom d'utilisateur, le mot de passe et le nom de la base de données.
Utilisez le nœud MySQL pour configurer les paramètres de connexion à la base de données MySQL de l'utilisateur, la configuration est terminée et déployée, et l'affichage connecté signifie que la connexion est réussie.
2. Collecte des données relatives aux esclaves
Utiliser l'acquisition de données Modbus RTU
Configurez l'adresse de l'hôte et le port du nœud Modbus et spécifiez les registres de données à collecter.
Créez un processus de collecte de données pour connecter le nœud Modbus au nœud MySQL. Configurez un nœud de temporisation pour déclencher périodiquement la tâche de collecte de données afin de garantir des données précises et en temps réel.
3. Formatage des données
Lorsque les données sont téléchargées dans la base de données MySQL, elles doivent être formatées dans l'instruction SQL correcte, conformément aux exigences de MySQL. Utilisez le nœud de calcul de fonction pour formater les données. Le format des données à convertir est le suivant :
| Format des données de sortie du nœud Modbus | Description | Format SQL MySQL pour le téléchargement des données |
| {
"temp" : 31.0, "hum" : 45.5 } |
Convertit les données d'objet émises par le nœud Modbus à gauche en une instruction SQL requise par MySQL à droite. | INSERT INTO my_table (temp, hum) VALUES (25.55, 45.5) ; |
Exemple de code :
var data = msg.payload
var sql = `INSERT INTO my_table (temp, hum) VALUES(${data.temp},${data.hum});`
msg.topic = sql
return msg ;
4. Téléchargement des données
Une fois le formatage des données terminé, connectez le nœud de calcul de fonction et le nœud MySQL, puis cliquez sur le nœud d'injection pour réaliser la collecte et le téléchargement des données. Si le test est concluant, le nœud d'injection peut être configuré pour s'exécuter périodiquement afin de réaliser la collecte et le téléchargement des données dans la base de données MySQL à intervalles réguliers.
La passerelle EG collecte des données à intervalles réguliers et les convertit dans des formats compatibles avec MySQL, une méthode qui permet le traitement en temps réel et le stockage à long terme de grandes quantités de données relatives aux appareils de terrain. Elle améliore l'efficacité du traitement des données et peut servir de base à l'analyse ultérieure des données et à la prise de décision. L'introduction de l'informatique en périphérie permet d'effectuer le traitement initial des données à proximité de la source de données, ce qui réduit la dépendance à l'égard de l'informatique en nuage et diminue la latence et le coût de la transmission des données.
Remarque : si vous avez besoin d'obtenir des données de la base de données MySQL, vous pouvez également télécharger un nœud MySQL en transmettant une instruction SQL de référence à la propriété msg.topic pour demander des données.