pythonwebsocketraspberry-pimqtt

MQTT_IO on PI, "client_socket, mqtt.WebsocketWrapper" error

I’ve been looking at this for days now, can’t figure it out! Hope that someone can point me in the correct direction!

I’m running Home Assistant on a VM on a Synology. Within Home Assistant, there is running a Mosquitto broker. I’m running MQTT-IO (https://mqtt-io.app/2.3.0/#/) on a RaspberryPi to connect its GPIO pins over MQTT to Home Assistant to control devices in my smart home. (https://mqtt-io.app/2.3.0/#/) Everything ran fine for over a year, last week my Pi ate the already old SD-card...

Because I’m stupid, I don’t have a backup of the PI :) So, I’ve been in the process of setting this up again, my old SD card boots and runs for +-10min before crashing. This way I can compare configs, but I’m not figuring it out!

It seems the “new” Pi is missing something.

Terminal input

python3 -m mqtt_io /home/Kwarco/Desktop/config.yml

Terminal output

`2024-06-14 22:33:59 mqtt_io.server [INFO] Digital output 'Ctrl_GordijnDicht' current value is False (raw: True)
2024-06-14 22:34:00 mqtt_io.server [INFO] Digital output 'Ctrl_GordijnOpen' current value is False (raw: True)
2024-06-14 22:34:01 mqtt_io.server [INFO] Digital output 'Ctrl_VerluchtingPower' current value is False (raw: True)
2024-06-14 22:34:02 mqtt_io.server [INFO] Digital output 'Ctrl_Verluchting1' current value is False (raw: True)
2024-06-14 22:34:03 mqtt_io.server [INFO] Digital output 'Ctrl_Verluchting2' current value is False (raw: True)
2024-06-14 22:34:04 mqtt_io.server [INFO] Digital output 'Ctrl_Verluchting3' current value is False (raw: True)
2024-06-14 22:34:05 mqtt_io.server [INFO] Digital output 'Ctrl_LuikDicht' current value is False (raw: False)
2024-06-14 22:34:06 mqtt_io.server [INFO] Digital output 'Ctrl_LuikOpen' current value is False (raw: False)
2024-06-14 22:34:06 mqtt_io.server [INFO] Connecting to MQTT...
2024-06-14 22:34:06 mqtt_io.server [ERROR] Exception in critical task:
Traceback (most recent call last):
  File "/usr/local/lib/python3.11/dist-packages/mqtt_io/server.py", line 1380, in _main_loop
    await self._connect_mqtt()
  File "/usr/local/lib/python3.11/dist-packages/mqtt_io/server.py", line 707, in _connect_mqtt
    await self.mqtt.connect()
  File "/usr/local/lib/python3.11/dist-packages/mqtt_io/mqtt/asyncio_mqtt.py", line 51, in inner
    await func(*args, **kwargs)
  File "/usr/local/lib/python3.11/dist-packages/mqtt_io/mqtt/asyncio_mqtt.py", line 116, in connect
    await self._client.connect(timeout=timeout)
  File "/home/Kwarco/.local/lib/python3.11/site-packages/asyncio_mqtt/client.py", line 82, in connect
    if not isinstance(client_socket, mqtt.WebsocketWrapper):
                                     ^^^^^^^^^^^^^^^^^^^^^
AttributeError: module 'paho.mqtt.client' has no attribute 'WebsocketWrapper'
2024-06-14 22:34:08 mqtt_io.server [INFO] Reconnecting to MQTT broker (infinite retries remaining)
2024-06-14 22:34:08 mqtt_io.server [INFO] Connecting to MQTT...
2024-06-14 22:34:08 mqtt_io.server [ERROR] Exception in critical task:
Traceback (most recent call last):
  File "/usr/local/lib/python3.11/dist-packages/mqtt_io/server.py", line 1380, in _main_loop
    await self._connect_mqtt()
  File "/usr/local/lib/python3.11/dist-packages/mqtt_io/server.py", line 707, in _connect_mqtt
    await self.mqtt.connect()
  File "/usr/local/lib/python3.11/dist-packages/mqtt_io/mqtt/asyncio_mqtt.py", line 51, in inner
    await func(*args, **kwargs)
  File "/usr/local/lib/python3.11/dist-packages/mqtt_io/mqtt/asyncio_mqtt.py", line 116, in connect
    await self._client.connect(timeout=timeout)
  File "/home/Kwarco/.local/lib/python3.11/site-packages/asyncio_mqtt/client.py", line 82, in connect
    if not isinstance(client_socket, mqtt.WebsocketWrapper):
                                     ^^^^^^^^^^^^^^^^^^^^^
AttributeError: module 'paho.mqtt.client' has no attribute 'WebsocketWrapper'
^CTraceback (most recent call last):
  File "<frozen runpy>", line 198, in _run_module_as_main
  File "<frozen runpy>", line 88, in _run_code
  File "/usr/local/lib/python3.11/dist-packages/mqtt_io/__main__.py", line 115, in <module>
    main()
  File "/usr/local/lib/python3.11/dist-packages/mqtt_io/__main__.py", line 107, in main
    mqtt_gpio.run()
  File "/usr/local/lib/python3.11/dist-packages/mqtt_io/server.py", line 1458, in run
    self.loop.run_until_complete(self._main_task)
  File "/usr/lib/python3.11/asyncio/base_events.py", line 653, in run_until_complete
    return future.result()
           ^^^^^^^^^^^^^^^
  File "/usr/local/lib/python3.11/dist-packages/mqtt_io/server.py", line 1422, in _main_loop
    await asyncio.sleep(reconnect_delay)
  File "/usr/lib/python3.11/asyncio/tasks.py", line 639, in sleep
    return await future
           ^^^^^^^^^^^^
asyncio.exceptions.CancelledError
Exception ignored in: <coroutine object MqttIo.digital_output_loop at 0x75804708>
Traceback (most recent call last):
  File "/usr/local/lib/python3.11/dist-packages/mqtt_io/server.py", line 1304, in digital_output_loop
  File "/usr/lib/python3.11/asyncio/queues.py", line 160, in get
  File "/usr/lib/python3.11/asyncio/base_events.py", line 761, in call_soon
  File "/usr/lib/python3.11/asyncio/base_events.py", line 519, in _check_closed
RuntimeError: Event loop is closed
Exception ignored in: <function Client.__del__ at 0x758173e8>
Traceback (most recent call last):
  File "/home/Kwarco/.local/lib/python3.11/site-packages/paho/mqtt/client.py", line 880, in __del__
  File "/home/Kwarco/.local/lib/python3.11/site-packages/paho/mqtt/client.py", line 1139, in _reset_sockets
  File "/home/Kwarco/.local/lib/python3.11/site-packages/paho/mqtt/client.py", line 1132, in _sock_close
  File "/home/Kwarco/.local/lib/python3.11/site-packages/paho/mqtt/client.py", line 2867, in _call_socket_close
  File "/home/Kwarco/.local/lib/python3.11/site-packages/asyncio_mqtt/client.py", line 308, in _on_socket_close
  File "/usr/lib/python3.11/asyncio/base_events.py", line 761, in call_soon
  File "/usr/lib/python3.11/asyncio/base_events.py", line 519, in _check_closed
RuntimeError: Event loop is closed
sys:1: RuntimeWarning: coroutine 'MqttIo._mqtt_publish' was never awaited


**Mosquitto broker logs:**
2024-06-14 22:34:06: New client connected from 192.168.XX.XX:43371 as mqtt-io-1634c5d8600786512fd602 (p2, c0, k60, u'Kwarco').
2024-06-14 22:34:08: New connection from 192.168.XX.XX:51041 on port 1883.
2024-06-14 22:34:08: Client mqtt-io-1634c5d8600786512fd602 already connected, closing old connection.
2024-06-14 22:34:08: New client connected from 192.168.XX.XX:51041 as mqtt-io-1634c5d860079c65156613caae5cfa86512fd602 (p2, c0, k60, u'Kwarco').
2024-06-14 22:34:09: Client mqtt-io-1634c5d8600786512fd602 closed its connection.`

/home/Kwarco/Desktop/config.yml content

mqtt:
  host: 192.168.xx.xx
  port: 1883
  user: "Kwarco"
  password: "xxxxxxxxxxxxxx"
  ha_discovery:
   enabled: yes
  topic_prefix: pimqtt/gpio
  status_topic: status
  status_payload_running: online
  status_payload_stopped: offline
  status_payload_dead: dead

gpio_modules:
  - name: raspberrypi
    module: raspberrypi

digital_outputs:
  - name: Ctrl_GordijnDicht
    module: raspberrypi
    pin: 2 # GPIO 
    on_payload: "ON"
    off_payload: "OFF"
    inverted: true
    initial: high
  - name: Ctrl_GordijnOpen
    module: raspberrypi
    pin: 3 # GPIO 
    on_payload: "ON"
    off_payload: "OFF"
    inverted: true
    initial: high
  - name: Ctrl_VerluchtingPower
    module: raspberrypi
    pin: 26 # GPIO 
    on_payload: "ON"
    off_payload: "OFF"
    inverted: true
    initial: high
  - name: Ctrl_Verluchting1
    module: raspberrypi
    pin: 6 # GPIO 
    on_payload: "ON"
    off_payload: "OFF"
    inverted: true
    initial: high
  - name: Ctrl_Verluchting2
    module: raspberrypi
    pin: 13 # GPIO 
    on_payload: "ON"
    off_payload: "OFF"
    inverted: true
    initial: high
  - name: Ctrl_Verluchting3
    module: raspberrypi
    pin: 19 # GPIO 
    on_payload: "ON"
    off_payload: "OFF"
    inverted: true
    initial: high
  - name: Ctrl_LuikDicht
    module: raspberrypi
    pin: 7 # GPIO 
    on_payload: "ON"
    off_payload: "OFF"
    inverted: false
    initial: low
  - name: Ctrl_LuikOpen
    module: raspberrypi
    pin: 1 # GPIO 
    on_payload: "ON"
    off_payload: "OFF"
    inverted: false
    initial: low

I don't understand that the connection is not going true. There is no change on the Home Assistant Side, i'm literally using the same config and commands, The only thing that is different is the versions of software. I tried to downgrade Raspberry Pi OS with no change. I cannot install a previous version of MQTT_IO

Solution

  • Best guess your old code was running with Paho v1.x and the latest (v2.1) removed the WebsocketWrapper as part of the major version change at v2.0.

    https://github.com/eclipse/paho.mqtt.python/releases/tag/v2.0.0

    You need to force the installation of v1.x or upgrade the code to work with the new v2.0 paho library.

    There is a migration guide here: https://eclipse.dev/paho/files/paho.mqtt.python/html/migrations.html