Python- 为什么我的 Paho Mqtt 消息与我发送的消息不同?

标签 python mqtt paho

我正在使用一些 C.H.I.P.s(想想 Raspberry Pi)进行一个项目,我需要将一些信息从从属板无线发送回主板。我使用 Paho 作为我的 Mqtt 客户端,并使用 Mosquitto 作为我的代理。我的问题是当我按下连接到从板的按钮之一时,它会发送我的消息,但是当主板接收到它时,它似乎是以“b''”的形式获取的。例如,如果我发送消息“off”,当我打印出 msg.payload 时,它会打印“b'off'”。这导致了一个问题,因为我无法比较消息以便从我的主板执行命令。

这是我的从板代码:

import paho.mqtt.client as paho
import CHIP_IO.GPIO as GPIO
import time

GPIO.cleanup()
GPIO.setup("XIO-P0", GPIO.IN, pull_up_down=GPIO.PUD_DOWN) 
GPIO.setup("XIO-P2", GPIO.IN, pull_up_down=GPIO.PUD_DOWN)

client = paho.Client()
client.connect("172.20.0.1", 1883)

print ("CONNECTED")

while True:
  if (GPIO.input("XIO-P0") == False):
    print ("Button P0 Pressed")
    client.publish('tipup', 'flag')
    time.sleep(1)

  if (GPIO.input("XIO-P2") == False):
    print ("Button P2 Pressed")
    client.publish('tipup', 'off')
    time.sleep(1)

这是我的主板代码(经纪人)

import paho.mqtt.client as paho
import CHIP_IO.GPIO as GPIO

GPIO.cleanup()
GPIO.setup("XIO-P2", GPIO.OUT)
GPIO.output("XIO-P2", GPIO.HIGH)

def on_connect(client, userdata, flags, rc):
  print("Connected with result code " + str(rc))
  client.subscribe("tipup")
  print("Subscribed")

def on_message(client, userdata, msg):
  print ("Message Received")
  print (str(msg.payload))

  if (msg.payload == 'flag'):
    print("Went through 'flag' if statement")
    print("Turning on LED")   
    GPIO.output("XIO-P2", GPIO.LOW)

  if (msg.payload == 'off'):
    print ("Turning off LED")
    GPIO.output("XIO-P2", GPIO.HIGH)

client = paho.Client()

client.on_connect = on_connect
client.on_message = on_message

client.connect("172.20.0.1", 1883)

client.loop_forever()

GPIO.cleanup()

当我在我的主板代码中打印 str(msg.payload) 时出现问题。我应该补充一点,这两个编译和运行都很好,这只是我在弄清楚为什么它没有通过我在 on_message() 中的任何一个 if 语句时注意到的一个问题。

最佳答案

'bXXX' means bytes .你需要convert this to UTF-8使用前:

msg.payload = msg.payload.decode("utf-8")

不过,我不确定为什么负载是以字节为单位的。

关于Python- 为什么我的 Paho Mqtt 消息与我发送的消息不同?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40922542/

相关文章:

Swift MQTT libmosquitto cleanSession 设置为 false 但无法设置持久订阅

openssl - Mosquitto OpenSSL 握手失败。

java - MQTT - Paho IMqttMessageLIstener 当监听器线程因操作而被阻止时会丢失消息

Python [pydantic] - 日期验证

python - 如果在 xpath (lxml) 中找不到节点/标签,如何返回字符串或匹配空

python - 使用 python 抓取 ajax 页面

node.js - mqtt mosca pahojs WebSocket 连接到 'ws://localhost:1884/mqtt' 失败/超时

具有依赖于 CPU 密集型计算的响应的 Python 异步 REST API。如何高效处理?

ssl - Mosquitto TLS/SSL SSL3_READ_BYTES : ssl handshake failure, 错误:成功和 sslv3 警报

python - 如何在同一个 paho-mqtt 脚本下运行多个设备