Procedura di migrazione per gli AWS IoT SiteWise allarmi in AWS IoT Events

Segui la AWS IoT SiteWise procedura Configura gli allarmi sugli asset fino a completare il passaggio per modificare le proprietà del modello di asset.

Per ogni proprietà da migrare, impostate lo stato di notifica MQTT su ATTIVO.

Nota il percorso dell'argomento in cui viene pubblicato l'avviso per ogni attributo di allarme modificato.

Apri la AWS Lambda console.

Scegli Crea funzione.

Inserisci un nome per il nome della funzione.

Seleziona NodeJS 22.x come Runtime.

Nel menu a discesa Modifica ruolo di esecuzione predefinito, scegli Usa ruolo esistente, quindi seleziona il ruolo IAM creato nei passaggi precedenti.

Scegli Crea funzione.

Incolla il seguente frammento di codice dopo aver sostituito le costanti codificate.

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

Apri CloudWatch di AWS Management Console.

Nella barra di navigazione a sinistra, scegli Metriche, quindi Tutte le metriche.

Scegli l'URL di un avviso per aprirlo.

Nella scheda Sorgente, l' CloudWatch output è simile a quello di questo esempio. Queste informazioni sulla fonte confermano che i dati metrici vengono inseriti 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"
}

Configura l'allarme esterno come proprietà in un modello di asset. Per ulteriori informazioni, consulta Definire gli allarmi esterni AWS IoT SiteWise nella Guida per l'AWS IoT SiteWise utente.

Crea una funzione Lambda che utilizzi l'BatchPutAssetPropertyValueAPI disponibile nella Guida per l'AWS IoT SiteWise utente a cui inviare i dati di allarme. AWS IoT SiteWise

Imposta le azioni di CloudWatch allarme per richiamare la funzione Lambda quando lo stato dell'allarme cambia. Per ulteriori informazioni, consulta la sezione Azioni di allarme nella Amazon CloudWatch User Guide.