AWS IoT Lambda - Rules Engine

• Rules engine
  • IoT Core(AWS server)에서 메시지를 다른 AWS Serveices에게 전달(여기서는 Dynamo DB)

Create Rule Engine

1. AWS IoT Console에서 Rule 생성

• AWS IoT에서 동작 > 규칙(Rule) > 생성

• Rule 이름을 정하고 스크롤을 아래로 내리면, SQL 쿼리 작성이 가능하다.

2. Rule의 SQL 쿼리 작성

• 같은 창에서 SQL 쿼리 작성

IoT query 참고

• 위와 같이 쿼리를 작성

• IoT Core에서 다음과 같은 메시지가 Publish 되엇을 때,
  

1 SELECT
      받은 ↓'Key' 를 ↓람다 인자로 전달
2     db_action as method,
3     device as device_id,
4     status as picture_num
5 FROM 'test/device/data'    <- Topic

• (line 2,3,4)발행된 Json 형식의 메시지에서 키: {db_action}, {device}, {status} 대항하는 값을 각각 {method}, {device_id}, {picture_num}이라는 인자로 Lambda 함수에 전달
• (line 5) 어떤 topic에 대해서 SQL 처리를 처리할 것인지 결정

3. Rule의 Action 설정: SQL문에서 처리 중인 topic 메시지가 도착하면 Lambda 호출하기

• 작업 추가하기 선택
  
  
• 여러 서비스 중에서 람다 함수 호출 선택

• 여기서 특정 람다 함수를 선택한다