Configure la acción de la AWS IoT SiteWise regla

Para crear una acción de AWS IoT SiteWise regla que analice cadenas de marcas de tiempo

1. Cree una función de Lambda con las siguientes propiedades:

   • Nombre de la función: utilice un nombre de función descriptivo (por ejemplo, ConvertNanosecondTimestampFromString).

   • Tiempo de ejecución: utilice un entorno de ejecución de Python 3, como Python 3.11 (python3.11).

   • Permisos: cree un rol con permisos Lambda básicos () AWS LambdaBasicExecutionRole.

   • Capas: añada la capa AWS SDKPandas-Python311 para que la utilice la función Lambda. numpy

   • Código de función: utilice el siguiente código de función, que consume un argumento de cadena denominado timestamp y las salidas timeInSeconds y offsetInNanos los valores de esa marca temporal.

     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
         }

     Esta función Lambda introduce cadenas de marcas de tiempo en formato ISO8601 mediante datetime64 from. NumPy

     nota

     Si las cadenas de marca de tiempo no están en el formato ISO 8601, puede implementar una solución que defina el formato de marca de tiempo. pandas Para obtener más información, consulte pandas.to_datetime..

2. Cuando configures la AWS IoT SiteWise acción de tu regla, usa las siguientes plantillas de sustitución para Time in seconds (timeInSeconds) y Offset in nanos (). offsetInNanos Estas plantillas de sustitución suponen que su carga de mensaje contiene la cadena de marca temporal en timestamp. La aws_lambda función utiliza una JSON estructura para su segundo parámetro, por lo que puedes modificar las siguientes plantillas de sustitución si es necesario.

   • En Time in seconds (Tiempo en segundos) (timeInSeconds), use la siguiente plantilla de sustitución.

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

   • En Offset in nanos (Desfase en nanosegundos) (offsetInNanos), use la siguiente plantilla de sustitución.

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

   Para cada parámetro, sustituya region y account-id con tu región y tu ID de AWS cuenta. Si ha usado otro nombre para su función de Lambda, cámbielo también.

3. Concede AWS IoT permisos para invocar tu función con el lambda:InvokeFunction permiso. Para obtener más información, consulte aws_lambda (,). functionArn inputJson

4. Pruebe la regla (por ejemplo, utilice el cliente de AWS IoT MQTT prueba) y compruebe que AWS IoT SiteWise recibe los datos que envía.

   Si su regla no funciona según lo previsto, consulte Solucionar problemas con una acción de AWS IoT SiteWise regla.