Étape 3 : Démontrer que vous vous abonnez à des messages avec leAWS IoTAppareil client

Assurez-vous que la fenêtre du terminal et la fenêtre avec le client de test MQTT sont visibles pendant que vous effectuez cette procédure. Assurez-vous également que votreClient MQTTest toujours abonné au#Filtre de rubriques. Si ce n'est pas le cas, abonnez-vous au#filtre de sujet à nouveau.

Dans la fenêtre du terminal, entrez ces commandes pour exécuter leAWS IoTDevice Client utilisant le fichier de configuration créé dansCréer le fichier de configuration.

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

Dans la fenêtre de terminal, leAWS IoTDevice Client affiche les messages d'information et les erreurs éventuelles qui se produisent lors de son exécution.

Si aucune erreur n'est affichée dans la fenêtre du terminal, continuez dans leAWS IoTconsole

DansAWS IoT, dans la consoleClient MQTT, choisissez lePublier dans une rubriqueonglet.

DansNom de la rubrique, saisisseztest/dc/subtopic

DansCharge utile des messages, passez en revue le contenu du message.

ChoisissezPublierpour publier le message MQTT.

Dans la fenêtre du terminal, surveillez lamessage reçuentrée de l'outilAWS IoTDevice Client qui se présente sous la forme suivante.

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

Après avoir vu lemessage reçuentrée indiquant que le message a été reçu, entrez^C(Ctrl+C) afin d'arrêter leAWS IoTClient de l'appareil.

Saisissez cette commande pour afficher la fin du fichier journal des messages et voir le message que vous avez publié à partir duClient MQTT.

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

Dans la fenêtre du terminal de votre ordinateur hôte local connecté à votre Raspberry Pi, ouvrez~/dc-configs/dc-pubsub-custom-config.jsonpour éditer et localiser lesamplesobjet.

Dans l'éditeur de texte, localisez lesampleset mettez à jour lesubscribe-topicse présente ainsi.

  "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"

La nouvellesubscribe-topicvaleur est uneFiltre de rubriques MQTTavec un caractère joker MQTT à la fin. Ceci décrit un abonnement à toutes les rubriques MQTT qui commencent partest/dc/. LeAWS IoTDevice Client écrit les charges utiles des messages qu'il reçoit de cet abonnement dans le fichier nommé danssubscribe-file.

Enregistrez le fichier de configuration modifié sous~/dc-configs/dc-pubsub-wild-config.jsonet quittez l'éditeur.

Dans la fenêtre du terminal de votre ordinateur hôte local connecté à votre Raspberry Pi, dans votre éditeur de texte préféré, ouvrez~/policies/pubsub_test_thing_policy.jsonpour éditer, puis localiser leiot::Subscribeetiot::Receiveinstructions de stratégie dans le fichier.

Dansiot::Subscribe, mettez à jour la chaîne de l'objet Resource pour la remplacersubtopicavec*afin que l'adresse se présente ainsi.

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

Dansiot::Receive, mettez à jour la chaîne de l'objet Resource pour la remplacersubtopicavec*afin que l'adresse se présente ainsi.

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

Enregistrez le document de stratégie mis à jour sous~/policies/pubsub_wild_test_thing_policy.jsonet quittez l'éditeur.

Entrez cette commande pour mettre à jour la stratégie de ce didacticiel afin d'utiliser les nouvelles définitions de ressources.

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

Si la commande réussit, elle renvoie une réponse telle que celle-ci. Remarquez quepolicyVersionIdest maintenant2, indiquant qu'il s'agit de la deuxième version de cette politique.

Si vous avez mis à jour la stratégie avec succès, vous pouvez passer à la procédure suivante.

{
    "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
}

Si vous obtenez une erreur indiquant qu'il existe trop de versions de stratégie pour en enregistrer une nouvelle, entrez cette commande pour répertorier les versions actuelles de la stratégie. Consultez la liste renvoyée par cette commande pour trouver une version de stratégie que vous pouvez supprimer.

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

Entrez cette commande pour supprimer une version dont vous n'avez plus besoin. Notez que vous ne pouvez pas supprimer la version de la stratégie par défaut. La version de stratégie par défaut est celle avec unisDefaultVersionvaleur detrue.

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

Après avoir supprimé une version de stratégie, réessayez cette étape.

DansClient MQTT, vérifiez les abonnements. Si l'icôneClient MQTTest abonné à la#Filtre de rubriques, passez à l'étape suivante. Dans le cas contraire, dans leClient MQTT, dansS'abonner à une rubrique, dansFiltre de rubriques, saisissez#(un signe de livre), puis choisissezS'abonnerpour y souscrire.

Dans la fenêtre du terminal de votre ordinateur hôte local connecté à votre Raspberry Pi, entrez ces commandes pour démarrer leAWS IoTClient de l'appareil.

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

En regardant leAWS IoTSortie Device Client dans la fenêtre du terminal sur l'ordinateur hôte local, revenez à laClient MQTT. DansPublier dans une rubrique, dansNom de la rubrique, saisisseztest/dc/subtopicChoisissezPublier.

Dans la fenêtre du terminal, confirmez que le message a été reçu en recherchant un message tel que :

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

En regardant leAWS IoTSortie Device Client dans la fenêtre du terminal de l'ordinateur hôte local, revenez à laTest client MQTT. DansPublier dans une rubrique, dansNom de la rubrique, saisisseztest/dc/subtopic2ChoisissezPublier.

Dans la fenêtre du terminal, confirmez que le message a été reçu en recherchant un message tel que :

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

Après avoir vu les messages confirmant que les deux messages ont été reçus, entrez^C(Ctrl+C) afin d'arrêter leAWS IoTClient de l'appareil.

Saisissez cette commande pour afficher la fin du fichier journal des messages et voir le message que vous avez publié à partir duTest client MQTT.

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