[PYTHON] Créer une boîte d'abonné MQTT

introduction

Cette fois, j'ai fait une boîte du côté abonné de MQTT et l'ai essayé avec Pepper.

Cliquez ici pour le contenu de l'opération côté éditeur.

• Créer une boîte d'édition MQTT
• Créer une boîte de publication MQTT Partie 2

J'étudie toujours MQTT.

Boîte d'abonné MQTT

Utilisez les bibliothèques suivantes comme bibliothèques MQTT pour Python.

• Paho - Open Source messaging for M2M

Éléments de réglage

Définissez les informations de courtier MQTT et les informations de rubrique à acquérir.

Code Python

Connectez-vous au courtier MQTT et abonnez-vous à la rubrique. Après cela, loop_forever le met dans l'état d'attente de réception. À la fin du programme, désabonnez-vous du sujet.

Pour savoir comment utiliser la bibliothèque dans la boîte, je me suis référé à l'article suivant.

• Créer une boîte Tweet pour Pepper

(Après avoir examiné quelque chose, je voulais corriger le code)

class MyClass(GeneratedClass):
    def __init__(self):
        GeneratedClass.__init__(self)

    def onLoad(self):
        self.framemanager = ALProxy("ALFrameManager")
        self.folderName = None

    def onUnload(self):
        import sys

        self.mqttc.unsubscribe(self.topic)

        if self.folderName and self.folderName in sys.path:
            sys.path.remove(self.folderName)
        self.folderName = None

    def onInput_onStart(self, payload):
        import sys, os

        self.folderName = os.path.join(
            self.framemanager.getBehaviorPath(self.behaviorId), "../lib")
        if self.folderName not in sys.path:
            sys.path.append(self.folderName)

        import paho.mqtt.client as paho

        self.host       = self.getParameter("Broker Host")
        self.port       = self.getParameter("Broker Port")
        self.keep_alive = self.getParameter("KeepAlive")
        self.topic      = self.getParameter("Topic")
        self.qos        = self.getParameter("Qos")

        self.mqttc = paho.Client()
        self.mqttc.on_message = self.onMessage
        self.mqttc.connect(self.host, self.port, self.keep_alive)
        self.mqttc.subscribe(self.topic, self.qos)

        self.mqttc.loop_forever()

    def onMessage(self, mqttc, obj, msg):
        self.logger.info("topic: " + msg.topic + ", payload: " + str(msg.payload) + ", qos: " + str(msg.qos) + ", retain: " + str(msg.retain))

    def onInput_onStop(self):
        self.onUnload()
        self.onStopped()

Connectez-vous avec Choregraphe

Côté éditeur

Passez simplement "bonjour le monde" au courtier MQTT.

pub.py

# coding=utf8

import paho.mqtt.client as paho

mqttc = paho.Client()

mqttc.connect("test.mosquitto.org", 1883, 60)
mqttc.publish("my/topic/pepper5", "hello world", 1)

Contrôle de fonctionnement

Exécuter l'abonné

Exécutez le programme dans Choregraphe et attendez que le message soit reçu.

Exécutez Publisher

Exécutez Publisher à partir du terminal.

$ python pub.py

Affichage des résultats

Le message Editeur-> Courtier-> Abonné est transmis, et le contenu est affiché dans le visualiseur de journal de Choregraphe côté Abonné.

Contrôle de fonctionnement 2

Si vous essayez de modifier le traitement lors de la réception d'un message du côté abonné vers le formulaire ci-dessous, Pepper parlera.

    def onMessage(self, mqttc, obj, msg):
        tts = ALProxy("ALTextToSpeech")
        tts.say(msg.payload)

Impressions

• J'ai fait les deux avec l'éditeur / abonné, mais Pepper semble être facile à utiliser car le côté éditeur saute régulièrement diverses informations, et le côté abonné acquiert des informations de contrôle et modifie le traitement.
• Je ne l'ai pas essayé cette fois, mais il semble intéressant d'utiliser un-à-plusieurs et plusieurs-à-un.