Migrationsverfahren für AWS IoT SiteWise Alarme in AWS IoT Events

Folgen Sie der Anleitung Alarme für Anlagen konfigurieren, AWS IoT SiteWise bis Sie den Schritt zum Bearbeiten der Eigenschaften des Asset-Modells abgeschlossen haben.

Ändern Sie für jede zu migrierende Eigenschaft den Status der MQTT-Benachrichtigung auf AKTIV.

Notieren Sie sich den Themenpfad, unter dem der Alarm für jedes geänderte Alarmattribut veröffentlicht wird.

Öffnen Sie die AWS Lambda console.

Wählen Sie Funktion erstellen.

Geben Sie einen Namen für den Funktionsnamen ein.

Wählen Sie NodeJS 2.x als Runtime aus.

Wählen Sie in der Dropdownliste Standardausführungsrolle ändern die Option Bestehende Rolle verwenden und wählen Sie dann die IAM-Rolle aus, die Sie in den vorherigen Schritten erstellt haben.

Wählen Sie Funktion erstellen.

Fügen Sie den folgenden Codeausschnitt ein, nachdem Sie die hartcodierten Konstanten ersetzt haben.

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

Öffnen Sie das CloudWatch AWS Management Console.

Wählen Sie in der linken Navigationsleiste Metriken und dann Alle Metriken aus.

Wählen Sie die URL eines Alarms aus, um ihn zu öffnen.

Auf der Registerkarte Quelle sieht die CloudWatch Ausgabe ähnlich wie in diesem Beispiel aus. Diese Quellinformationen bestätigen, dass die metrischen Daten in 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"
}

Konfigurieren Sie den externen Alarm als Eigenschaft in einem Asset-Modell. Weitere Informationen finden Sie AWS IoT SiteWise im AWS IoT SiteWise Benutzerhandbuch unter Definieren externer Alarme.

Erstellen Sie eine Lambda-Funktion, die die BatchPutAssetPropertyValueAPI im AWS IoT SiteWise Benutzerhandbuch verwendet, um Alarmdaten an zu AWS IoT SiteWise senden.

Richten Sie CloudWatch Alarmaktionen ein, um Ihre Lambda-Funktion aufzurufen, wenn sich der Alarmstatus ändert. Weitere Informationen finden Sie im Abschnitt Alarmaktionen im CloudWatch Amazon-Benutzerhandbuch.