[PYTHON] Lorsqu'un mot-clé apparaît dans une rubrique à laquelle vous êtes abonné par MQTT, publiez-le dans une autre rubrique

【Aperçu】

J'ai écrit ce processus plusieurs fois, et finalement j'ai eu l'idée de le réutiliser. L'image ressemble à la figure ci-dessous, avec S'abonner pour le sujet A sur la gauche et Publier pour le sujet B sur la droite.

Dans le script, le sujet de gauche est exprimé sous la forme «SUB_TOPIC» et le sujet de droite est exprimé sous la forme «PUB_TOPIC». À propos, l'hôte peut être différent du côté SUB et du côté PUB, j'ai donc essayé d'avoir les informations de connexion du côté SUB et du côté PUB respectivement.

【scénario】

Comme ça.

sample.py

#!/usr/bin/python
# encoding:utf-8

import paho.mqtt.client as mqtt
import re
import sys

#Paramètres liés au sujet auxquels ce script s'abonne
SUB_TOPIC = "subtopic"
SUB_USERNAME = 'username'
SUB_PASSWORD = 'password'
SUB_HOST = 'localhost'
SUB_PORT = 1883

#Paramètres liés au sujet que ce script publie
PUB_TOPIC = "pubtopic"
PUB_USERNAME = 'username'
PUB_PASSWORD = 'password'
PUB_HOST = 'localhost'
PUB_PORT = 1883

#Lorsque ce mot clé apparaît dans la rubrique secondaire Sub, sortie dans la rubrique latérale Pub
KEYWORD = "TEST"

#Drapeaux pour le contrôle de sortie de débogage
ISDEBUG = True

def sub_on_connect(client, userdata, flags, rc):
    client.subscribe(SUB_TOPIC)

def sub_on_message(client, userdata, msg):
    #Le message reçu est msg.Stocké dans la charge utile
    debug_echo(msg.payload)

    match = re.match(KEYWORD, msg.payload)

    if match is None:
        debug_echo("Not Match")
    else:
        debug_echo("Match")
        publish("OK")


def publish(msg):
    pub_client.publish(PUB_TOPIC, msg)
    pass


def debug_echo(msg):
    if ISDEBUG :
        print msg
        sys.stderr.write(msg+"\n")

if __name__ == '__main__':
    #Préparation du client expéditeur
    pub_client = mqtt.Client(protocol=mqtt.MQTTv311)
    pub_client.username_pw_set(PUB_USERNAME, password=PUB_PASSWORD)
    pub_client.connect(PUB_HOST, port=PUB_PORT, keepalive=60)

    #Préparation du client bénéficiaire
    sub_client = mqtt.Client(protocol=mqtt.MQTTv311)
    sub_client.on_connect = sub_on_connect
    sub_client.on_message = sub_on_message
    sub_client.username_pw_set(SUB_USERNAME, password=SUB_PASSWORD)
    sub_client.connect(SUB_HOST, port=SUB_PORT, keepalive=60)

    #Démarrer la boucle de réception
    sub_client.loop_forever()

Addendum: modifié pour afficher le contenu de débogage dans la sortie d'erreur standard.