Procedimento de migração para AWS IoT SiteWise alarmes em AWS IoT Events

Siga o AWS IoT SiteWise procedimento Configurar alarmes em ativos até chegar à etapa de edição das propriedades do modelo de ativo.

Para cada propriedade a ser migrada, altere o status da Notificação MQTT para ATIVO.

Observe o caminho do tópico no qual o alarme é publicado para cada atributo de alarme modificado.

Abra a AWS Lambda console.

Escolha a opção Criar função.

Insira um nome para o nome da função.

Selecione NodeJS 22.x como Runtime.

No menu suspenso Alterar função de execução padrão, escolha Usar função existente e selecione a função do IAM que você criou nas etapas anteriores.

Escolha a opção Criar função.

Cole o seguinte trecho de código depois de substituir as constantes codificadas.

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 o CloudWatch do AWS Management Console.

No painel de navegação à esquerda, escolha Métricas e, em seguida, Todas as métricas.

Escolha o URL de um alarme para abri-lo.

Na guia Fonte, a CloudWatch saída é semelhante a este exemplo. Essas informações de origem confirmam que os dados métricos estão sendo CloudWatch inseridos.

{
    "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 o alarme externo como uma propriedade em um modelo de ativo. Para obter mais informações, consulte Definir alarmes externos AWS IoT SiteWise no Guia do AWS IoT SiteWise usuário.

Crie uma função Lambda que use a BatchPutAssetPropertyValueAPI encontrada no Guia do AWS IoT SiteWise usuário para enviar dados de alarme para o. AWS IoT SiteWise

Configure ações de CloudWatch alarme para invocar sua função Lambda quando os estados do alarme mudarem. Para obter mais informações, consulte a seção Ações de alarme no Guia CloudWatch do usuário da Amazon.