Athena로 데이터 쿼리

Athena로 자산 데이터 쿼리

1. Athena 콘솔로 이동합니다.

   시작하기 페이지가 나타나면 시작하기를 선택합니다.

2. Athena를 처음 사용하는 경우 다음 단계를 완료하여 쿼리 결과에 대한 S3 버킷을 구성합니다. Athena는 쿼리 결과를 이 버킷에 저장합니다.

   중요

   이전에 생성한 크롤러가 쿼리 결과를 크롤하지 않도록 자산 데이터 버킷과 다른 버킷을 사용하십시오. Athena 쿼리 결과에만 사용할 버킷을 생성하는 것이 좋습니다. 자세한 내용은 Amazon Simple Storage Service 사용 설명서에서 버킷 생성을 참조하세요.

   1. 설정을 선택합니다.

   2. 쿼리 결과 위치에 Athena 쿼리 결과를 위한 S3 버킷을 입력합니다. 버킷은 /로 끝나야 합니다.

      

   3. 저장(Save)을 선택합니다.

3. 왼쪽 패널에는 쿼리할 데이터 원본이 포함되어 있습니다. 다음을 따릅니다.

   1. 데이터 소스의 경우 를 AwsDataCatalog사용하도록 선택하십시오. AWS Glue Data Catalog

   2. 데이터베이스의 경우 크롤러로 만든 AWS Glue 데이터베이스를 선택합니다.

      

   테이블 2개가 보여야 합니다(asset_metadata 및 asset_property_updates).

4. 자산 속성 데이터와 메타데이터를 조합하여 보기를 생성하려면 다음 쿼리를 입력한 다음 쿼리 실행을 선택합니다.

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

   이 쿼리는 자산 ID 및 속성 ID의 자산 속성 데이터 및 메타데이터 테이블을 조인하여 보기를 생성합니다. 보기가 이미 존재하는 경우 기존 보기를 대체하기 때문에 이 쿼리는 여러 번 실행할 수 있습니다.

5. + 아이콘을 선택하여 새 쿼리를 추가합니다.

6. 자산 데이터 샘플을 보려면 다음 쿼리를 입력한 다음 쿼리 실행을 선택합니다. 타임스탬프는 버킷에 데이터가 있는 간격으로 바꿉니다.

   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;

   이 쿼리는 타임스탬프 2개 사이에 데이터 포인트 최대 50개를 출력하며 가장 최근 항목을 먼저 표시합니다.

   쿼리 출력은 다음 결과와 비슷합니다.