Procédure de migration pour les AWS IoT SiteWise alarmes dans AWS IoT Events

Suivez la AWS IoT SiteWise procédure de configuration des alarmes sur les actifs jusqu'à ce que vous passiez à chaque étape de modification des propriétés du modèle d'actifs.

Pour chaque propriété à migrer, remplacez le statut de notification MQTT par ACTIVE.

Notez le chemin de rubrique vers lequel l'alarme est publiée pour chaque attribut d'alarme modifié.

Ouvrez la AWS Lambda console.

Choisissez Créer une fonction.

Entrez un nom pour le nom de la fonction.

Sélectionnez NodeJS 22.x comme environnement d'exécution.

Dans la liste déroulante Modifier le rôle d'exécution par défaut, choisissez Utiliser le rôle existant, puis sélectionnez le rôle IAM que vous avez créé lors des étapes précédentes.

Choisissez Créer une fonction.

Collez l'extrait de code suivant après avoir remplacé les constantes codées en dur.

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

Ouvrez la CloudWatch AWS Management Console.

Dans le volet de navigation de gauche, choisissez Metrics, puis All metrics.

Choisissez l'URL d'une alarme pour l'ouvrir.

Sous l'onglet Source, le CloudWatch résultat est similaire à celui de cet exemple. Ces informations de source confirment que les données métriques alimentent 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"
}

Configurez l'alarme externe en tant que propriété dans un modèle d'actif. Pour plus d'informations, voir Définir les alarmes externes AWS IoT SiteWise dans le guide de AWS IoT SiteWise l'utilisateur.

Créez une fonction Lambda qui utilise l'BatchPutAssetPropertyValueAPI figurant dans le guide de l'AWS IoT SiteWise utilisateur pour envoyer des données d'alarme à. AWS IoT SiteWise

Configurez des actions CloudWatch d'alarme pour appeler votre fonction Lambda lorsque l'état de l'alarme change. Pour plus d'informations, consultez la section Actions d'alarme du guide de CloudWatch l'utilisateur Amazon.