Procedimiento de migración de AWS IoT SiteWise alarmas en AWS IoT Events

Siga el AWS IoT SiteWise procedimiento de configuración de las alarmas de los activos hasta llegar a editar las propiedades del modelo de activos.

Para cada propiedad que vaya a migrar, cambie el estado de la notificación MQTT a ACTIVO.

Anote la ruta temática en la que se publica la alarma para cada atributo de alarma modificado.

Abra la AWS Lambda console.

Elija Crear función.

Introduzca un nombre para el nombre de la función.

Seleccione Nodejs 22.x como motor de ejecución.

En el menú desplegable Cambiar la función de ejecución predeterminada, elija Usar la función existente y, a continuación, seleccione la función de IAM que creó en los pasos anteriores.

Elija Crear función.

Pegue el siguiente fragmento de código después de reemplazar las constantes codificadas de forma rígida.

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)}')
        }

Abra la CloudWatch de AWS Management Console.

En el menú de navegación de la izquierda, selecciona Métricas y, a continuación, Todas las métricas.

Elige la URL de una alarma para abrirla.

En la pestaña Fuente, el CloudWatch resultado tiene un aspecto similar al de este ejemplo. La información de esta fuente confirma que se están introduciendo los datos de las métricas 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"
}

Configure la alarma externa como una propiedad en un modelo de activos. Para obtener más información, consulte Definir alarmas externas AWS IoT SiteWise en la Guía del AWS IoT SiteWise usuario.

Cree una función Lambda que utilice la BatchPutAssetPropertyValueAPI que se encuentra en la Guía del AWS IoT SiteWise usuario para enviar datos de alarma a. AWS IoT SiteWise

Configure acciones de CloudWatch alarma para invocar la función Lambda cuando cambien los estados de alarma. Para obtener más información, consulta la sección Acciones de alarma en la Guía del CloudWatch usuario de Amazon.