中 Amazon IoT SiteWise 警报的迁移程序 Amazon IoT Events

按照中的配置资产警报 Amazon IoT SiteWise程序进行操作，直到完成编辑资产模型属性的步骤。

对于要迁移的每个属性，将 MQTT 通知状态更改为 “活动”。

记下每个修改后的警报属性的警报发布到的主题路径。

打开 Amazon 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 Amazon Web Services Management Console。

在左侧导航栏中，选择指标，然后选择所有指标。

选择警报的 URL 将其打开。

在 S ourc e 选项卡下， 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"
}

将外部警报配置为资产模型中的一个属性。有关更多信息，请参阅《Amazon IoT SiteWise 用户指南》 Amazon IoT SiteWise中的定义外部警报。

创建一个 Lambda 函数，该函数使用Amazon IoT SiteWise 用户指南中的 BatchPutAssetPropertyValueAPI 向其发送警报数据。 Amazon IoT SiteWise

设置 CloudWatch 警报操作，以便在警报状态发生变化时调用 Lambda 函数。有关更多信息，请参阅《Amazon CloudWatch 用户指南》中的 “警报操作” 部分。