Démontrer l'abonnement aux messages avec le AWS IoT Device Client

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

Dans la fenêtre du terminal, entrez ces commandes pour exécuter le client de AWS IoT périphérique à l'aide du fichier de configuration créé dansCréez 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 du terminal, le client du AWS IoT périphérique affiche les messages d'information et les éventuelles erreurs survenant lors de son exécution.

Si aucune erreur ne s'affiche dans la fenêtre du terminal, continuez dans la AWS IoT console.

Dans la AWS IoT console, dans le client de MQTT test, choisissez l'onglet Publier dans une rubrique.

Dans Topic name (Nom de la rubrique), saisissez test/dc/subtopic.

Dans Charge utile du message , passez en revue le contenu du message.

Choisissez Publier pour publier le MQTT message.

Dans la fenêtre du terminal, recherchez le message reçu du client du AWS IoT périphérique qui ressemble à ceci.

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

Après avoir vu le message reçu indiquant que le message a été reçu, entrez ^C (Ctrl-C) pour arrêter le client du AWS IoT périphérique.

Entrez cette commande pour afficher la fin du fichier journal des messages et voir le message que vous avez publié depuis le client de MQTT test.

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.json pour le modifier et localisez l'objet samples.

Dans l'éditeur de texte, localisez l'samplesobjet et mettez à jour la valeur subscribe-topic pour qu'elle ressemble à ceci.

  "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 nouvelle subscribe-topic valeur est un filtre de MQTT sujet avec MQTT un caractère générique à la fin. Ceci décrit un abonnement à toutes les MQTT rubriques commençant partest/dc/. Le client du AWS IoT périphérique écrit les charges utiles des messages qu'il reçoit dans le cadre de cet abonnement dans le fichier indiqué danssubscribe-file.

Enregistrez le fichier de configuration modifié sous ~/dc-configs/dc-pubsub-wild-config.json, et 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.json pour modification, puis recherchez les iot::Subscribe et les déclarations de politique iot::Receive dans le fichier.

Dans la déclaration de politique iot::Subscribe, mettez à jour la chaîne de l'objet Resource subtopic à remplacer par *, afin qu'elle ressemble à ceci.

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

Dans la déclaration de politique iot::Receive, mettez à jour la chaîne de l'objet Resource subtopic à remplacer par *, afin qu'elle ressemble à ceci.

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

Enregistrez le document de politique mis à jour et quittez l'éditeur ~/policies/pubsub_wild_test_thing_policy.json.

Entrez cette commande pour mettre à jour la politique 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 comme celle-ci. Notez que policyVersionId est maintenant 2, ce qui indique qu'il s'agit de la deuxième version de cette politique.

Si vous avez correctement mis à jour la politique, 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 recevez un message d'erreur indiquant qu'il existe trop de versions de politique pour en enregistrer une nouvelle, entrez cette commande pour répertorier les versions actuelles de la politique. Consultez la liste renvoyée par cette commande pour rechercher une version de politique que vous pouvez supprimer.

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

Saisissez cette commande pour supprimer une version dont vous n'avez plus besoin. Notez que vous ne pouvez pas supprimer la version de politique par défaut. La version de politique par défaut est celle dont la valeur isDefaultVersion est de true.

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

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

Dans le client de MQTT test, vérifiez les abonnements. Si le client de MQTT test est abonné au filtre de # rubrique, passez à l'étape suivante. Sinon, dans le client de MQTT test, dans l'onglet S'abonner à un sujet, dans le filtre de sujet, entrez # (un signe dièse), puis choisissez S'abonner pour vous y abonner.

Dans la fenêtre du terminal de votre ordinateur hôte local connecté à votre Raspberry Pi, entrez ces commandes pour démarrer le AWS IoT Device Client.

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

Tout en regardant le résultat du AWS IoT Device Client dans la fenêtre du terminal de l'ordinateur hôte local, retournez au client de MQTT test. Dans l'onglet Publier dans une rubrique, dans Nom de rubrique, entrez test/dc/subtopic, puis choisissez Publier.

Dans la fenêtre du terminal, vérifiez que le message a bien é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

Tout en regardant la sortie du AWS IoT Device Client dans la fenêtre du terminal de l'ordinateur hôte local, retournez au client de MQTT test. Dans l'onglet Publier dans une rubrique, dans Nom de rubrique, entrez test/dc/subtopic2, puis choisissez Publier.

Dans la fenêtre du terminal, vérifiez que le message a bien é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 la réception des deux messages, entrez ^C (Ctrl-C) pour arrêter le AWS IoT Device Client.

Entrez cette commande pour afficher la fin du fichier journal des messages et voir le message que vous avez publié depuis le client de MQTT test.

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