의 AWS IoT SiteWise 경보에 대한 마이그레이션 절차 AWS IoT Events

자산 모델의 속성을 편집하는 각 단계까지 진행 중인 자산에 대한 경보 구성 AWS IoT SiteWise 절차를 따릅니다.

마이그레이션할 각 속성에 대해 MQTT 알림 상태를 ACTIVE로 변경합니다.

수정된 각 경보 속성에 대해 경보가 게시하는 주제 경로를 기록해 둡니다.

AWS Lambda console을 엽니다.

함수 생성을 선택합니다.

함수 이름의 이름을 입력합니다.

NodeJS 22.x를 런타임으로 선택합니다.

기본 실행 역할 변경 드롭다운에서 기존 역할 사용을 선택한 다음 이전 단계에서 생성한 IAM 역할을 선택합니다.

함수 생성을 선택합니다.

하드 코딩된 상수를 교체한 후 다음 코드 조각을 붙여 넣습니다.

import json
import boto3
from datetime import datetime

# Initialize CloudWatch client
cloudwatch = boto3.client('cloudwatch')

def lambda_handler(message, context):
    try:
        # Parse the incoming IoT message
        # Extract relevant information
        asset_id = message['payload']['assetId']
        property_id = message['payload']['propertyId']
        
        # Process each value in the values array
        for value in message['payload']['values']:
            # Extract timestamp and value
            timestamp = datetime.fromtimestamp(value['timestamp']['timeInSeconds'])
            metric_value = value['value']['doubleValue']
            quality = value.get('quality', 'UNKNOWN')
            
            # Publish to CloudWatch
            response = cloudwatch.put_metric_data(
                Namespace='IoTSiteWise/AssetMetrics',
                MetricData=[
                    {
                        'MetricName': f'Property_your-property-id',
                        'Value': metric_value,
                        'Timestamp': timestamp,
                        'Dimensions': [
                            {
                                'Name': 'AssetId',
                                'Value': 'your-asset-id'
                            },
                            {
                                'Name': 'Quality',
                                'Value': quality
                            }
                        ]
                    }
                ]
            )
            
        return {
            'statusCode': 200,
            'body': json.dumps('Successfully published metrics to CloudWatch')
        }
        
    except Exception as e:
        print(f'Error processing message: {str(e)}')
        return {
            'statusCode': 500,
            'body': json.dumps(f'Error: {str(e)}')
        }

CloudWatch AWS Management Console를 엽니다.

왼쪽 탐색 창에서 지표를 선택한 다음 모든 지표를 선택합니다.

경보의 URL을 선택하여 엽니다.

소스 탭에서 CloudWatch 출력은이 예제와 비슷합니다. 이 소스 정보는 지표 데이터가 CloudWatch로 공급되고 있음을 확인합니다.

{
    "view": "timeSeries",
    "stacked": false,
    "metrics": [
        [ "IoTSiteWise/AssetMetrics", "Property_your-property-id-hash", "Quality", "GOOD", "AssetId", "your-asset-id-hash", { "id": "m1" } ]
    ],
    "region": "your-region"
}

외부 경보를 자산 모델의 속성으로 구성합니다. 자세한 내용은 AWS IoT SiteWise 사용 설명서의 에서 외부 경보 정의를 AWS IoT SiteWise 참조하세요.

AWS IoT SiteWise 사용 설명서의 BatchPutAssetPropertyValue API를 사용하여 경보 데이터를 로 전송하는 Lambda 함수를 생성합니다 AWS IoT SiteWise.

경보 상태가 변경될 때 Lambda 함수를 호출하도록 CloudWatch 경보 작업을 설정합니다. 자세한 내용은 Amazon CloudWatch 사용 설명서의 경보 작업 섹션을 참조하세요.