MQTT

Dispositivi che pubblicano attraverso un broker MQTT esterno, in MQTT semplice o Sparkplug B, con il broker modellato come il nodo che condividono tutti i dispositivi sotto di esso, e i dati della stazione stessa pubblicati su un broker.

Il driver MQTT legge e scrive i tag di apparecchiature che pubblicano attraverso un broker MQTT esterno: un gateway, un sensore wireless, un flusso Node-RED, un nodo edge che parla Sparkplug B. La stazione è client di quel broker: si abbona ai topic che leggono i suoi tag e pubblica le scritture fatte sui suoi tag, e ogni broker può pubblicare i dati della stazione stessa, i tag, le variabili di Logic e gli allarmi elencati nella sua scheda Pubblicare, come JSON o in Sparkplug B. È client e non broker, quindi l'apparecchiatura e la stazione si collegano entrambe a un broker: se non ce n'è uno, il broker MQTT della stazione stessa può esserlo, e accenderlo aggiunge a questo driver il broker Questa stazione; Installare un broker mostra come metterne in piedi uno separato.

Tutti i dispositivi dietro un broker usano la stessa connessione, perciò la topologia è Driver → Broker → Dispositivo → Tag: il broker possiede dove risponde e come la stazione vi accede, scritti una volta sola; ogni dispositivo sotto di esso possiede solo il modo in cui pubblica, MQTT semplice o Sparkplug B, e i suoi tag. I due protocolli convivono sotto lo stesso broker. I valori arrivano per abbonamento, non per interrogazione, quindi nessun dispositivo o tag MQTT ha un intervallo di interrogazione.

La pagina del driver

La pagina del driver MQTT elenca broker invece di dispositivi. La frase sotto la sua intestazione dice « Ogni broker è una connessione a un broker MQTT esterno. Configurare dove risponde e come accede la stazione, poi aggiungere i dispositivi che pubblicano attraverso di esso. » La tabella Broker MQTT porta Aggiungi broker a destra del titolo e una riga per broker: Nome, Indirizzo (mqtt://host:port, oppure mqtts://host:port con TLS, vuoto finché il broker non ha un host), Dispositivi, Stato (un punto e lo stato del broker con quello che fanno i suoi dispositivi, come « Connesso · 2/2 dispositivi connessi »), poi Apri e, per Configurare Connector, Abilita, Disabilita ed Elimina. La tabella vuota dice « Nessun broker. » Un broker che ha rifiutato la stazione porta il segno rosso dell'albero dopo il nome, e la pagina nomina sotto l'intestazione i broker con errore (« 1 broker MQTT con errore: Plant »).

Nell'albero la riga del driver conta i due livelli (« 1 broker MQTT · 2 dispositivi »), e l'intestazione della pagina mostra il numero di broker tra parentesi. Nel menu Nuovo… della colonna la voce MQTT offre Nuovo broker, poi ogni broker con il suo Nuovo dispositivo e i suoi dispositivi, e il clic destro sulla riga del driver offre Aggiungi broker. La barra del driver non ha Rileva: una scansione ascolta un solo broker, quindi sta nella pagina del broker. Una volta aggiunto, il driver sta sotto la cartella Driver dell'albero, con o senza broker.

Il broker

Aggiungi broker, Nuovo broker nel menu Nuovo… e il clic destro sulla riga del driver creano un broker chiamato « Nuovo broker » (poi « Nuovo broker 2 ») e disabilitato, così che la sua connessione venga compilata prima che la stazione si colleghi. Il registro delle azioni lo dice: « Broker 'Nuovo broker' aggiunto come disabilitato. Indicare dove risponde, poi abilitarlo. » Il broker non viene aperto: è evidenziato nella tabella Broker MQTT della pagina del driver, dove la schermata va da Nuovo… o dal clic destro. La sua pagina, raggiunta con Apri sulla sua riga o con la sua riga nell'albero, porta la frase « Un broker MQTT: dove risponde e come la stazione vi accede. Ogni dispositivo sotto di esso condivide questa connessione. » e, nell'intestazione, lo stato, il suo punto e l'indirizzo. Sotto l'intestazione sono nominati i dispositivi del broker che hanno un errore proprio (« 1 dispositivo con errore: Pump »); finché il broker stesso ha un errore, i suoi dispositivi rimandano a lui: la pagina di un dispositivo dice « Questo dispositivo passa per il broker MQTT Plant, che ha un errore. La pagina del broker dice perché. »

La scheda Connessione al broker

Sotto i campi, una frase dice che cosa stanno facendo il broker e i suoi dispositivi, che cosa manca ancora al broker, e « Tutti i dispositivi sotto questo broker e ciò che la stazione vi pubblica condividono questa connessione: la sessione si apre quando il primo dispositivo abilitato o la prima riga pubblicata ne ha bisogno. » Tutti i campi restano modificabili con il broker abilitato. Una modifica salvata di dove risponde, del trasporto, dell'accesso, dell'ID client o del keep-alive ricollega l'unica sessione che condividono tutti i dispositivi del broker.

La barra dei comandi

Il clic destro sulla riga di un broker offre Aggiungi dispositivo, Abilita, Disabilita ed Elimina.

Stati del broker

Il broker riferisce la sua sessione separatamente dai suoi dispositivi, nella riga dell'albero, nella tabella dei broker del driver e nella propria intestazione:

La riga dell'albero mostra lo stato e il numero di dispositivi (« Connesso · 2 dispositivi »), e il riepilogo sotto la scheda aggiunge che cosa fanno i dispositivi: « Connesso · 2/2 dispositivi connessi », « Connesso · 1 connessi · 1 con problemi », « Nessuna sessione · nessun dispositivo abilitato ». Un dispositivo Sparkplug B che ha annunciato la propria morte toglie dall'aria solo sé stesso: il broker resta Connesso. La sessione parla MQTT 5 e ripiega su MQTT 3.1.1 con un broker che non lo parla, parte pulita e si ricollega da sola, aspettando sempre di più tra un tentativo e l'altro finché il broker resta assente.

La scheda Rileva i dispositivi

Disegnata solo per Configurare Connector, sotto la frase « Ascolta su questo broker per un po': i nodi edge e i dispositivi Sparkplug B che si annunciano, e i topic sotto un filtro. »

Rileva avvia la scansione e diventa Annulla mentre è in corso. La frase sotto i campi dice che cosa farà (« Ascolta 192.168.0.20:1883 per 10 s. »), e la frase di avanzamento conta la finestra (« Ascolto di 192.168.0.20:1883 · 4 di 10 s… »). La scansione ha bisogno di un host salvato sul broker: fino ad allora la scheda dice « Inserire l'host del broker e lasciare che la modifica venga salvata prima del rilevamento. » Una modifica in sospeso sul broker viene salvata prima; quando non si può, non parte niente: « Il rilevamento non è partito perché non è stato possibile salvare la modifica del broker. »

Che cosa fa una scansione sul broker:

• Si collega con un ID client proprio, quindi non fa mai cadere dal broker la sessione dei dispositivi, e può girare con il broker abilitato e in uso.
• Si abbona a tutti i topic Sparkplug B (spBv1.0/#) e al filtro dei topic. I certificati di nascita Sparkplug B non vengono conservati, perciò a un nodo edge sentito senza certificato viene chiesto di annunciarsi di nuovo (il comando Node Control/Rebirth, l'unico messaggio che la scansione pubblica); un nodo edge in funzione risponde dentro la finestra.
• Ogni nodo edge e ogni dispositivo dietro di esso che si annuncia (NBIRTH, DBIRTH) diventa un candidato con le sue metriche come tag, tipizzate secondo quello che dichiara la nascita. Le tubature proprie del nodo edge (bdSeq e le metriche Node Control/… e Device Control/…) restano fuori, come le metriche che nessun tag legge (array, set di dati, template, insiemi di proprietà, byte, file), contate per motivo. Un nodo edge sentito ma non nato dentro la finestra viene offerto senza tag.
• Con un filtro dei topic, i topic semplici sentiti sotto di esso diventano un candidato a sé: ogni topic è un tag oppure, per un payload JSON, ogni valore che contiene lo è tramite il suo percorso del valore (fino a 32 per topic, quattro livelli di profondità, i primi 8 elementi di un array). Un numero viene offerto come Double, true o false come Boolean, tutto il resto come String. L'elenco si ferma a 500 topic. Un topic il cui editore conserva l'ultimo messaggio si sente subito; qualsiasi altro solo se pubblica durante la finestra.
• Non si salva niente finché non si aggiunge un candidato. Annullare chiude subito la finestra.

La scheda dei risultati, Dispositivi rilevati, elenca Pubblica come (group/edge node, con /device dietro un nodo edge, oppure « Topic semplici »), Dispositivo (il nome con cui aggiungerlo, modificabile: l'ID del dispositivo o del nodo edge, oppure i livelli del filtro prima del suo primo carattere jolly), Risultato (« 12 di 12 tag selezionati ») e Aggiungi dispositivo, che crea il dispositivo sotto questo broker con quei tag. Un'identità Sparkplug B già configurata sul broker mostra « Già configurato » e offre Apri al suo posto. Una scansione che non ha sentito niente dice « Niente si è annunciato su questo broker mentre la scansione ascoltava. »

Un dispositivo che c'è già trova dalla sua stessa pagina quello che non legge ancora: Rileva tag, nell'intestazione della sua scheda dei tag, ascolta 10 s sul suo broker. Un dispositivo Sparkplug B sente solo il proprio edge node, a cui si chiede la nascita mentre a nessun altro si chiede nulla; un dispositivo semplice sente i topic sotto i livelli che i suoi tag hanno in comune (plant/oven/# per plant/oven/temperature e plant/oven/count), e ogni topic del broker quando non ne hanno nessuno in comune. Si offrono solo i valori per cui non ha ancora un tag (vedere Rilevare i tag di un dispositivo).

La scheda Dispositivi

« Ogni dispositivo legge topic semplici, oppure un nodo edge o un dispositivo Sparkplug B. La connessione è ereditata dal broker e non può essere cambiata qui. » Aggiungi dispositivo crea « Nuovo dispositivo » sotto questo broker, abilitato, in MQTT semplice, evidenziato in questa tabella e portato in vista: « Dispositivo 'Nuovo dispositivo' aggiunto su 'Plant'. » La tabella elenca Dispositivo, Pubblica come, Tag e Stato di salute, con Apri, Abilita, Disabilita ed Elimina su ogni riga; vuota, dice « Nessun dispositivo configurato su questo broker. » Un dispositivo con un errore proprio porta il segno rosso dell'albero dopo il nome.

La scheda Pubblicare

L'ultima scheda pubblica i dati della stazione stessa su questo broker, sotto la frase « La stazione pubblica ogni riga su questo broker come JSON sul suo topic ogni volta che il valore o la sua qualità cambia, e di nuovo tutte le righe ogni volta che la connessione si apre. Il broker conserva l'ultimo messaggio di ogni topic per chi si iscrive più tardi. La stazione si iscrive solo al topic di scrittura di ogni riga in Lettura e scrittura. » Chi consulta il Connector legge la scheda; chi lo configura la modifica. Il broker Questa stazione del broker MQTT della stazione stessa ha la stessa scheda.

In Sparkplug B la frase sotto il titolo dice invece « La stazione è un nodo edge Sparkplug B su questo broker: le variabili e gli allarmi del Logic sono le sue metriche, e ogni dispositivo con righe è un dispositivo Sparkplug B. Annuncia tutte le metriche quando la connessione si apre e ogni volta che l'elenco cambia, poi pubblica ogni valore o qualità che cambia. Solo una riga in Lettura e scrittura accetta un valore da un comando. », e sotto i campi ID nodo edge (il nome della stazione) mostra il nodo edge con cui pubblica.

La tabella elenca Sorgente, Topic MQTT e Accesso, per topic; una riga la cui sorgente non è ancora scelta dice « Ancora nessuna sorgente ». Senza righe, dice « Ancora nulla è pubblicato su questo broker. Aggiungere una riga con Nuova riga. » In Sparkplug B la colonna Topic MQTT è Metrica: un tag dopo il suo dispositivo (Oven · Temperature), una variabile o un allarme con il suo nome sul nodo edge (Logic/Oven/Setpoint, Alarms/High). Con il broker disabilitato e righe nell'elenco, una nota dice « Il broker è disabilitato, quindi non viene pubblicato nulla finché non è abilitato. » Con una riga del broker in Lettura e scrittura, una seconda nota dice « Le righe in Lettura e scrittura accettano i valori pubblicati sul loro topic di scrittura. Chiunque possa pubblicare su questo broker può cambiare quelle sorgenti, quindi il nome utente e la password del broker sono la loro unica protezione. » In Sparkplug B dice « Le righe in Lettura e scrittura accettano i valori dei comandi Sparkplug B (NCMD, DCMD). Chiunque possa pubblicare su questo broker può cambiare quelle sorgenti, quindi il nome utente e la password del broker sono la loro unica protezione. »

I campi di una riga si salvano nel momento in cui cambiano:

Sotto i campi una frase dice che cosa pubblica la riga:

Sotto quella frase, una riga in Lettura e scrittura mostra il suo Topic di scrittura, il topic della riga seguito da /set. In Sparkplug B non c'è un topic di scrittura: una seconda frase dice la metrica con cui la riga viene pubblicata, del suo dispositivo Sparkplug B per un tag, del nodo edge della stazione per una variabile e, per un allarme, le cinque metriche sotto il suo nome (Active, Acked, State, Priority e Message).

Una modifica che l'elenco rifiuta non viene salvata: il motivo è scritto in rosso sopra i campi della riga, e la modifica resta sullo schermo perché la si possa correggere.

Che cosa viene pubblicato, e quando, si trova in Pubblicazione.

Dispositivo

Il dispositivo non ha host, porta, credenziali né intervallo di interrogazione propri: tutto questo è del broker. Ogni ID Sparkplug B è un solo livello di topic: « Un ID Sparkplug B non può contenere '/', '+' o '#'. » Un broker nomina un nodo edge o un dispositivo Sparkplug B una volta sola, quindi un secondo dispositivo con gli stessi ID di gruppo, nodo edge e dispositivo su quel broker viene rifiutato: « Il dispositivo Sparkplug B Plant/Line1/Press1 sul broker 'Plant' appartiene già al dispositivo 'Press'. » I dispositivi in MQTT semplice non nominano niente di proprio sul broker, e due di loro possono leggere gli stessi topic.

La Base URI che mostra l'intestazione è l'indirizzo di runtime: mqtt://<broker id>?host=…&port=…&tls=0&keepAlive=60&clientId=…&mode=plain, con &silence=… quando il dispositivo imposta un tempo massimo senza messaggi, e per un dispositivo Sparkplug B mode=sparkplug&group=…&node=…, con &device=… dietro un nodo edge. Nomina il broker con la sua identità stabile, mai con il nome descrittivo, e non porta mai il nome utente né la password.

La copia di un dispositivo MQTT resta sullo stesso broker. Una copia Sparkplug B prende la prima identità che nessun dispositivo di quel broker ha: il suo ID più interno, l'ID del dispositivo o, per le metriche proprie del nodo edge, l'ID del nodo edge, viene numerato come il nome della copia (« Press1 (2) »).

Indirizzamento del tag

Il campo dell'indirizzo è Topic MQTT su un dispositivo in MQTT semplice e Metrica su uno Sparkplug B, ed è obbligatorio (« Topic MQTT è obbligatorio per questo driver. »). Un tag semplice ha altri tre campi; una metrica Sparkplug B non ne ha nessuno, perché porta il proprio tipo e si scrive con il comando proprio del protocollo.

I tipi di dato sono Boolean, Int16, Int32, Int64, Float, Double, String e DateTime. L'anteprima in sola lettura dell'indirizzo sul filo è il topic seguito da quello che si applica di path, command e payload (plant/line1/temperature?path=sensors[0].value&command=plant/line1/setpoint), oppure il nome della metrica; un carattere che chiuderebbe una parte (%, ?, &, =, #, +, uno spazio) si scrive come %XX.

Lettura

La sessione tiene l'ultimo messaggio di ogni topic a cui si è abbonata, e un tag legge da lì:

Un tag Boolean accetta true o false, 1 o 0, on o off. Un tag intero accetta un numero frazionario arrotondato e rifiuta uno fuori dal suo intervallo. Un tag DateTime accetta testo ISO 8601 o millisecondi Unix. Un tag String accetta il testo così com'è, e un oggetto o un array JSON come il suo JSON grezzo. Una metrica Sparkplug B di un tipo senza segno si legge nel tipo con segno immediatamente più largo (UInt8 come Int16, UInt16 come Int32, UInt32 e UInt64 come Int64), così che tutto il suo intervallo venga letto.

Scrittura

Una scrittura passa per lo stesso imbuto di quella di qualsiasi altro driver: la casella di scrittura riceve il valore ingegneristico, e le fasi di conversione vengono invertite prima che il valore grezzo venga pubblicato (vedere Connector).

Finché il broker non è raggiungibile, o il nodo edge o il dispositivo ha annunciato la propria morte, una scrittura viene rifiutata come scollegata e non si invia niente. Una scrittura Sparkplug B su una metrica che il certificato di nascita non dichiara viene rifiutata, perché il nodo edge non la accetterebbe, e così un valore che il tipo della metrica non può portare. Una scrittura non viene mai conservata: un setpoint conservato verrebbe applicato di nuovo da ogni abbonato che si colleghi in seguito.

Pubblicazione

Questa sezione descrive il Formato di pubblicazione su JSON; lo Sparkplug B ha la sezione seguente.

Ogni riga della scheda Pubblicare di un broker viene pubblicata sul suo topic, conservata, con QoS 1, attraverso la connessione che usano i dispositivi del broker: la stazione non apre mai una seconda connessione verso un broker. Un broker usato solo per pubblicare non ha bisogno di dispositivi. Resta sotto il driver MQTT, e il suo stato (Connessione…, Connesso, Non raggiungibile) è quello di questa connessione. Pubblica finché è abilitato e l'elenco ha righe; non ha un interruttore proprio.

Un valore viaggia nel suo tipo JSON: un numero, true o false, testo, una data e un'ora come testo ISO 8601; un numero che il JSON non porta (NaN, un infinito) viaggia come null. Un tag di un dispositivo disabilitato pubblica null e bad.

La stazione legge ciò che pubblica e non calcola nulla per farlo: l'ultima lettura di un tag, il valore di una variabile, lo stato di un allarme. Non si iscrive a nessun topic di una riga di sola lettura, quindi un messaggio che un altro sistema pubblica lì non raggiunge mai la stazione; una riga in Lettura e scrittura accetta valori sul suo topic di scrittura (Scrittura di ritorno). Un agente legge gli elenchi con mqtt_publish_list e li modifica con mqtt_publish_upsert e mqtt_publish_delete (Strumenti):

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()

Pubblicazione in Sparkplug B

Con Formato di pubblicazione su Sparkplug B, il broker pubblica lo stesso elenco secondo la specifica Sparkplug B, con la stazione come nodo edge: un host Sparkplug B, come il MQTT Engine di Ignition, elenca la stazione sotto il suo gruppo e il suo nodo edge, ogni dispositivo sotto di essa e ogni metrica con il suo tipo, senza alcuna mappatura costruita a mano. La connessione è quella che usano i dispositivi del broker, come in JSON.

Una / dentro un nome diventa _, quindi le cartelle sono gli unici livelli. Due dispositivi, o due metriche, i cui nomi diventano uguali ricevono _2, _3 nell'ordine dei loro nomi. Le righe conservano i loro topic, su cui in Sparkplug B non viene pubblicato nulla e su cui l'elenco torna a pubblicare quando il broker torna a JSON.

Ogni messaggio esce con QoS 0, mai conservato, tranne l'NDEATH. Il numero di sequenza seq riparte da 0 a ogni NBIRTH e conta ogni messaggio successivo fino a 255, poi ricomincia; bdSeq conta le connessioni, così l'NBIRTH e l'NDEATH di una connessione portano lo stesso numero. Nulla resta in coda mentre il broker non è raggiungibile.

Un tag viene pubblicato nel suo tipo; una variabile nel tipo con cui la serve il server OPC UA (un numero intero come Int64, un numero reale come Double, un valore di presentazione come testo). Ogni metrica porta la sua qualità nella proprietà Quality, la convenzione che leggono gli host Sparkplug B: 192 buona, 64 incerta (con l'ultimo valore pubblicato quando la lettura ha smesso di arrivare), 0 cattiva (la metrica resta allora senza valore).

La stazione ascolta sempre i comandi per il nodo edge, perché un host possa chiedere una rinascita, e i comandi per un dispositivo solo finché una delle sue righe è in Lettura e scrittura. Passare un broker a Sparkplug B fa riaprire la sua connessione una volta, perché il broker tenga l'ultima volontà del nodo edge; i dispositivi del broker la attraversano come ogni riconnessione. La stazione è un nodo edge e non un'applicazione host primaria: non aspetta il messaggio STATE di un host per nascere.

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

Scrittura di ritorno

Una riga di una scheda Pubblicare in Lettura e scrittura accetta valori sul suo topic di scrittura, il topic della riga seguito da /set: una dashboard nel cloud che legge plant/oven/setpoint invia un nuovo setpoint su plant/oven/setpoint/set. La stazione lo scrive come un client del suo server Modbus o del suo server OPC UA scrive una riga marcata in lettura e scrittura.

Il diario tecnico annota ogni scrittura con l'origine MQTT <nome del broker> nell'area Connector, come annota la scrittura di un operatore. Un messaggio che non è stato scritto viene annotato nell'area Connector, componente MQTT publication, una volta e poi in un riepilogo ogni pochi minuti finché si ripete.

Il nome utente e la password del broker sono l'unica protezione: chi il broker lascia pubblicare su un topic di scrittura può cambiare quella sorgente, e su un broker nel cloud condiviso con altre persone sono più persone dell'impianto. Dare all'account della dashboard sul broker solo i topic di cui ha bisogno. Su un broker in Sparkplug B le stesse righe accettano comandi Sparkplug B (NCMD, DCMD) al posto di un topic di scrittura (Pubblicazione in Sparkplug B).

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

Sicurezza

Con Usa TLS, il certificato del broker viene accettato in uno di due modi: la sua catena e il suo nome host si convalidano nell'archivio certificati di Windows, come in qualsiasi connessione HTTPS di questo computer, oppure è stato approvato proprio quel certificato in Accesso delle apparecchiature, nella pagina di questo driver. Un broker il cui certificato viene da un'autorità di certificazione propria diventa attendibile appena quell'autorità viene installata nell'archivio di Windows, e uno con un certificato autofirmato non richiede nulla di installato una volta approvato il suo certificato. La revoca non viene controllata, e nulla accetta un certificato alla cieca: uno sconosciuto viene rifiutato, il broker resta Non raggiungibile, con il motivo, e i suoi dispositivi attendono l'approvazione. La password viaggia dentro la connessione TLS; senza TLS viaggia in chiaro, come avverte la scheda.

Accesso delle apparecchiature

Un broker con un certificato autofirmato, o emesso da un'autorità propria, presenta un certificato di cui nessuna radice installata in Windows si fa garante. Non serve installare quella radice su questo computer. Con Usa TLS, la prima connessione viene rifiutata, il broker resta Non raggiungibile, con il motivo, i suoi dispositivi leggono In attesa dell'approvazione del certificato nell'albero e nelle loro pagine, il cui pulsante Verifica il certificato apre questa scheda sul certificato, e il certificato attende in Accesso delle apparecchiature, alla fine della pagina del driver MQTT, la stessa scheda che porta la pagina del driver OPC UA, finché non si decide:

Verificare l'impronta con chi gestisce il broker prima di approvare il certificato. Un'approvazione accetta quel certificato e nessun altro, e solo entro le sue date di validità; sostituisce la radice che manca a Windows e il nome che il certificato porta, così un broker raggiunto con il suo indirizzo IP si collega anche se il suo certificato nomina un altro host, e nient'altro del certificato viene allentato. Quando il broker risponde a un indirizzo di cui era stato approvato il certificato con un altro, i suoi dispositivi smettono di leggere, il nuovo attende qui e la stazione segnala « Certificato cambiato: <nome> » con un pulsante Verifica. Un rilevamento del broker dalla scheda Rileva i dispositivi incontra le stesse decisioni. Un certificato che Windows considera già attendibile viene accettato come prima e non compare mai qui; nulla viene approvato automaticamente.

La causa del broker dice il motivo invece di un errore TLS senza nome: « Il certificato del broker a <host>:<porta> (i primi 16 caratteri dell'impronta) attende la vostra approvazione in Accesso delle apparecchiature, nella pagina del driver MQTT. La lettura inizia appena lo approvate. » Uno bloccato dice « …è bloccato in questa stazione. Verificarlo in Accesso delle apparecchiature, nella pagina del driver MQTT. » Un certificato fuori dalle sue date di validità, revocato o con la firma non valida viene rifiutato con quel motivo e non viene mai elencato, perché nessuna approvazione lo rende valido.

Le decisioni sono conservate nella cartella dati della stazione, in ua\pki\mqtt, e sopravvivono a un riavvio. I verbi vengono disegnati solo per un ruolo che può configurare il Connector, e agiscono solo nella finestra della stazione stessa: un browser su un altro dispositivo legge la scheda senza cambiarla, e nessuno strumento di agente approva un certificato (connector_browse segnala i dispositivi del broker con awaitingCertificate). L'elenco tiene fino a 100 certificati in attesa di approvazione; quando è pieno, uno nuovo viene ancora rifiutato ma non elencato, e la scheda lo dice.

Preparare il broker

Un broker deve accettare le connessioni dal computer della stazione, e accettare l'accesso della stazione. Eclipse Mosquitto 2, il broker più diffuso, non fa né l'una né l'altra cosa di fabbrica: senza un listener nel suo mosquitto.conf ascolta solo sul proprio computer, e appena ne ha uno rifiuta un client senza nome utente. MQTT non dice quale broker ha risposto, quindi la stazione nomina Mosquitto come il caso comune, mai come una certezza.

I primi due sono detti sulla pagina del broker, al posto del suo errore in inglese, con questi passi e la porta; i suoi dispositivi continuano a rimandare al broker. L'avviso scompare da solo non appena la sessione si connette. Il segno dell'albero e il registro conservano la causa in inglese, che termina con gli stessi passi di Mosquitto.

Installare un broker

La stazione ha bisogno di un broker a cui collegarsi, e l'apparecchiatura anche. Dove non ce n'è uno, Eclipse Mosquitto è un piccolo broker che gira come servizio di Windows:

1. Scaricare il programma di installazione per Windows dalla pagina dei download di mosquitto.org ed eseguirlo. Installa il servizio Mosquitto Broker in C:\Program Files\mosquitto.

2. Di serie, Mosquitto risponde solo sul computer su cui gira. Per lasciare entrare le apparecchiature della rete, aggiungere un listener e un file di password al mosquitto.conf di quella cartella:

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

   Creare il file con l'account che useranno la stazione e le apparecchiature (il comando chiede la password):

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

3. Riavviare il servizio da un prompt dei comandi di amministratore, e consentire l'ingresso della porta TCP 1883 in Windows Defender Firewall per la rete delle apparecchiature:

   net stop mosquitto
   net start mosquitto
   

4. Nella pagina del broker, inserire localhost come Indirizzo host quando il broker gira sul computer stesso della stazione, oppure l'indirizzo di quel computer negli altri casi, Porta 1883 e l'account creato, poi Abilita.

Per provare un tag semplice prima che le apparecchiature siano collegate, pubblicare un valore di prova conservato dalla stessa cartella e puntare su di esso il Topic MQTT di un tag:

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

Limiti da conoscere

• Il driver MQTT è un client, non un broker: le apparecchiature e la stazione si collegano a un broker, il broker MQTT della stazione stessa o un altro.
• La scheda Pubblicare di un broker esce come JSON o come Sparkplug B, mai entrambi insieme. In Sparkplug B la stazione è un nodo edge, non un'applicazione host primaria, e non usa alias, modelli né valori storici.
• La stazione non è un'applicazione host Sparkplug B: non pubblica nessun messaggio STATE. Un nodo edge impostato per aspettare un host primario prima di pubblicare resta muto.
• Il MQTT semplice non dice niente di un editore che si è zittito: un tag semplice tiene l'ultimo valore ricevuto finché la connessione al broker regge, datato dal suo arrivo, a meno che il suo dispositivo non imposti un Tempo massimo senza messaggi (s). Un topic pubblicato solo quando il valore cambia non distingue un editore zittito da un valore stabile, quindi il suo dispositivo resta a 0. Lo Sparkplug B invece lo dice, con il certificato di morte.
• La sessione parte pulita: quello che è stato pubblicato mentre la stazione non era collegata non viene riproposto, ed è il messaggio conservato di un topic a ridare un valore al suo tag.
• Un tag legge un topic, mai un filtro, e un valore di esso; una metrica Sparkplug B che è un array, un set di dati, un template o un insieme di proprietà non viene letta.
• Solo TCP, con o senza TLS: niente MQTT su WebSockets, niente certificato client, e nessun broker più vecchio di MQTT 3.1.1.
• Un dispositivo non può essere spostato su un altro broker: crearlo sotto l'altro broker ed eliminare quello vecchio.