Interrogez des données avec Athena

Pour interroger les données des actifs avec Athena

1. Accédez à la console Athena.

   Si la page Mise en route s'affiche, choisissez Démarrer.

2. Si vous utilisez Athena pour la première fois, suivez les étapes ci-dessous pour configurer un compartiment S3 pour les résultats des requêtes. Athena stocke les résultats de vos requêtes dans ce compartiment.

   Important

   Utilisez un compartiment différent de celui de votre compartiment de données de ressources, afin que l'analyseur que vous avez créé précédemment n'analyse pas les résultats de la requête. Nous vous recommandons de créer un bucket à utiliser uniquement pour les résultats des requêtes Athena. Pour plus d'informations, consultez la section Création d'un compartiment dans le guide de l'utilisateur d'Amazon Simple Storage Service.

   1. Sélectionnez Settings (Paramètres).

   2. Dans Emplacement des résultats de la requête, entrez le compartiment S3 pour les résultats de la requête Athena. Le compartiment doit se terminer par /.

      

   3. Choisissez Save (Enregistrer).

3. Le panneau de gauche contient la source de données à interroger. Procédez comme suit :

   1. Pour Source de données, choisissez AwsDataCatalogd'utiliser le AWS Glue Data Catalog.

   2. Pour Base de données, choisissez la AWS Glue base de données que vous avez créée avec le robot d'exploration.

      

   Vous devez voir deux tables : asset_metadata et asset_property_updates.

4. Pour créer une vue à partir de la combinaison de données et de métadonnées de propriétés de ressources, entrez la requête suivante, puis choisissez Exécuter la requête.

   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") ) );

   Cette requête joint les tables de données et de métadonnées de propriétés de ressources sur l'ID de ressource et l'ID de propriété pour créer une vue. Vous pouvez exécuter cette requête plusieurs fois, car elle remplace la vue existante, si elle existe déjà.

5. Pour ajouter une nouvelle requête, cliquez sur l'icône +.

6. Pour afficher un exemple de données de ressource, entrez la requête suivante, puis choisissez Exécuter la requête. Remplacez les horodatages par un intervalle pour lequel votre compartiment contient des données.

   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;

   Cette requête génère jusqu'à 50 points de données entre deux horodatages. Les entrées les plus récentes sont affichées en premier.

   Votre sortie de requête peut ressembler aux résultats suivants.