Configurar a ação da AWS IoT SiteWise regra

Para criar uma ação de AWS IoT SiteWise regra que analisa cadeias de caracteres de carimbo de data/hora

1. Crie uma função do Lambda com as seguintes propriedades:

   • Nome da função – use um nome descritivo de função (por exemplo, ConvertNanosecondTimestampFromString).

   • Tempo de execução — Use um tempo de execução do Python 3, como o Python 3.11 (). python3.11

   • Permissões — Crie uma função com permissões básicas do Lambda () AWS LambdaBasicExecutionRole.

   • Camadas — Adicione a AWS SDKPandascamada -Python311 para usar a função Lambda. numpy

   • Código de função – use o código de função a seguir, que consome um argumento de string chamado timeInSeconds e emite na saída os valores timestamp e offsetInNanos para esse time stamp.

     import json
     import math
     import numpy
     
     # Converts a timestamp string into timeInSeconds and offsetInNanos in Unix epoch time.
     # The input timestamp string can have up to nanosecond precision.
     def lambda_handler(event, context):
         timestamp_str = event['timestamp']
         # Parse the timestamp string as nanoseconds since Unix epoch.
         nanoseconds = numpy.datetime64(timestamp_str, 'ns').item()
         time_in_seconds = math.floor(nanoseconds / 1E9)
         # Slice to avoid precision issues.
         offset_in_nanos = int(str(nanoseconds)[-9:])
         return {
             'timeInSeconds': time_in_seconds,
             'offsetInNanos': offset_in_nanos
         }

     Essa função Lambda insere cadeias de caracteres de timestamp no ISO formato 8601 usando datetime64 de. NumPy

     nota

     Se suas cadeias de caracteres de carimbo de data/hora não estiverem no formato ISO 8601, você poderá implementar uma solução pandas que defina o formato de carimbo de data/hora. Para obter mais informações, consulte pandas.to_datetime.

2. Ao configurar a AWS IoT SiteWise ação para sua regra, use os seguintes modelos de substituição para Tempo em segundos (timeInSeconds) e Deslocamento em nanos (). offsetInNanos Esses modelos de substituição presumem que a carga de mensagem contém a string de time stamp em timestamp. A aws_lambda função consome uma JSON estrutura para seu segundo parâmetro, então você pode modificar os modelos de substituição abaixo, se necessário.

   • Para Time in seconds (Tempo em segundos) (timeInSeconds), use o seguinte modelo de substituição.

     ${aws_lambda('arn:aws:lambda:region:account-id:function:ConvertNanosecondTimestampFromString', {'timestamp': timestamp}).timeInSeconds}

   • Para Offset in nanos (Deslocamento em nanos) (offsetInNanos), use o seguinte modelo de substituição.

     ${aws_lambda('arn:aws:lambda:region:account-id:function:ConvertNanosecondTimestampFromString', {'timestamp': timestamp}).offsetInNanos}

   Para cada parâmetro, substitua region e account-id com sua região e ID AWS da conta. Se você usou um nome diferente para sua função do Lambda, altere-o também.

3. Conceda AWS IoT permissões para invocar sua função com a lambda:InvokeFunction permissão. Para obter mais informações, consulte aws_lambda (,). functionArn inputJson

4. Teste sua regra (por exemplo, use o cliente AWS IoT MQTT de teste) e verifique se ele AWS IoT SiteWise recebe os dados que você envia.

   Se sua regra não funcionar como esperado, consulte Solucionar problemas de uma ação de AWS IoT SiteWise regra.