MQTT над WebSocket в питона

Question

есть ли поддержка в питона, чтобы подписаться на MQTT брокера с портом 8080

import sys 
import paho.mqtt.client as mqtt 

def on_connect(mqttc, obj, flags, rc): 
    print("rc: "+str(rc)) 

def on_message(mqttc, obj, msg): 
    print(msg.topic+" "+str(msg.qos)+" "+str(msg.payload)) 

def on_publish(mqttc, obj, mid): 
    print("mid: "+str(mid)) 

def on_subscribe(mqttc, obj, mid, granted_qos): 
    print("Subscribed: "+str(mid)+" "+str(granted_qos)) 

def on_log(mqttc, obj, level, string): 
    print(string) 

mqttc = mqtt.Client() 
mqttc.on_message = on_message 
mqttc.on_connect = on_connect 
mqttc.on_publish = on_publish 
mqttc.on_subscribe = on_subscribe 
mqttc.connect("test.mosquitto.org", 8080, 60) 
mqttc.subscribe("test/iot", 0) 

mqttc.loop_forever() 

я не могу соединиться с этим кодом. Mosquitto имеет поддержку websocket на порту 8080, но эта библиотека paho не работает. любое решение для python? Я использую python 2.7 на окнах 10.

Answer 1

Модуль Pāho MQTT представил WebSocket поддерживает несколько дней назад. Я не думаю, что он выпущен еще, но вы можете установить его из мастера в подразделении Linux, используя

pip install git+git://github.com/eclipse/paho.mqtt.python.git 

Также работает под окнами. (Спасибо за информацию из комментариев)

Вы можете использовать WebSockets как транспорт, соединив с

mqttc = mqtt.Client(transport="websockets") 

UPDATE:

Если вы пытаетесь использовать протокол WebSocket с клиентом питона, потому что вам также необходимо подключить клиент браузера (например, MQTT.js), после чего вы также можете настроить mosquitto для прослушивания веб-сайтов и обычного протокола mqtt.

Просто создайте файл конфигурации, например, в

/etc/mosquitto/mosquitto.conf 

со следующим содержанием:

listener 1883 
protocol mqtt 

listener 9001 
protocol websockets 

Затем вы можете запустить mosquitto с

mosquitto -c /etc/mosquitto/mosquitto.conf 

Вы должны увидеть подобный вывод :

затем

1469015320: mosquitto version 1.4.8 (build date 2016-05-3112:07:40+0200) starting 
1469015320: Config loaded from /etc/mosquitto/mosquitto1.conf. 
1469015320: Opening ipv4 listen socket on port 1883. 
1469015320: Opening ipv6 listen socket on port 1883. 
1469015320: Opening websockets listen socket on port 9001. 

Ваш клиент питона подключается к порту 1883 и браузера клиента к 9001

Вы можете использовать what-mqtt browser client для проверки WebSocket слушателя. Просто укажите это на ws://localhost:9001

Answer 2

Нет, версия библиотеки Paho для Python не поддерживает MQTT поверх Websockets.

На самом деле я считаю, что только родная сторона клиента (не в браузере) библиотека MQTT, которая поддерживает MQTT над WebSockets является модулем NodeJS (https://www.npmjs.com/package/mqtt)

Answer 3

Между февралем и сейчас исправлена ​​кодовая база paho.mqtt.python. Просто добавьте transport='websockets', как предложил Fl0v0, он просто работает. Ниже приведен полный код, который подписывается на все или все под $SYS/. Код испытания на главной ветви Зафиксировать хэш e56f913 на 3 июня 2016 года

#!/usr/bin/python 

import sys 
import paho.mqtt.client as mqtt 

def on_connect(mqttc, obj, flags, rc): 
    print("rc: "+str(rc)) 

def on_message(mqttc, obj, msg): 
    print(msg.topic+" "+str(msg.qos)+" "+str(msg.payload)) 

def on_publish(mqttc, obj, mid): 
    print("mid: "+str(mid)) 

def on_subscribe(mqttc, obj, mid, granted_qos): 
    print("Subscribed: "+str(mid)+" "+str(granted_qos)) 

def on_log(mqttc, obj, level, string): 
    print(string) 

mqttc = mqtt.Client(transport='websockets') 
mqttc.on_message = on_message 
mqttc.on_connect = on_connect 
mqttc.on_publish = on_publish 
mqttc.on_subscribe = on_subscribe 

mqttc.connect("test.mosquitto.org", 8080, 60) 

mqttc.subscribe("#", 0) 
#mqttc.subscribe("$SYS/#", 0) 

mqttc.loop_forever() 

Update: Код выше не работает на Windows 7 с питоном 2.7.6, что я тестировал с путем вызова от одного версия Cygwin (но не cygwin python).Ни одна из тем "#" или "$SYS/#" не опубликовала ни одного опубликованного сообщения.

Вместо этого в качестве примера следует использовать паб или субтитра. Патч paho.mqtt.python examples/pub-single.py и examples/sub-simple.py. Затем запустите sub-simple.py в одном терминале. Запустите pub-single.py в другом терминале, дважды. Абонентский терминал распечатает два сообщения, опубликованные издателем.

Патч к examples/pub-single.py:

-publish.single("paho/test/single", "boo", hostname="test.mosquitto.org") 
+publish.single("/HelloWorld", "boo", hostname="test.mosquitto.org", 
+    port=8080, transport='websockets') 

Патч к examples/sub-simple.py:

-topics = ['#'] 
+topics = ['/HelloWorld'] 

-m = subscribe.simple(topics, hostname="iot.eclipse.org", retained=False, msg_count=2) 
+m = subscribe.simple(topics, hostname="test.mosquitto.org", 
+       retained=False, msg_count=2, 
+       port=8080, transport='websockets')