配置 AWS IoT SiteWise 规则操作

创建解析时间戳字符串的 AWS IoT SiteWise 规则操作

1. 创建具有以下属性的 Lambda 函数：

   • 函数名称 – 使用描述性函数名称（例如 ConvertNanosecondTimestampFromString）。

   • 运行时 — 使用 Python 3 运行时，例如 Python 3.11 (python3.11)。

   • 权限-创建具有基本 Lambda 权限的角色 () AWS LambdaBasicExecutionRole。

   • 图层 — 添加 AWS SDKPandas-Python311 层以供 Lambda 函数使用。numpy

   • 函数代码 – 使用以下函数代码，该函数使用名为 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
         }

     此 Lambda 函数使用来自 datetime64 输入 ISO8601 格式的时间戳字符串。 NumPy

     注意

     如果您的时间戳字符串不是 ISO 8601 格式，则可以使用定义时间戳格式pandas来实现解决方案。有关更多信息，请参阅 pandas.to_datetime。

2. 为规则配置 AWS IoT SiteWise 操作时，请使用以下替换模板来替换时间（以秒为单位timeInSeconds）和以纳为单位的偏移量（offsetInNanos）。这些替换模板假定您的消息负载包含 timestamp 格式的时间戳字符串。该aws_lambda函数的第二个参数使用一个JSON结构，因此您可以根据需要修改以下替换模板。

   • 对于 时间 (以秒为单位) (timeInSeconds)，请使用以下替换模板。

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

   • 对于以 偏移量 (以纳秒为单位) (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 规则操作进行故障排除。