での AWS IoT SiteWise アラームの移行手順 AWS IoT Events

各ステップでアセットモデルのプロパティを編集するまで、「Configure alarm on assets in AWS IoT SiteWise procedure」に従います。

移行するプロパティごとに、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 ユーザーガイド」の「アラームアクション」セクションを参照してください。