設定規 AWS IoT SiteWise 則動作

若要建立剖析時間戳記字串的 AWS IoT SiteWise 規則動作

1. 建立具有下列屬性的 Lambda 函數：

   • 函數名稱 — 使用描述性函數名稱 (例如ConvertNanosecondTimestampFromString)。

   • 執行階段 — 使用 Python 3 執行階段，例如 Python 3.11 (python3.11)。

   • 權限 — 建立具有基本 Lambda 權限的角色 (AWS LambdaBasicExecutionRole)。

   • 層 — 新增要使用的 Lambda 函數的 AWS SDKPandas-Python311 圖層。numpy

   • 函數代碼 — 使用下列函數程式碼，它會使用名為的字串引數，timestamptimeInSeconds並輸出該時間戳記的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
         }

     這個 Lambda 函數輸入使用日期時間 64 從 ISO8601 格式的時間戳字符串。 NumPy

     注意

     如果您的時間戳記字串不是 ISO 8601 格式，您可以實作定義時間戳記格式pandas的解決方案。如需詳細資訊，請參閱熊貓。

2. 當您設定規則的 AWS IoT SiteWise 動作時，請使用下列替代範本，以秒為單位 (timeInSeconds) 和位移 (以 nanos 為單位offsetInNanos)。這些替代範本會假設您的訊息承載包含 timestamp 中的時間戳記字串。該aws_lambda函數消耗其第二個參數的JSON結構，因此您可以根據需要修改以下替換模板。

   • 針對 Time in seconds (以秒為單位的時間) (timeInSeconds)，使用以下替代範本。

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

   • 針對 Offset in nanos (以奈米為單位的位移) (offsetInNanos)，使用以下替代範本。

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

   對於每個參數，請替換 region 以及 account-id 使用您的地區和 AWS 帳戶 ID。如果您為 Lambda 函數使用了不同的名稱，請同時進行變更。

3. 授予 AWS IoT 權限以使用lambda:InvokeFunction權限調用您的函數。如需詳細資訊，請參閱 aws_lambda (functionArn,inputJson)。

4. 測試您的規則（例如，使用 AWS IoT MQTT測試用戶端），並確認是否 AWS IoT SiteWise 接收到您傳送的資料。

   如果規則無法正常運作，請參閱 疑難排解 AWS IoT SiteWise 規則動作。