MQTT

Équipements qui publient par un broker MQTT externe, en MQTT simple ou en Sparkplug B, avec le broker modélisé comme le nœud que partagent tous les équipements placés dessous, et les données propres de la station publiées sur un broker.

Le pilote MQTT lit et écrit les tags d'équipements qui publient par un broker MQTT externe : une passerelle, un capteur sans fil, un flux Node-RED, un nœud de périphérie qui parle Sparkplug B. La station est cliente de ce broker : elle s'abonne aux topics que lisent ses tags et publie les écritures que vous faites, et chaque broker peut publier les données propres de la station, les tags, variables Logic et alarmes listés sur sa carte Publier, en JSON ou en Sparkplug B. Elle est cliente et non broker, si bien que l'équipement et la station se connectent tous deux à un broker : quand vous n'en avez pas, le broker MQTT propre à la station peut être celui-là, et sa mise en marche ajoute le broker Cette station à ce pilote; Installer un broker montre comment en mettre un autre en place.

Tous les équipements derrière un broker empruntent la même connexion, d'où la topologie Pilote → Broker → Équipement → Tag : le broker porte l'endroit où il répond et la façon dont la station s'y connecte, saisis une seule fois; chaque équipement placé dessous ne porte que sa façon de publier, MQTT simple ou Sparkplug B, et ses tags. Les deux protocoles cohabitent sous un même broker. Les valeurs arrivent par abonnement, pas par interrogation : aucun équipement ni tag MQTT n'a d'intervalle d'interrogation.

La page du pilote

La page du pilote MQTT liste des brokers au lieu d'équipements. La phrase sous son en-tête dit « Chaque broker est une connexion à un broker MQTT externe. Configurez où il répond et comment la station s'y connecte, puis ajoutez les équipements qui publient par lui. » Le tableau Brokers MQTT porte Ajouter un broker à droite de son titre et une ligne par broker : Nom, Adresse (mqtt://host:port, ou mqtts://host:port avec TLS, vide tant que le broker n'a pas d'hôte), Équipements, État (une pastille et l'état du broker avec ce que font ses équipements, comme « En ligne · 2/2 équipements en ligne »), puis Ouvrir et, pour Configurer le Connector, Activer, Désactiver et Supprimer. Le tableau vide dit « Aucun broker pour l'instant. » Un broker qui a refusé la station porte le marqueur rouge de l'arborescence après son nom, et la page nomme sous son en-tête les brokers en erreur (« 1 broker MQTT en erreur : Plant »).

Dans l'arbre, la ligne du pilote compte les deux niveaux (« 1 broker MQTT · 2 équipements »), et l'en-tête de la page affiche le nombre de brokers entre parenthèses. Dans le menu Nouveau… de la colonne, l'entrée MQTT propose Nouveau broker, puis chaque broker avec son propre Nouvel équipement et ses équipements, et le clic droit sur la ligne du pilote propose Ajouter un broker. La barre du pilote n'a pas de Découvrir : un balayage écoute un seul broker, il se trouve donc sur la page du broker. Une fois ajouté, le pilote se range sous le dossier Pilotes de l'arborescence, avec ou sans broker.

Le broker

Ajouter un broker, Nouveau broker dans le menu Nouveau… et le clic droit sur la ligne du pilote créent un broker nommé « Nouveau broker » (puis « Nouveau broker 2 ») et désactivé, pour que sa connexion soit renseignée avant que la station ne se connecte. Le journal des actions le dit : « Broker désactivé « Nouveau broker » ajouté. Indiquez où il répond, puis activez-le. » Le broker n'est pas ouvert : il est mis en évidence dans le tableau Brokers MQTT de la page du pilote, où l'écran va depuis Nouveau… ou le clic droit. Sa page, atteinte par Ouvrir sur sa ligne ou par sa ligne dans l'arborescence, porte la phrase « Un broker MQTT : où il répond et comment la station s'y connecte. Chaque équipement placé dessous partage cette connexion. » et, dans l'en-tête, l'état, sa pastille et l'adresse. Sous l'en-tête, les équipements du broker qui ont une erreur à eux sont nommés (« 1 équipement en erreur : Pump »); tant que le broker lui-même est en erreur, ses équipements y renvoient : la page d'un équipement dit « Cet équipement passe par le broker MQTT Plant, qui est en erreur. La page du broker indique pourquoi. »

La carte Connexion au broker

Sous les champs, une phrase dit ce que font le broker et ses équipements, ce qui manque encore au broker, et « Tous les équipements sous ce broker et ce que la station y publie partagent cette connexion : la session s'ouvre quand le premier équipement activé ou la première ligne publiée en a besoin. » Tous les champs restent modifiables pendant que le broker est activé. Une modification enregistrée de l'endroit où il répond, du transport, de l'identification, de l'ID client ou du maintien de session reconnecte la session unique que partagent tous les équipements du broker.

La barre de commandes

Le clic droit sur la ligne d'un broker propose Ajouter un équipement, Activer, Désactiver et Supprimer.

États du broker

Le broker rend compte de sa session à part de ses équipements, dans la ligne de l'arbre, dans le tableau des brokers du pilote et dans son propre en-tête :

La ligne de l'arbre affiche l'état et le nombre d'équipements (« En ligne · 2 équipements »), et le résumé sous la carte ajoute ce que font les équipements : « En ligne · 2/2 équipements en ligne », « En ligne · 1 en ligne · 1 en anomalie », « Aucune session · aucun équipement activé ». Un équipement Sparkplug B qui a annoncé sa mort ne met hors service que lui-même : le broker reste En ligne. La session parle MQTT 5 et se replie sur MQTT 3.1.1 avec un broker qui ne le parle pas, démarre propre et se reconnecte d'elle-même, en attendant de plus en plus longtemps entre deux tentatives tant que le broker reste absent.

La carte Découvrir les équipements

Dessinée seulement pour Configurer le Connector, sous la phrase « Écoute ce broker un moment : les nœuds de périphérie et équipements Sparkplug B qui s'annoncent, et les topics sous un filtre. »

Découvrir lance le balayage et devient Annuler pendant qu'il roule. La phrase sous les champs dit ce qu'il va faire (« Écoute 192.168.0.20:1883 pendant 10 s. »), et la phrase de progression compte la fenêtre (« Écoute de 192.168.0.20:1883 · 4 sur 10 s… »). Le balayage a besoin d'un hôte enregistré sur le broker : jusque-là, la carte dit « Saisissez l'hôte du broker et laissez la modification s'enregistrer avant la découverte. » Une modification en attente sur le broker est enregistrée d'abord; quand elle ne peut pas l'être, rien ne démarre : « La découverte n'a pas démarré parce que la modification du broker n'a pas pu être enregistrée. »

Ce que fait un balayage sur le broker :

• Il se connecte sous un ID client à lui, si bien qu'il n'éjecte jamais la session des équipements du broker, et il peut rouler pendant que le broker est activé et utilisé.
• Il s'abonne à tous les topics Sparkplug B (spBv1.0/#) et au filtre de topics. Les certificats de naissance Sparkplug B ne sont pas retenus, si bien qu'un nœud de périphérie entendu sans certificat est prié de s'annoncer à nouveau (la commande Node Control/Rebirth, le seul message que publie le balayage); un nœud de périphérie en marche répond dans la fenêtre.
• Chaque nœud de périphérie et chaque équipement derrière lui qui s'annonce (NBIRTH, DBIRTH) devient un candidat avec ses métriques comme tags, typées selon ce que déclare la naissance. La plomberie propre au nœud de périphérie (bdSeq et les métriques Node Control/… et Device Control/…) est laissée de côté, tout comme les métriques qu'aucun tag ne lit (tableaux, jeux de données, modèles, ensembles de propriétés, octets, fichiers), comptées par motif. Un nœud de périphérie entendu mais pas né dans la fenêtre est proposé sans tags.
• Avec un filtre de topics, les topics simples entendus dessous deviennent un candidat à part : chaque topic est un tag ou, pour une charge utile JSON, chaque valeur qu'elle contient en est un par son chemin de la valeur (jusqu'à 32 par topic, quatre niveaux de profondeur, les 8 premiers éléments d'un tableau). Un nombre est proposé en Double, true ou false en Boolean, tout le reste en String. La liste s'arrête à 500 topics. Un topic dont l'éditeur retient son dernier message est entendu tout de suite; tout autre, seulement s'il publie pendant la fenêtre.
• Rien n'est enregistré tant que vous n'ajoutez pas un candidat. Annuler termine la fenêtre aussitôt.

La carte de résultats, Équipements découverts, liste Publie comme (group/edge node, avec /device derrière un nœud de périphérie, ou « Topics simples »), Équipement (le nom sous lequel l'ajouter, modifiable : l'ID de l'équipement ou du nœud de périphérie, ou les niveaux du filtre avant son premier joker), Résultat (« 12 tags sur 12 sélectionnés ») et Ajouter un équipement, qui crée l'équipement sous ce broker avec ces tags. Une identité Sparkplug B déjà configurée sur le broker affiche « Déjà configuré » et propose Ouvrir à la place. Un balayage qui n'a rien entendu dit « Rien ne s'est annoncé sur ce broker pendant l'écoute du balayage. »

Un équipement que vous avez déjà trouve depuis sa propre page ce qu'il ne lit pas encore : Découvrir les tags, dans l'en-tête de sa carte des tags, écoute 10 s sur son broker. Un équipement Sparkplug B n'entend que son propre nœud de bordure, à qui l'on demande sa naissance pendant qu'on ne demande rien aux autres; un équipement simple entend les topics sous les niveaux que partagent ses tags (plant/oven/# pour plant/oven/temperature et plant/oven/count), et tous les topics du broker quand ils n'en partagent aucun. Seules les valeurs pour lesquelles il n'a pas encore de tag sont proposées (voir Découvrir les tags d'un équipement).

La carte Équipements

« Chaque équipement lit des topics simples, ou un nœud de périphérie ou équipement Sparkplug B. La connexion est héritée du broker et ne peut pas être changée ici. » Ajouter un équipement crée « Nouvel équipement » sous ce broker, activé, en MQTT simple, mis en évidence dans ce tableau et amené dans la zone visible : « Équipement « Nouvel équipement » ajouté sur « Plant ». » Le tableau liste Équipement, Publie comme, Tags et État de santé, avec Ouvrir, Activer, Désactiver et Supprimer sur chaque ligne; vide, il dit « Aucun équipement configuré sur ce broker. » Un équipement qui a une erreur à lui porte le marqueur rouge de l'arborescence après son nom.

La carte Publier

La dernière carte publie les données propres de la station sur ce broker, sous la phrase « La station publie chaque ligne sur ce broker en JSON, sur son topic, dès que la valeur ou sa qualité change, et toutes les lignes à nouveau chaque fois que la connexion s'ouvre. Le broker garde le dernier message de chaque topic pour qui s'y abonne plus tard. La station ne s'abonne qu'au topic d'écriture de chaque ligne en Lecture et écriture. » Qui consulte le Connector lit la carte; qui le configure la modifie. Le broker Cette station du broker MQTT propre à la station porte la même carte.

En Sparkplug B, la phrase sous le titre dit à la place « La station est un nœud de périphérie Sparkplug B sur ce broker : les variables et les alarmes du Logic sont ses propres métriques, et chaque équipement qui a des lignes est un équipement Sparkplug B. Elle annonce toutes les métriques à l'ouverture de la connexion et chaque fois que la liste change, puis publie chaque valeur ou qualité qui change. Seule une ligne en Lecture et écriture accepte une valeur venue d'une commande. », et sous les champs ID du nœud de périphérie (le nom de la station) montre le nœud de périphérie sous lequel elle publie.

Le tableau liste Source servie, Topic MQTT et Accès, par topic; une ligne dont la source n'est pas encore choisie indique « Pas encore de source ». Sans aucune, il indique « Rien n'est encore publié sur ce broker. Ajoutez une ligne avec Nouvelle ligne. » En Sparkplug B, la colonne Topic MQTT devient Métrique : un tag après son équipement (Oven · Temperature), une variable ou une alarme par son nom sur le nœud de périphérie (Logic/Oven/Setpoint, Alarms/High). Quand le broker est désactivé et que la liste a des lignes, une note dit « Le broker est désactivé, donc rien n'est publié tant qu'il n'est pas activé. » Quand une ligne du broker est en Lecture et écriture, une seconde note dit « Les lignes en Lecture et écriture acceptent les valeurs publiées sur leur topic d'écriture. Quiconque peut publier sur ce broker peut modifier ces sources : le nom d'utilisateur et le mot de passe du broker sont leur seule protection. » En Sparkplug B, elle dit « Les lignes en Lecture et écriture acceptent les valeurs des commandes Sparkplug B (NCMD, DCMD). Quiconque peut publier sur ce broker peut modifier ces sources : le nom d'utilisateur et le mot de passe du broker sont leur seule protection. »

Les champs d'une ligne sont enregistrés dès qu'ils changent :

Sous les champs, une phrase dit ce que publie la ligne :

Sous cette phrase, une ligne en Lecture et écriture montre son Topic d'écriture, le topic de la ligne suivi de /set. En Sparkplug B, il n'y a pas de topic d'écriture : une seconde phrase dit la métrique sous laquelle la ligne est publiée, celle de son équipement Sparkplug B pour un tag, celle du nœud de périphérie de la station pour une variable et, pour une alarme, les cinq métriques sous son nom (Active, Acked, State, Priority et Message).

Une modification que la liste refuse n'est pas enregistrée : la raison s'écrit en rouge au-dessus des champs de la ligne, et la modification reste à l'écran pour que vous la corrigiez.

Ce qui est publié, et quand, se trouve dans Publication.

Équipement

L'équipement n'a ni hôte, ni port, ni identifiants, ni intervalle d'interrogation à lui : tout cela appartient au broker. Chaque ID Sparkplug B est un seul niveau de topic : « Un ID Sparkplug B ne peut contenir ni '/', ni '+', ni '#'. » Un broker ne nomme un nœud de périphérie ou un équipement Sparkplug B qu'une fois, si bien qu'un deuxième équipement avec les mêmes ID de groupe, de nœud de périphérie et d'équipement sur ce broker est refusé : « L'équipement Sparkplug B Plant/Line1/Press1 du broker « Plant » appartient déjà à l'équipement « Press ». » Les équipements en MQTT simple ne nomment rien d'eux-mêmes sur le broker, et deux d'entre eux peuvent lire les mêmes topics.

La Base URI qu'affiche l'en-tête est l'adresse d'exécution : mqtt://<broker id>?host=…&port=…&tls=0&keepAlive=60&clientId=…&mode=plain, avec &silence=… quand l'équipement fixe une durée maximale sans message, et pour un équipement Sparkplug B mode=sparkplug&group=…&node=…, avec &device=… derrière un nœud de périphérie. Elle nomme le broker par son identité stable, jamais par son nom convivial, et ne porte jamais le nom d'utilisateur ni le mot de passe.

La copie d'un équipement MQTT reste sur le même broker. Une copie Sparkplug B prend la première identité qu'aucun équipement de ce broker n'a : son ID le plus intérieur, l'ID de l'équipement ou, pour les métriques propres au nœud de périphérie, l'ID du nœud de périphérie, est numéroté comme l'est le nom de la copie (« Press1 (2) »).

Adressage du tag

Le champ d'adresse est Topic MQTT sur un équipement en MQTT simple et Métrique sur un équipement Sparkplug B, et il est obligatoire (« Topic MQTT est obligatoire pour ce pilote. »). Un tag simple a trois champs de plus; une métrique Sparkplug B n'en a aucun, car elle porte son propre type et s'écrit par la commande propre au protocole.

Les types de données sont Boolean, Int16, Int32, Int64, Float, Double, String et DateTime. L'aperçu en lecture seule de l'adresse sur le fil est le topic suivi de ce qui s'applique de path, command et payload (plant/line1/temperature?path=sensors[0].value&command=plant/line1/setpoint), ou le nom de la métrique; un caractère qui terminerait une partie (%, ?, &, =, #, +, une espace) s'écrit %XX.

Lecture

La session garde le dernier message de chaque topic auquel elle s'est abonnée, et un tag lit dedans :

Un tag Boolean accepte true ou false, 1 ou 0, on ou off. Un tag entier accepte un nombre fractionnaire arrondi et refuse un nombre hors de sa plage. Un tag DateTime accepte du texte ISO 8601 ou des millisecondes Unix. Un tag String accepte le texte tel quel, et un objet ou un tableau JSON comme son JSON brut. Une métrique Sparkplug B d'un type non signé se lit dans le type signé immédiatement plus large (UInt8 en Int16, UInt16 en Int32, UInt32 et UInt64 en Int64), pour que toute sa plage se lise.

Écriture

Une écriture passe par le même entonnoir que celle de n'importe quel autre pilote : la case d'écriture reçoit la valeur d'ingénierie, et les étapes de conversion sont inversées avant que la valeur brute ne soit publiée (voir Connector).

Tant que le broker est injoignable, ou que le nœud de périphérie ou l'équipement a annoncé sa mort, une écriture est refusée comme déconnectée et rien n'est envoyé. Une écriture Sparkplug B sur une métrique que le certificat de naissance ne déclare pas est refusée, puisque le nœud de périphérie ne la prendrait pas, tout comme une valeur que le type de la métrique ne peut pas porter. Une écriture n'est jamais retenue : une consigne retenue serait appliquée de nouveau par chaque abonné qui se connecterait plus tard.

Publication

Cette section décrit le Format de publication sur JSON; le Sparkplug B a la section suivante.

Chaque ligne de la carte Publier d'un broker est publiée sur son topic, en message retenu, en QoS 1, par la connexion qu'empruntent les équipements du broker : la station n'ouvre jamais une deuxième connexion vers un broker. Un broker qui ne sert qu'à publier n'a besoin d'aucun équipement. Il reste sous le pilote MQTT, et son état (Connexion…, En ligne, Injoignable) est celui de cette connexion. Il publie tant qu'il est activé et que sa liste a des lignes; il n'a pas d'interrupteur à lui.

Une valeur voyage dans son type JSON : un nombre, true ou false, du texte, une date et une heure en texte ISO 8601; un nombre que le JSON ne porte pas (NaN, un infini) voyage en null. Un tag d'un équipement désactivé publie null et bad.

La station lit ce qu'elle publie et ne calcule rien pour cela : la dernière lecture d'un tag, la valeur d'une variable, l'état d'une alarme. Elle ne s'abonne à aucun topic d'une ligne en lecture seule, si bien qu'un message qu'un autre système y publie n'atteint jamais la station; une ligne en Lecture et écriture accepte des valeurs sur son topic d'écriture (Écriture en retour). Un agent lit les listes avec mqtt_publish_list et les modifie avec mqtt_publish_upsert et mqtt_publish_delete (Outils) :

mqtt_publish_upsert(brokerId: "<id from mqtt_broker_list>", source: "Connector.Simulated.Oven.Temperature")
mqtt_publish_upsert(brokerId: "<id from mqtt_broker_list>", source: "Alarms.Oven.HighTemperature", topic: "plant/oven/alarms/high")
mqtt_publish_upsert(id: "<id from mqtt_publish_list>", access: "ReadAndWrite")
mqtt_publish_list()

Publication en Sparkplug B

Avec Format de publication sur Sparkplug B, le broker publie la même liste selon la spécification Sparkplug B, la station étant un nœud de périphérie : un hôte Sparkplug B, comme le MQTT Engine d'Ignition, liste la station sous son groupe et son nœud de périphérie, chaque équipement sous elle et chaque métrique avec son type, sans aucune correspondance construite à la main. La connexion est celle qu'utilisent les équipements du broker, comme en JSON.

Une / à l'intérieur d'un nom devient _, de sorte que les dossiers sont les seuls niveaux. Deux équipements, ou deux métriques, dont les noms deviennent identiques reçoivent _2, _3 dans l'ordre de leurs propres noms. Les lignes gardent leurs topics, sur lesquels rien n'est publié en Sparkplug B et sur lesquels la liste publie à nouveau quand le broker repasse en JSON.

Chaque message sort en QoS 0, jamais retenu, sauf le NDEATH. Le numéro de séquence seq repart de 0 à chaque NBIRTH et compte chaque message suivant jusqu'à 255, puis recommence; bdSeq compte les connexions, si bien que le NBIRTH et le NDEATH d'une connexion portent le même numéro. Rien n'attend dans une file pendant que le broker est indisponible.

Un tag est publié dans son propre type; une variable dans le type sous lequel le serveur OPC UA la sert (un nombre entier en Int64, un nombre réel en Double, une valeur de présentation en texte). Chaque métrique porte sa qualité dans la propriété Quality, la convention que lisent les hôtes Sparkplug B : 192 bonne, 64 incertaine (avec la dernière valeur publiée quand la lecture a cessé d'arriver), 0 mauvaise (la métrique n'a alors pas de valeur).

La station écoute toujours les commandes adressées au nœud de périphérie, pour qu'un hôte puisse demander une renaissance, et les commandes adressées à un équipement seulement tant qu'une de ses lignes est en Lecture et écriture. Passer un broker en Sparkplug B rouvre sa connexion une fois, pour que le broker garde la dernière volonté du nœud de périphérie; les équipements du broker la traversent comme toute reconnexion. La station est un nœud de périphérie et non une application hôte principale : elle n'attend pas le message STATE d'un hôte pour naître.

mqtt_broker_upsert(id: "<id from mqtt_broker_list>", publishFormat: "SparkplugB", sparkplugGroupId: "Plant1")
mqtt_publish_list()

Écriture en retour

Une ligne d'une carte Publier en Lecture et écriture accepte des valeurs sur son topic d'écriture, le topic de la ligne suivi de /set : un tableau de bord dans le cloud qui lit plant/oven/setpoint envoie une nouvelle consigne sur plant/oven/setpoint/set. La station l'écrit comme un client de son serveur Modbus ou de son serveur OPC UA écrit une ligne marquée en lecture et écriture.

Le journal technique note chaque écriture avec l'origine MQTT <nom du broker> dans la zone Connector, comme l'écriture d'un opérateur. Un message qui n'a pas été écrit est noté dans la zone Connector, composant MQTT publication, une fois puis dans un résumé toutes les quelques minutes tant qu'il se répète.

Le nom d'utilisateur et le mot de passe du broker sont la seule protection : celui que le broker laisse publier sur un topic d'écriture peut modifier cette source, et sur un broker dans le cloud partagé avec d'autres personnes, cela fait plus de monde que l'usine. Ne donnez au compte du tableau de bord sur le broker que les topics dont il a besoin. Sur un broker en Sparkplug B, les mêmes lignes acceptent des commandes Sparkplug B (NCMD, DCMD) au lieu d'un topic d'écriture (Publication en Sparkplug B).

"C:\Program Files\mosquitto\mosquitto_pub" -h localhost -u dashboard -P <password> -t plant/oven/setpoint/set -m 65

Sécurité

Avec Utiliser TLS, le certificat du broker est accepté de l'une de deux façons : sa chaîne et son nom d'hôte se valident dans le magasin de certificats de Windows, comme pour toute connexion HTTPS de cet ordinateur, ou vous avez approuvé ce certificat précis sous Accès des équipements, sur la page de ce pilote. Un broker dont le certificat vient d'une autorité de certification à vous devient approuvé dès que cette autorité est installée dans le magasin de Windows, et un broker au certificat autosigné n'a besoin de rien d'installé une fois son certificat approuvé. La révocation n'est pas vérifiée, et rien n'accepte un certificat sans l'avoir vu : un certificat inconnu est refusé, le broker reste Injoignable, avec le motif, et ses équipements attendent l'approbation. Le mot de passe circule dans la connexion TLS; sans TLS il circule en clair, comme la carte l'avertit.

Accès des équipements

Un broker au certificat autosigné, ou émis par une autorité à lui, présente un certificat dont aucune racine installée dans Windows ne se porte garante. Cette racine n'a pas besoin d'être installée sur cet ordinateur. Avec Utiliser TLS, la première connexion est refusée, le broker reste Injoignable, avec le motif, ses équipements indiquent En attente de l'approbation du certificat dans l'arborescence et sur leurs pages, dont le bouton Examiner le certificat ouvre cette carte sur le certificat, et le certificat attend sous Accès des équipements, à la fin de la page du pilote MQTT, la même carte que porte la page du pilote OPC UA, jusqu'à ce que vous décidiez :

Vérifiez l'empreinte auprès de la personne qui gère le broker avant d'approuver le certificat. Une approbation accepte ce certificat et aucun autre, et seulement dans ses dates de validité; elle tient lieu de la racine qui manque à Windows et du nom que porte le certificat, si bien qu'un broker joint par son adresse IP se connecte même si son certificat nomme un autre hôte, et rien d'autre du certificat n'est assoupli. Quand le broker répond à une adresse dont vous aviez approuvé le certificat avec un autre, ses équipements cessent de lire, le nouveau attend ici, et la station signale « Certificat modifié : <nom> » avec un bouton Examiner. Un balayage du broker depuis la carte Découvrir les équipements se heurte aux mêmes décisions. Un certificat auquel Windows fait déjà confiance est accepté comme avant et n'apparaît jamais ici; rien n'est approuvé automatiquement.

La cause du broker dit le motif au lieu d'une erreur TLS sans nom : « Le certificat du broker à <hôte>:<port> (les 16 premiers caractères de l'empreinte) attend votre approbation sous Accès des équipements, sur la page du pilote MQTT. La lecture commence dès que vous l'approuvez. » Un certificat bloqué donne « …est bloqué à cette station. Examinez-le sous Accès des équipements, sur la page du pilote MQTT. » Un certificat hors de ses dates de validité, révoqué ou à la signature invalide est refusé avec ce motif et n'est jamais listé, car aucune approbation ne le rend valable.

Les décisions sont conservées dans le dossier de données de la station, sous ua\pki\mqtt, et survivent à un redémarrage. Les verbes ne sont dessinés que pour un rôle qui peut configurer le Connector, et ils n'agissent que dans la fenêtre de la station elle-même : un navigateur sur un autre appareil lit la carte sans la changer, et aucun outil d'agent n'approuve un certificat (connector_browse signale les équipements du broker avec awaitingCertificate). La liste garde jusqu'à 100 certificats en attente d'approbation; une fois pleine, un nouveau est encore refusé mais pas listé, et la carte le dit.

Préparer le broker

Un broker doit accepter les connexions venant de l'ordinateur de la station, et accepter l'ouverture de session de la station. Eclipse Mosquitto 2, le broker le plus courant, ne fait ni l'un ni l'autre en sortie d'usine : sans listener dans son mosquitto.conf il n'écoute que sur son propre ordinateur, et dès qu'il en a un il refuse un client sans nom d'utilisateur. MQTT ne dit pas quel broker a répondu : la station nomme donc Mosquitto comme le cas courant, jamais comme une certitude.

Les deux premiers sont dits sur la page du broker, à la place de son erreur en anglais, avec ces étapes et le port; ses équipements continuent de renvoyer au broker. L'avis disparaît de lui-même dès que la session se connecte. La marque de l'arbre et le journal gardent la cause en anglais, qui se termine par les mêmes étapes Mosquitto.

Installer un broker

La station a besoin d'un broker auquel se connecter, et l'équipement aussi. Là où vous n'en avez pas, Eclipse Mosquitto est un petit broker qui roule comme service Windows :

1. Téléchargez le programme d'installation pour Windows depuis la page de téléchargements de mosquitto.org et lancez-le. Il installe le service Mosquitto Broker dans C:\Program Files\mosquitto.

2. D'origine, Mosquitto ne répond que sur l'ordinateur où il roule. Pour laisser entrer les équipements du réseau, ajoutez un listener et un fichier de mots de passe au mosquitto.conf de ce dossier :

   listener 1883
   password_file C:\Program Files\mosquitto\passwd
   

   Créez le fichier avec le compte qu'utiliseront la station et les équipements (la commande demande le mot de passe) :

   "C:\Program Files\mosquitto\mosquitto_passwd" -c "C:\Program Files\mosquitto\passwd" station
   

3. Redémarrez le service depuis une invite de commandes d'administrateur, et autorisez l'entrée du port TCP 1883 dans le pare-feu Windows Defender pour le réseau des équipements :

   net stop mosquitto
   net start mosquitto
   

4. Sur la page du broker, saisissez localhost comme Hôte quand le broker roule sur l'ordinateur même de la station, ou l'adresse de cet ordinateur sinon, Port 1883 et le compte que vous avez créé, puis Activer.

Pour essayer un tag simple avant que les équipements ne soient connectés, publiez une valeur d'essai retenue depuis le même dossier et pointez le Topic MQTT d'un tag dessus :

"C:\Program Files\mosquitto\mosquitto_pub" -h localhost -u station -P <password> -t plant/line1/temperature -m 21.5 -r

Limites à connaître

• Le pilote MQTT est un client, pas un broker : les équipements et la station se connectent à un broker, le broker MQTT propre à la station ou un autre.
• La carte Publier d'un broker sort en JSON ou en Sparkplug B, jamais les deux à la fois. En Sparkplug B, la station est un nœud de périphérie, pas une application hôte principale, et n'utilise ni alias, ni modèles, ni valeurs historiques.
• La station n'est pas une application hôte Sparkplug B : elle ne publie aucun message STATE. Un nœud de périphérie réglé pour attendre un hôte primaire avant de publier reste muet.
• Le MQTT simple ne dit rien d'un éditeur qui s'est tu : un tag simple garde la dernière valeur reçue tant que la connexion au broker tient, datée de son arrivée, à moins que son équipement ne fixe une Durée maximale sans message (s). Un topic publié seulement quand sa valeur change ne distingue pas un éditeur qui s'est tu d'une valeur stable : son équipement garde donc 0. Le Sparkplug B le dit, par le certificat de mort.
• La session démarre propre : ce qui a été publié pendant que la station n'était pas connectée n'est pas rejoué, et c'est le message retenu d'un topic qui redonne une valeur à son tag.
• Un tag lit un topic, jamais un filtre, et une valeur de ce topic; une métrique Sparkplug B qui est un tableau, un jeu de données, un modèle ou un ensemble de propriétés n'est pas lue.
• TCP seulement, avec ou sans TLS : pas de MQTT sur WebSockets, pas de certificat client, et aucun broker antérieur à MQTT 3.1.1.
• Un équipement ne peut pas être déplacé vers un autre broker : créez-le sous l'autre broker et supprimez l'ancien.