Etapa 3: demonstrar a assinatura de mensagens com o AWS IoT Device Client

Certifique-se de que a janela do terminal e a janela com o cliente de teste MQTT estejam visíveis enquanto você realiza esse procedimento. Além disso, certifique-se de que o cliente de teste MQTT ainda seja assinante no filtro de tópicos #. Se não o for, assine novamente o filtro de tópicos #.

Na janela do terminal, digite os seguintes comandos para executar o AWS IoT Device Client usando o arquivo de configuração criado em Crie o arquivo de configuração.

cd ~/aws-iot-device-client/build
./aws-iot-device-client --config-file ~/dc-configs/dc-pubsub-custom-config.json

Na janela do terminal, o AWS IoT Device Client exibe mensagens com informações e quaisquer erros ocorridos durante a execução.

Caso nenhum erro seja exibido na janela do terminal, continue no console do AWS IoT.

No console do AWS IoT, no cliente de teste MQTT, selecione a guia Publicar em um tópico.

Em Nome do tópico, digite test/dc/subtopic

Em Carga da mensagem, examine o conteúdo da mensagem.

Selecione Publicar para publicar a mensagem MQTT.

Na janela do terminal, procure pela entrada de mensagem recebida do AWS IoT Device Client, semelhante à seguinte.

2021-11-10T16:02:20.890Z [DEBUG] {samples/PubSubFeature.cpp}: Message received on subscribe topic, size: 45 bytes

Depois de encontrar a entrada de mensagem recebida, comprovando que a mensagem foi recebida, digite ^C (Ctrl-C) para interromper o AWS IoT Device Client.

Insira o seguinte comando para visualizar o final do arquivo de log de mensagens e ver a mensagem que foi publicada no cliente de teste MQTT.

tail ~/.aws-iot-device-client/log/pubsub_rx_msgs.log

Na janela do terminal do computador host local que está conectado ao Raspberry Pi, abra ~/dc-configs/dc-pubsub-custom-config.json para edição e localize o objeto samples.

No editor de texto, localize o objeto samples e atualize o valor de subscribe-topic para que se assemelhe a isto.

  "samples": {
    "pub-sub": {
      "enabled": true,
      "publish-topic": "test/dc/pubtopic",
      "publish-file": "~/messages/sample-ws-message.json",
      "subscribe-topic": "test/dc/#",
      "subscribe-file": "~/.aws-iot-device-client/log/pubsub_rx_msgs.log"

O novo valor de subscribe-topic é um filtro de tópicos MQTT com um caractere curinga MQTT no final. Isso descreve uma assinatura de todos os tópicos MQTT que começam com test/dc/. O AWS IoT Device Client grava as cargas de mensagens recebidas dessa assinatura no arquivo nomeado em subscribe-file.

Salve o arquivo de configuração modificado como ~/dc-configs/dc-pubsub-wild-config.json e saia do editor de texto.

Na janela do terminal do seu computador host local conectado ao Raspberry Pi, em seu editor de texto favorito, abra ~/policies/pubsub_test_thing_policy.json para edição e, depois, localize as declarações de política iot::Subscribe e iot::Receive no arquivo.

Na declaração de política iot::Subscribe, atualize a string no objeto Resource para substituir subtopic por *, de modo que fique semelhante ao seguinte.

    {
      "Effect": "Allow",
      "Action": [
        "iot:Subscribe"
      ],
      "Resource": [
        "arn:aws:iot:us-west-2:57EXAMPLE833:topicfilter/test/dc/*"
      ]
    }

Na declaração de política iot::Receive, atualize a string no objeto Resource para substituir subtopic por *, de modo que fique semelhante ao seguinte.

    {
      "Effect": "Allow",
      "Action": [
        "iot:Receive"
      ],
      "Resource": [
        "arn:aws:iot:us-west-2:57EXAMPLE833:topic/test/dc/*"
      ]
    }

Salve o documento de política atualizado como ~/policies/pubsub_wild_test_thing_policy.json e saia do editor.

Insira o seguinte comando para atualizar a política deste tutorial para usar as novas definições de recursos.

aws iot create-policy-version \
--set-as-default \
--policy-name "PubSubTestThingPolicy" \
--policy-document "file://~/policies/pubsub_wild_test_thing_policy.json"

Em caso de êxito, ele retornará uma resposta como a seguinte. Observe que policyVersionId agora é 2, o que indica que esta é a segunda versão desta política.

Se você obteve êxito em atualizar a política, avance para o próximo procedimento.

{
    "policyArn": "arn:aws:iot:us-west-2:57EXAMPLE833:policy/PubSubTestThingPolicy",
    "policyDocument": "{\n  \"Version\": \"2012-10-17\",\n  \"Statement\": [\n    {\n      \"Effect\": \"Allow\",\n      \"Action\": [\n        \"iot:Connect\"\n      ],\n      \"Resource\": [\n        \"arn:aws:iot:us-west-2:57EXAMPLE833:client/PubSubTestThing\"\n      ]\n    },\n    {\n      \"Effect\": \"Allow\",\n      \"Action\": [\n        \"iot:Publish\"\n      ],\n      \"Resource\": [\n        \"arn:aws:iot:us-west-2:57EXAMPLE833:topic/test/dc/pubtopic\"\n      ]\n    },\n    {\n      \"Effect\": \"Allow\",\n      \"Action\": [\n        \"iot:Subscribe\"\n      ],\n      \"Resource\": [\n        \"arn:aws:iot:us-west-2:57EXAMPLE833:topicfilter/test/dc/*\"\n      ]\n    },\n    {\n      \"Effect\": \"Allow\",\n      \"Action\": [\n        \"iot:Receive\"\n      ],\n      \"Resource\": [\n        \"arn:aws:iot:us-west-2:57EXAMPLE833:topic/test/dc/*\"\n      ]\n    }\n  ]\n}\n",
    "policyVersionId": "2",
    "isDefaultVersion": true
}

Caso receba um erro informando que há versões da política demais para que uma nova seja salva, insira o seguinte comando para listar as versões atuais da política. Examine a lista retornada pelo comando a seguir para encontrar uma versão da política que possa ser excluída.

aws iot list-policy-versions --policy-name "PubSubTestThingPolicy"

Digite o comando a seguir para excluir uma versão que não é mais necessária. Não é possível excluir a versão padrão da política. A versão padrão da política é aquela com um valor de isDefaultVersion de true.

aws iot delete-policy-version \
--policy-name "PubSubTestThingPolicy" \
--policy-version-id policyId

Depois de excluir uma versão da política, tente a etapa novamente.

No cliente de teste MQTT, verifique as assinaturas. Se o cliente de teste MQTT for assinante do filtro de tópicos #, avance para a próxima etapa. Caso contrário, no cliente de teste MQTT, na guia Assinar um tópico, em Filtro de tópicos, insira # (caractere de jogo da velha) e escolha Assinar para assinar.

Na janela do terminal do computador host local conectado ao Raspberry Pi, execute os comandos a seguir para iniciar o AWS IoT Device Client.

cd ~/aws-iot-device-client/build
./aws-iot-device-client --config-file ~/dc-configs/dc-pubsub-wild-config.json

Enquanto observa a saída do AWS IoT Device Client na janela do terminal no computador host local, retorne ao cliente de teste MQTT. Na guia Publicar em um tópico, em Nome do tópico, insira test/dc/subtopic e selecione Publicar.

Na janela do terminal, confirme se a mensagem foi recebida procurando uma mensagem como:

2021-11-10T16:34:20.101Z [DEBUG] {samples/PubSubFeature.cpp}: Message received on subscribe topic, size: 76 bytes

Enquanto observa a saída do AWS IoT Device Client na janela do terminal do computador host local, retorne ao cliente de teste MQTT. Na guia Publicar em um tópico, em Nome do tópico, insira test/dc/subtopic2 e selecione Publicar.

Na janela do terminal, confirme se a mensagem foi recebida procurando uma mensagem como:

2021-11-10T16:34:32.078Z [DEBUG] {samples/PubSubFeature.cpp}: Message received on subscribe topic, size: 77 bytes

Depois de ver as mensagens que confirmam que ambas as mensagens foram recebidas, digite ^C (Ctrl-C) para interromper o AWS IoT Device Client.

Insira o seguinte comando para visualizar o final do arquivo de log de mensagens e ver a mensagem que foi publicada no cliente de teste MQTT.

tail -n 20 ~/.aws-iot-device-client/log/pubsub_rx_msgs.log