AWS IoT SiteWise 규칙 작업을 구성합니다.

타임스탬프 문자열을 파싱하는 AWS IoT SiteWise 규칙 액션을 만들려면

1. 다음 속성을 사용하여 Lambda 함수를 만듭니다.

   • 함수 이름 - 설명이 포함된 함수 이름(예: ConvertNanosecondTimestampFromString)을 사용합니다.

   • 런타임 — Python 3.11 (python3.11) 과 같은 Python 3 런타임을 사용합니다.

   • 권한 — 기본 Lambda 권한 () 을 사용하여 역할을 생성합니다. AWS LambdaBasicExecutionRole

   • 레이어 — Lambda 함수가 사용할 AWS SDKPandas-Python311 계층을 추가합니다. 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를 사용하여 타임스탬프 문자열을 8601 ISO형식으로 입력합니다. NumPy

     참고

     타임스탬프 문자열이 ISO 8601 형식이 아닌 경우 타임스탬프 형식을 정의하는 솔루션을 구현할 수 있습니다. pandas 자세한 내용은 pandas.to_datetime을 참조하세요.

2. 규칙에 맞게 AWS IoT SiteWise 작업을 구성할 때는 다음과 같은 시간 (초timeInSeconds) 및 오프셋 (nanos) 단위의 오프셋 () 대체 템플릿을 사용하십시오. 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 규칙 조치 문제 해결 단원을 참조하세요.