Tutorial: Archiviazione dei dati del dispositivo in una tabella DynamoDB

Accedi alla console Dynamo DB e scegli Create table (Crea una tabella).

In Create table (Crea tabella):

1. In Table name (Nome tabella), inserisci il nome della tabella: wx_data.

2. In Partition key (Chiave di partizione) inserisci sample_time e, nell'elenco delle opzioni accanto al campo, scegli Number.

3. In Sort key (chiave di ordinamento), inserisci device_id e nell'elenco delle opzioni accanto al campo, scegli Number.

4. Nella parte inferiore della pagina, scegli Create (Crea).

Apri l’hub Rules (Regole) della console AWS IoT. In alternativa, puoi aprire la AWS IoT home page all'interno di AWS Management Console e passare a Message Routing>Rules.

Per iniziare a creare la nuova regola in Rules (Regole), scegli Create rule (Crea regola).

In Proprietà delle regole:

1. In Role name (Nome ruolo) immettere wx_data_ddb.

   Ricorda che il nome di una regola deve essere univoco all'interno della tua regione Account AWS e non può avere spazi. Abbiamo usato un carattere di sottolineatura in questo nome per separare le due parole nel nome della regola.

2. In Description (Descrizione), descrivi la regola.

   Una descrizione significativa ti aiuta a ricordare cosa fa questa regola e perché l'hai creata. La descrizione può essere lunga quanto necessario, quindi sii il più dettagliato possibile.

Seleziona Successivo per continuare.

In Istruzione SQL:

1. In Versione SQL, seleziona 2016-03-23.

2. Nella casella di modifica Istruzione SQL, inserisci l'istruzione:

   SELECT temperature, humidity, barometer,
     wind.velocity as wind_velocity,
     wind.bearing as wind_bearing,
   FROM 'device/+/data'

   Questa istruzione:

   • Ascolta i messaggi MQTT con un argomento che corrisponde al filtro dell’argomento device/+/data.

   • Formatta gli elementi dell’attributo wind come attributi individuali.

   • Consente di passare gli attributi temperature, humidity e barometer invariati.

Seleziona Successivo per continuare.

In Azioni delle regole:

1. Per aprire l'elenco delle azioni della regola per questa regola, in Azione 1, scegli DynamoDB.

   Nota

   Assicurati di scegliere DynamoDB e non DBv2 Dynamo come azione della regola.

2. In Table name (Nome tabella) scegli il nome della tabella Dynamo DB creata in un passaggio precedente: wx_data.

   I campi Partition key type (Tipo di chiave di partizione) e Sort key type (Tipo di chiave di ordinamento) sono compilati con i valori dalla tabella Dynamo DB.

3. In Chiave di partizione, immettere sample_time.

4. In Partition key value (Valore della chiave di partizione), immettere ${timestamp()}.

   Questo è il primo di Modelli di sostituzione che userai in questa regola. Invece di utilizzare un valore dal payload del messaggio, utilizzerà il valore restituito dal metodo della funzione timestamp. Per ulteriori informazioni, consulta timestamp nella Guida per gli sviluppatori di AWS IoT Core .

5. In Sort key (chiave di ordinamento), immettere device_id.

6. In Sort key value (Valore della chiave di ordinamento), immettere ${cast(topic(2) AS DECIMAL)}.

   Questa è la seconda di Modelli di sostituzione che userai in questa regola. Inserisce il valore del secondo elemento nel nome dell’argomento, che è l'ID del dispositivo, dopo la sua trasformazione in un valore DECIMALE per corrispondere al formato numerico della chiave. Per ulteriori informazioni sugli argomenti, consulta la sezione argomenti nella Guida per sviluppatori di AWS IoT Core . Oppure per saperne di più sul casting, vedi cast nella Guida per lo Sviluppatore di AWS IoT Core .

7. In Write message data to this column (Scrivi i dati del messaggio in questa colonna), immettere device_data.

   Questo creerà la colonna device_data nella tabella Dynamo DB.

8. Lascia vuoto il campo Operation (Operazione).

9. In IAM Role (Ruolo IAM), scegli Create new role (Crea nuovo ruolo).

10. Nella finestra di dialogo Create role (Crea ruolo), per Role name (Nome ruolo), immetti wx_ddb_role. Questo nuovo ruolo conterrà automaticamente una policy con prefisso "aws-iot-rule" che consentirà alla wx_data_ddb regola di inviare dati alla tabella wx_data DynamoDB che hai creato.

11. In IAM role (Ruolo IAM) scegliere wx_ddb_role.

12. Nella parte inferiore della pagina scegli Next (Avanti).

Nella parte inferiore della pagina Rivedi e crea, scegli Create per creare la regola.

Nel Client MQTT nella console AWS IoT, effettua la sottoscrizione all'argomento di input, device/+/data.

1. Nel client MQTT, scegli Subscribe to a topic (Effettua la sottoscrizione a un argomento).

2. Per Topic filter (Filtro argomenti), inserisci l'argomento del filtro dell’argomento di input, device/+/data.

3. Scegliere Subscribe (Effettua sottoscrizione).

Ora pubblica un messaggio per l'argomento di input con un ID dispositivo specifico, device/22/data. Non è possibile pubblicare su argomenti MQTT che contengono caratteri jolly.

1. Nel client MQTT, scegli Publish to a topic (Pubblica in un argomento).

2. Per Topic name (Nome argomento), inserisci un nome per l'argomento di input, device/22/data.

3. Per Message payload (Payload del messaggio)(, inserisci i seguenti dati di esempio.

   {
     "temperature": 28,
     "humidity": 80,
     "barometer": 1013,
     "wind": {
       "velocity": 22,
       "bearing": 255
     }
   }

4. Per pubblicare il messaggio MQTT, scegli Publish (Pubblica).

5. Nel client MQTT, scegli Subscribe to a topic (Effettua la sottoscrizione a un argomento). Nella colonna Subscribe (Effettua sottoscrizione), scegli la sottoscrizione device/+/data. Verifica che vengano visualizzati i dati di esempio del passaggio precedente.

Seleziona per visualizzare la riga della tabella Dynamo DB creata dalla regola.

1. Nell'hub DynamoDB Tables AWS IoT della console, scegli wx_data, quindi scegli la scheda Items.

   Se sei già sulla scheda Items (Elementi), è possibile che sia necessario aggiornare la visualizzazione selezionando l'icona Aggiorna nell'angolo in alto a destra dell'intestazione della tabella.

2. Nota che i valori sample_time nella tabella sono collegamenti, quindi aprine uno. Se hai appena inviato il tuo primo messaggio, sarà l'unico nella lista.

   Questo collegamento visualizza tutti i dati nella riga della tabella.

3. Espandi la voce device_dati per visualizzare i dati risultanti dall'istruzione query della regola.

4. Esplora le diverse rappresentazioni dei dati disponibili in questo display. È possibile modificare i dati anche in questo display.

5. Al termine della revisione di questa riga di dati, per salvare le modifiche apportate, scegli Save (Salva) o, per uscire senza salvare le modifiche, scegli Cancel (Annulla).