Interroga i dati con Athena

Per interrogare i dati degli asset con Athena

1. Vai alla console Athena.

   Se viene visualizzata la pagina Nozioni di base, scegliere Inizia.

2. Se utilizzi Athena per la prima volta, completa i seguenti passaggi per configurare un bucket S3 per i risultati delle query. Athena memorizza i risultati delle tue ricerche in questo bucket.

   Importante

   Utilizzare un bucket diverso rispetto al bucket dei dati di asset, in modo che il crawler creato in precedenza non esegua il crawling dei risultati delle query. Ti consigliamo di creare un bucket da utilizzare solo per i risultati delle query Athena. Per ulteriori informazioni, consulta Creare un bucket nella Guida per l'utente di Amazon Simple Storage Service.

   1. Seleziona Impostazioni.

   2. In Posizione dei risultati della query, inserisci il bucket S3 per i risultati della query Athena. Il bucket deve terminare con /.

      

   3. Seleziona Salva.

3. Il pannello a sinistra contiene l'origine dati su cui eseguire le query. Esegui questa operazione:

   1. Per Origine dati, scegli di AwsDataCatalogutilizzare il. AWS Glue Data Catalog

   2. Per Database, scegli il AWS Glue database che hai creato con il crawler.

      

   Vengono visualizzate due tabelle: asset_metadata e asset_property_updates.

4. Per creare una visualizzazione a partire dalla combinazione di dati delle proprietà degli asset e metadati, immettere la query seguente e scegliere Esegui query.

   CREATE
           OR REPLACE VIEW iot_sitewise_asset_data AS
   SELECT "from_unixtime"("time_in_seconds" + ("offset_in_nanos" / 1000000000)) "timestamp",
            "metadata"."asset_name",
            "metadata"."asset_property_name",
            "data"."asset_property_value",
            "metadata"."asset_property_unit",
            "metadata"."asset_property_alias"
   FROM ( "iot_sitewise_asset_database".asset_property_updates data
   INNER JOIN "iot_sitewise_asset_database".asset_metadata metadata
       ON ( ("data"."asset_id" = "metadata"."asset_id")
           AND ("data"."asset_property_id" = "metadata"."asset_property_id") ) );

   Questa query esegue il join dei dati delle proprietà degli asset e delle tabelle dei metadati sull'ID asset e l'ID proprietà per creare una visualizzazione. È possibile eseguire questa query più volte perché sostituisce la visualizzazione esistente, se esiste già.

5. Per aggiungere una nuova query, scegli l'icona +.

6. Per visualizzare un esempio di dati degli asset, immettere la query seguente e scegliere Esegui query. Sostituire i timestamp con un intervallo per il quale il bucket contiene dati.

   SELECT *
   FROM "iot_sitewise_asset_database"."iot_sitewise_asset_data"
   WHERE "timestamp"
       BETWEEN TIMESTAMP '2020-05-14 12:00:00.000'
           AND TIMESTAMP '2020-05-14 13:00:00.000'
   ORDER BY  "timestamp" DESC LIMIT 50;

   Questa query genera fino a 50 punti dati tra due timestamp, con le voci più recenti visualizzate per prime.

   L'aspetto dell'output della query è simile ai risultati seguenti.