如何在python中使用Mosquitto发布文件？

Question

我正在使用python-mosquitto订阅我的MQTT代理，该代理支持文件类型上传。从命令行在Mosquitto上使用-
f标志可以很好地使用它。但是，当我从python脚本中进行操作时，我无法弄清楚如何使用client.publish（topic，有效负载）指定要发布的文件。

TypeError: payload must be a string, bytearray, int, float or None.当我尝试向它扔一些奇怪的东西时，Python mosquitto给了我错误。我已经有一个文件存储在本地目录中，我想将其指定为发布的有效负载。

我对MQTT很有经验，但是我的python非常生锈，我假设我需要在此处执行某种类型的文件流功能，但不确定如何做到这一点。

我想在这里指定图片： mqttc.publish("/v3/device/file", NEED_TO_SPECIFY_HERE)

我尝试通过执行以下操作打开图像：

    f = open("/home/pi/mosq/imagecap/imagefile.jpg", "rb")
    imagebin = f.read()
    mqttc.publish("/v3/device/file", imagebin)

但这没有用，也没有用 mqttc.publish("/v3/device/file", bytearray(open('/tmp/test.png', 'r').read()))

client.publish不会引发错误，但是代理未正确接收文件。有任何想法吗？

谢谢！！

Answer 1

值得注意的是，这是Python 2和Python 3之间可能存在差异的领域之一。

Python 2file.read()返回a，str而Python
3返回bytes。mosquitto.publish()处理这两种类型，因此在这种情况下应该可以，但这是需要注意的。

我在下面的@hardillb的代码中添加了我认为有一些小的改进。请不要优先接受我的回答，因为他是最初写的，并且先到达那里！我本来可以编辑他的答案，但是我认为看到差异很有用。

#!/usr/bin/python

import mosquitto

def on_publish(mosq, userdata, mid):
  # Disconnect after our message has been sent.
  mosq.disconnect()

# Specifying a client id here could lead to collisions if you have multiple
# clients sending. Either generate a random id, or use:
#client = mosquitto.Mosquitto()
client = mosquitto.Mosquitto("image-send")
client.on_publish = on_publish
client.connect("127.0.0.1")

f = open("data")
imagestring = f.read()
byteArray = bytes(imagestring)
client.publish("photo", byteArray ,0)
# If the image is large, just calling publish() won't guarantee that all 
# of the message is sent. You should call one of the mosquitto.loop*()
# functions to ensure that happens. loop_forever() does this for you in a
# blocking call. It will automatically reconnect if disconnected by accident
# and will return after we call disconnect() above.
client.loop_forever()