Nota:
- Questa esercitazione richiede l'accesso a Oracle Cloud. Per iscriversi a un account gratuito, consulta Inizia a utilizzare Oracle Cloud Infrastructure Free Tier.
- Utilizza valori di esempio per le credenziali, la tenancy e i compartimenti di Oracle Cloud Infrastructure. Al termine del laboratorio, sostituisci questi valori con quelli specifici del tuo ambiente cloud.
Integra ThingsBoard con i servizi di streaming OCI
Introduzione
ThingsBoard è una piattaforma IoT open source per la raccolta dei dati, l'elaborazione, la visualizzazione e la gestione dei dispositivi. Questa esercitazione descrive i passi da seguire per integrare ThingsBoard con i servizi di streaming di Oracle Cloud Infrastructure (OCI). In questo modo è possibile memorizzare i dati in un database, eseguire l'analisi, utilizzare le funzioni per modificare ed elaborare queste informazioni.
Obiettivi
- Raccogliere le informazioni necessarie da OCI.
- Configurare un nodo Kafka in una catena di regole ThingsBoard.
Prerequisiti
- Conoscenza di base di OCI Streaming, Kafka.
- Informazioni sulla catena di regole ThingsBoard.
- Privilegi utente per la creazione e l'accesso alle risorse di streaming.
- ThingsBoard installato su un sistema. Puoi trovare le procedure di installazione della Community Edition qui.
Task 1: raccolta dei parametri di steaming OCI necessari per l'integrazione con un server Kafka
-
Se non hai già creato un flusso OCI, puoi seguire questi passi per creare un nuovo flusso dalla console.
-
Nel caso di un flusso esistente, tenere presenti le seguenti informazioni:
-
Aprire il menu di navigazione e fare clic su Analitica e AI.
-
In Messaggistica fare clic su Streaming.
-
Nella scheda Streams aprire il flusso esistente e prendere nota del nome del flusso, ad esempio: thingsboard_stream
-
Fare clic sul collegamento Pool di streaming, ad esempio: thingsboard_stream_pool
-
Nel menu a sinistra, accedere a Impostazioni di connessione Kafka e copiare le informazioni riportate di seguito.
-
Server di bootstrap: ad esempio, cell-1.streaming.eu-frankfurt-1.oci.oraclecloud.com:9092
-
Stringhe di connessione SASL: ad esempio, *org.apache.kafka.common.security.plain.PlainLoginModule obbligatorio username="
/oracleidentitycloudservice/ / " password="AUTH_TOKEN";* -
Protocollo di sicurezza: SASL_SSL
-
Meccanismo di sicurezza: PLAIN
-
-
Nell'angolo in alto a destra della schermata, fare clic sull'icona del profilo. In Profilo utente fare clic su Token di autenticazione, generare un token e copiare il valore: AUTH_TOKEN, ad esempio: xmo?(cv<abcd..... È inoltre possibile utilizzare un token esistente.
-
Task 2: configurare il nodo della regola Kafka
-
Trascinare un nodo della regola Kafka dal pannello di azione. Verranno utilizzate le informazioni annotate nel task 1 per configurare la regola Kafka.
-
Nome: ad esempio - ThingsBoard2OCIStream
-
Pattern di argomenti: "StreamName", ad esempio - thingsdemo-s0
-
Server di bootstrap: "Server di bootstrap", ad esempio - cell-1.streaming.eu-frankfurt-1.oci.oraclecloud.com:9092
-
Altre proprietà: fare clic su Aggiungi e aggiungere le seguenti coppie di chiavi:
-
security.protocol: "Protocollo di sicurezza" SASL_SSL
-
sasl.mechanism: PLAINA "Meccanismo di sicurezza"
-
ssl.endpoint.identification.algorithm: https
-
sasl.jaas.config: <Stringhe di connessione SASL:>, ad esempio - *org.apache.kafka.common.security.plain.PlainLoginModule obbligatorio username="
/ / " password="AUTH_TOKEN";* (sostituire AUTH_TOKEN con il valore copiato nel task 1)
-
-
NOTA:
Se la stringa sasl.jaas.config non funziona, potrebbe essersi verificato un problema con Oracle Identity Cloud Service nella tenancy, quindi provare a utilizzare la stessa risorsa da un utente locale.
Facoltativo: è inoltre possibile selezionare la modalità Debug per la risoluzione dei problemi.
Dopo aver aggiornato i valori richiesti, fare clic sul pulsante Verifica per salvare la configurazione.
Task 3: configurazione della catena di regole
-
Trascinare un collegamento tra blocchi di timeeries e kafka, in modo da poter inoltrare la serie temporale salvata al nostro flusso OCI.
-
Immettere Operazione riuscita per l'etichetta del collegamento.
-
Fare clic sul pulsante Checkmark per salvare la configurazione.
-
Eseguire il login alla console OCI e controllare il flusso per confermare che sta ricevendo i dati. Fare clic su Load Messages.
Dopo che le informazioni sono state ricevute in streaming OCI, è possibile utilizzare il servizio Connettore di servizio OCI, ad esempio per trasferirlo in altri servizi come storage OCI, funzioni OCI e così via.
Collegamenti correlati
Conferme
- Adina Nicolescu (senior Cloud Engineer), Guido Alejandro Ferreyra (Principal Cloud Architect)
Altre risorse di apprendimento
Esplora altri laboratori su docs.oracle.com/learn o accedi a contenuti di formazione gratuiti sul canale YouTube di Oracle Learning. Inoltre, visitare education.oracle.com/learning-explorer per diventare Explorer di Oracle Learning.
Per la documentazione sul prodotto, visitare il sito Oracle Help Center.
Integrate ThingsBoard with OCI Streaming Services
F79939-01
April 2023
Copyright © 2023, Oracle and/or its affiliates.