中的 AWS IoT SiteWise 警示遷移程序 AWS IoT Events

遵循程序中的資產設定警示 AWS IoT SiteWise，直到您完成編輯資產模型屬性的每個步驟。

對於每個要遷移的屬性，請將 MQTT 通知狀態變更為 ACTIVE。

請注意警示針對每個修改的警示屬性發佈的主題路徑。

開啟 AWS Lambda console。

選擇 Create function (建立函數)。

輸入函數名稱的名稱。

選取 NodeJS 22.x 作為執行時間。

在變更預設執行角色下拉式清單中，選擇使用現有角色，然後選取您在先前步驟中建立的 IAM 角色。

選擇 Create function (建立函數)。

在取代硬式編碼常數之後，貼上下列程式碼片段。

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。

建立 Lambda 函數，使用AWS IoT SiteWise 《 使用者指南》中的 BatchPutAssetPropertyValue API 將警示資料傳送至 AWS IoT SiteWise。

設定 CloudWatch 警示動作，以在警示狀態變更時叫用 Lambda 函數。如需詳細資訊，請參閱《Amazon CloudWatch 使用者指南》中的警示動作一節。