자습서: MQTT 메시지 재게시

콘솔의 규칙 허브를 엽니다. AWS IoT

규칙에서 생성을 선택하고 새 규칙 생성을 시작합니다.

규칙 생성의 상단 부분에서:

1. 이름에 규칙 이름을 입력합니다. 본 자습서에서는 이름을 republish_temp로 지정합니다.

   규칙 이름은 계정 및 지역 내에서 고유해야 하며 공백을 포함할 수 없습니다. 이 이름에 밑줄 문자를 사용하여 규칙 이름의 두 단어를 구분했습니다.

2. 설명에서 규칙을 설명합니다.

   의미 있는 설명은 이 규칙이 수행하는 작업과 규칙을 생성한 이유를 기억하는 데 도움이 됩니다. 설명은 필요한 만큼 길어질 수 있으므로 가능한 한 자세하게 설명하세요.

규칙 생성의 규칙 쿼리 문에서:

1. SQL 버전 사용에서 2016-03-23를 선택합니다.

2. 규칙 쿼리 문 편집 상자에 쿼리 문을 입력합니다.

   SELECT topic(2) as device_id, temperature FROM 'device/+/data'

   이 문은 다음을 수행합니다.

   • device/+/data 주제 필터와 일치하는 주제가 있는 MQTT 메시지를 수신합니다.

   • 주제 문자열에서 두 번째 요소를 선택하여 device_id 필드에 할당합니다.

   • 메시지 페이로드에서 temperature 값 필드를 선택하여 temperature 필드에 할당합니다.

하나 이상의 작업 설정에서:

1. 이 규칙에 대한 규칙 작업 목록을 열려면 작업 추가를 선택합니다.

2. 작업 선택에서 AWS IoT 주제에 메시지 다시 게시를 선택합니다.

3. 작업 목록 하단에서 구성 작업을 선택하여 선택한 작업의 구성 페이지를 엽니다.

구성 작업에서:

1. 주제에 device/data/temp를 입력합니다. 이 규칙이 게시할 메시지의 MQTT 주제입니다.

2. 서비스 품질(QoS)에서 0 - 메시지가 0번 이상 전송됨을 선택합니다.

3. 이 작업을 수행할 수 있는 AWS IoT 액세스 권한을 부여할 역할 선택 또는 만들기에서:

   1. Create Role(역할 생성)을 선택합니다. 새 역할 생성 대화 상자가 열립니다.

   2. 새 역할을 설명하는 이름을 입력합니다. 본 자습서에서는 republish_role을 사용합니다.

      새 역할을 만들면 규칙 작업을 수행할 올바른 정책이 만들어지고 새 역할에 연결됩니다. 이 규칙 작업의 주제를 변경하거나 다른 규칙 작업에서 이 역할을 사용하는 경우 새 주제 또는 작업에 권한을 부여하도록 해당 역할에 대한 정책을 업데이트해야 합니다. 기존 역할을 업데이트하려면 이 섹션의 역할 업데이트를 선택합니다.

   3. 역할 생성을 선택하여 역할을 생성하고 대화 상자를 닫습니다.

4. 작업 추가를 선택하여 규칙에 작업을 추가하고 규칙 생성 페이지로 이동합니다.

AWS IoT 주제에 메시지 다시 게시 작업이 이제 하나 이상의 작업 설정에 나열되어 있습니다.

새 작업 타일의 AWS IoT 주제에 메시지 재게시 아래에서 재게시 작업으로 게시할 주제를 볼 수 있습니다.

이 규칙 작업은 이 규칙에 추가할 유일한 규칙 작업입니다.

규칙 생성에서 하단으로 스크롤하고 규칙 생성을 선택하여 규칙을 생성하고 이 단계를 완료합니다.

AWS IoT 콘솔의 MQTT 클라이언트에서 입력 주제(이 경우 device/+/data)를 구독합니다.

1. MQTT 클라이언트에서 구독 아래에서 주제 구독을 선택합니다.

2. 구독 주제에 입력 주제 필터 device/+/data의 주제를 입력합니다.

3. 나머지 필드는 기본 설정을 유지합니다.

4. 주제 구독을 선택합니다.

   구독 열의 주제 게시 아래에 device/+/data가 나타납니다.

규칙에서 게시할 주제 device/data/temp를 구독합니다.

1. 구독 아래에서 주제 구독을 다시 선택하고, 구독 주제에 다시 게시된 메시지의 주제 device/data/temp를 입력합니다.

2. 나머지 필드는 기본 설정을 유지합니다.

3. 주제 구독을 선택합니다.

   구독 열의 device/+/data에서 device/data/temp가 나타납니다.

특정 디바이스 ID device/22/data로 입력 주제에 메시지를 게시합니다. 와일드카드 문자가 포함된 MQTT 항목에는 게시할 수 없습니다.

1. MQTT 클라이언트의 구독 아래에서 주제 게시를 선택합니다.

2. 게시 필드에 입력 주제 이름 device/22/data를 입력합니다.

3. 여기에 표시된 샘플 데이터를 복사하고 주제 이름 아래의 편집 상자에 샘플 데이터를 붙여 넣습니다.

   {
     "temperature": 28,
     "humidity": 80,
     "barometer": 1013,
     "wind": {
       "velocity": 22,
       "bearing": 255
     }
   }

4. MQTT 메시지를 전송하려면 주제 게시를 선택합니다.

전송한 메시지를 검토합니다.

1. MQTT 클라이언트의 구독 아래에서 이전에 구독한 두 주제 옆에 녹색 점이 있습니다.

   녹색 점은 마지막으로 메시지를 본 이후 하나 이상의 새 메시지가 수신되었음을 나타냅니다.

2. 구독 아래에서 device/+/data를 선택하여 메시지 페이로드가 방금 게시한 것과 일치하고 다음과 같이 표시되는지 확인하세요.

   {
     "temperature": 28,
     "humidity": 80,
     "barometer": 1013,
     "wind": {
       "velocity": 22,
       "bearing": 255
     }
   }

3. 구독 아래에서 device/data/temp를 선택하여 게시된 메시지 페이로드가 다음과 같이 표시되는지 확인하세요.

   {
     "device_id": "22",  
     "temperature": 28
   }

   device_id 값은 따옴표로 묶인 문자열이고 temperature 값은 숫자여야 합니다. 이는 topic() 함수가 입력 메시지의 주제 이름에서 문자열을 추출하는 반면 temperature 값은 입력 메시지의 페이로드에서 숫자 값을 사용하기 때문입니다.

   device_id 값을 숫자 값으로 만들려면 규칙 쿼리 문에서 topic(2)를 다음으로 바꿉니다.

   cast(topic(2) AS DECIMAL)

   topic(2) 값을 숫자 값으로 캐스팅하는 것은 주제의 해당 부분에 숫자만 포함된 경우에만 작동합니다.

device/data/temp 주제에 올바른 메시지가 게시되었으면 규칙이 작동한 것입니다. 다음 섹션에서 재게시 규칙 작업에 대해 자세히 알아볼 수 있는 내용을 확인하세요.

device/+/data 또는 device/data/temp 주제에 올바른 메시지가 게시되었음을 확인할 수 없는 경우 문제 해결 팁을 확인하세요.