Configura l'azione della AWS IoT SiteWise regola

Per creare un'azione di AWS IoT SiteWise regola che analizzi le stringhe del timestamp

1. Crea una funzione Lambda con le seguenti proprietà:

   • Nome della funzione: utilizza un nome di funzione descrittivo (ad esempio,ConvertNanosecondTimestampFromString).

   • Runtime — Usa un runtime Python 3, come Python 3.11 (). python3.11

   • Autorizzazioni: crea un ruolo con AWS LambdaBasicExecutionRoleautorizzazioni Lambda di base ().

   • Livelli: aggiungi il AWS SDKPandaslivello -Python311 per l'utilizzo della funzione Lambda. numpy

   • Codice funzione: utilizzate il seguente codice di funzione, che utilizza un argomento di stringa denominato timestamp e restituisce e valori per quel timestamp. timeInSeconds offsetInNanos

     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
         }

     Questa funzione Lambda immette stringhe di timestamp in formato 8601 utilizzando datetime64 from. ISO NumPy

     Nota

     Se le stringhe del timestamp non sono in formato ISO 8601, puoi implementare una soluzione che definisca il formato del timestamp. pandas Per ulteriori informazioni, consulta pandas.to_datetime.

2. Quando configuri l' AWS IoT SiteWise azione per la tua regola, usa i seguenti modelli sostitutivi per Time in seconds () e Offset in nanos (). timeInSeconds offsetInNanos Questi modelli di sostituzione presuppongono che il payload del messaggio contenga la stringa timestamp in timestamp. La aws_lambda funzione utilizza una JSON struttura per il secondo parametro, quindi potete modificare i modelli di sostituzione seguenti, se necessario.

   • Per Time in seconds (Tempo in secondi) (timeInSeconds), utilizzare il seguente modello di sostituzione.

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

   • Per Offset in nanos (Offset in nanosecondi) (offsetInNanos), utilizzare il seguente modello di sostituzione.

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

   Per ogni parametro, sostituisci region e account-id con la tua regione e l'ID AWS dell'account. Se hai usato un nome diverso per la tua funzione Lambda, cambia anche quello.

3. Concedi AWS IoT le autorizzazioni per richiamare la tua funzione con l'autorizzazione. lambda:InvokeFunction Per ulteriori informazioni, consulta aws_lambda (,). functionArn inputJson

4. Verifica la tua regola (ad esempio, usa il client di AWS IoT MQTT test) e verifica che AWS IoT SiteWise riceva i dati che invii.

   Se la regola non funziona come previsto, consultare Risolvere i problemi relativi a un'azione relativa a una regola AWS IoT SiteWise.