Tutorial: republicar uma mensagem MQTT

Abra o hub de regras do AWS IoT console.

Em Regras, escolha Criar e comece a criar sua nova regra.

Na parte superior da opção Criar uma regra:

1. Em Nome, insira o nome da regra. Para este tutorial, dê o nome republish_temp.

   Lembre-se de que o nome de uma regra deve ser exclusivo em sua conta e região e não pode ter espaços. Usamos um caractere sublinhado nesse nome para separar as duas palavras no nome da regra.

2. Em Descrição, descreva a regra.

   Uma descrição significativa ajuda você a lembrar ao que essa regra se refere e por que você a criou. A descrição pode ser tão longa quanto necessário, portanto, seja o mais detalhista possível.

Na declaração de consulta de regra de Criar uma regra:

1. Em Usando a SQL versão, selecione2016-03-23.

2. Na caixa de edição Instrução de consulta de regra, insira a instrução:

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

   Esta declaração:

   • Escuta MQTT mensagens com um tópico que corresponda ao filtro de device/+/data tópicos.

   • Seleciona o segundo elemento da cadeia de caracteres do tópico e o atribui ao campo device_id.

   • Seleciona o campo de valor temperature da carga útil da mensagem e o atribui ao campo temperature.

Em Definir uma ou mais ações:

1. Para abrir a lista de ações de regra para essa regra, escolha Adicionar ação.

2. Em Selecionar uma ação, escolha Republicar uma mensagem em um AWS IoT tópico.

3. Na parte inferior da lista de ações, escolha Configurar ação para abrir a página de configuração da ação selecionada.

Em Configurar ação:

1. Em Tópico, insira device/data/temp. Esse é o MQTT tópico da mensagem que essa regra publicará.

2. Em Qualidade de Serviço, escolha 0 - A mensagem é entregue zero ou mais vezes.

3. Em Escolha ou crie uma função para conceder AWS IoT acesso para realizar essa ação:

   1. Selecione Criar perfil. A caixa de diálogo Criar um novo perfil é aberta.

   2. Insira um nome que descreva o novo perfil. Neste tutorial, use republish_role.

      Quando você cria um novo perfil, as políticas corretas para executar a ação da regra são criadas e anexadas ao novo perfil. Se você alterar o tópico dessa ação de regra ou usar esse perfil em outra ação de regra, deverá atualizar a política desse perfil para autorizar o novo tópico ou ação. Para atualizar uma função existente, escolha Atualizar função nesta seção.

   3. Escolha Criar função para criar a função e fechar a caixa de diálogo.

4. Escolha Adicionar ação para adicionar a ação à regra e retornar à página Criar uma regra.

A ação Republicar uma mensagem em um AWS IoT tópico agora está listada em Definir uma ou mais ações.

No bloco da nova ação, abaixo de Republicar uma mensagem em um AWS IoT tópico, você pode ver o tópico no qual sua ação de republicação será publicada.

Essa é a única ação de regra que você adicionará a essa regra.

Em Criar uma regra, desça até a parte inferior e escolha Criar regra para criar a regra e concluir esta etapa.

No MQTTcliente no AWS IoT console, assine os tópicos de entrada, neste caso,device/+/data.

1. No MQTT cliente, em Assinaturas, escolha Inscrever-se em um tópico.

2. Em Tópico de assinatura, insira o tópico do filtro de tópico de entrada, device/+/data.

3. Deixe os demais campos com as configurações padrão.

4. Escolha Assinar um tópico.

   Na coluna Assinaturas, em Publicar em um tópico , device/+/data é exibido.

Assine o tópico que sua regra publicará: device/data/temp.

1. Em Assinaturas, escolha Assinar um tópico novamente e, em Tópico de assinatura, insira o tópico da mensagem republicada, device/data/temp.

2. Deixe os demais campos com as configurações padrão.

3. Escolha Assinar um tópico.

   Na coluna Assinaturas, em dispositivo/+/dado, device/data/temp é exibido.

Publique uma mensagem no tópico de entrada com um ID de dispositivo específico, device/22/data. Você não pode publicar em MQTT tópicos que contenham caracteres curinga.

1. No MQTT cliente, em Assinaturas, escolha Publicar no tópico.

2. No campo Publicar, insira o nome do tópico de entrada, device/22/data.

3. Copie os dados de amostra mostrados aqui e, na caixa de edição abaixo do nome do tópico, cole os dados de amostra.

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

4. Para enviar sua MQTT mensagem, escolha Publicar no tópico.

Revise as mensagens enviadas.

1. No MQTT cliente, em Assinaturas, há um ponto verde ao lado dos dois tópicos nos quais você se inscreveu anteriormente.

   Os pontos verdes indicam que uma ou mais mensagens novas foram recebidas desde a última vez que você as viu.

2. Em Assinaturas, escolha dispositivo/+/dado para verificar se a carga útil da mensagem corresponde ao que você acabou de publicar e tem a seguinte aparência:

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

3. Em Assinaturas, escolha dispositivo/dados/temperatura para verificar se a carga útil da mensagem republicada tem a seguinte aparência:

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

   Observe que o valor device_id valor é uma string citada e o valor temperature é numérico. Isso ocorre porque a topic()função extraiu a string do nome do tópico da mensagem de entrada, enquanto o valor temperature usa o valor numérico da carga útil da mensagem de entrada.

   Se você quiser transformar o valor device_id em um valor numérico, substitua topic(2) na instrução de consulta de regra por:

   cast(topic(2) AS DECIMAL)

   Observe que converter o valor topic(2) em um valor numérico só funcionará se essa parte do tópico contiver somente caracteres numéricos.

Se você perceber que a mensagem correta foi publicada no tópico dispositivo/dados/temporário, sua regra funcionou. Veja o que mais você pode aprender sobre a ação da regra de republicação na próxima seção.

Se você não vê que a mensagem correta foi publicada nos tópicos dispositivo/+/dados ou dispositivo/dados/temp, confira as dicas de solução de problemas.