Prosedur migrasi untuk AWS IoT SiteWise alarm di AWS IoT Events

Ikuti Konfigurasi alarm pada aset dalam AWS IoT SiteWise prosedur hingga Anda setiap langkah untuk Mengedit properti model aset.

Untuk setiap properti yang akan dimigrasi, ubah status Pemberitahuan MQTT menjadi AKTIF.

Perhatikan jalur topik yang dipublikasikan alarm untuk setiap atribut alarm yang dimodifikasi.

Buka AWS Lambda console.

Pilih Buat fungsi.

Masukkan nama untuk nama Fungsi.

Pilih NodeJS 22.x sebagai Runtime.

Di dropdown Ubah peran eksekusi default, pilih Gunakan peran yang ada, lalu pilih peran IAM yang Anda buat di langkah sebelumnya.

Pilih Buat fungsi.

Tempel cuplikan kode berikut setelah mengganti konstanta kode keras.

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

Buka CloudWatch AWS Management Console.

Di navigasi kiri, pilih Metrik, lalu Semua metrik.

Pilih URL alarm untuk membukanya.

Di bawah tab Sumber, CloudWatch outputnya terlihat mirip dengan contoh ini. Informasi sumber ini menegaskan bahwa data metrik dimasukkan ke dalam 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"
}

Konfigurasikan alarm eksternal sebagai properti dalam model aset. Untuk informasi selengkapnya, lihat Mendefinisikan alarm eksternal AWS IoT SiteWise di Panduan AWS IoT SiteWise Pengguna.

Buat fungsi Lambda yang menggunakan BatchPutAssetPropertyValueAPI yang terdapat di Panduan AWS IoT SiteWise Pengguna untuk mengirim data alarm ke. AWS IoT SiteWise

Siapkan tindakan CloudWatch alarm untuk menjalankan fungsi Lambda Anda saat status alarm berubah. Untuk informasi selengkapnya, lihat bagian Tindakan alarm di Panduan CloudWatch Pengguna Amazon.