Блог

Я совершенно новичок в IoT, и у меня есть упражнение по кодированию для моего университета. Я не знаю, как подключить этот скрипт, чтобы подключиться к MQTT и работать без ошибок.

Как я могу подключиться к MQTT? Сценарий выглядит следующим образом:

 import paho.mqtt.client as mqtt
import ssl
import os
import sys

import matplotlib.pyplot as plt
from matplotlib.widgets import Button
from threading import Timer
from datetime import datetime

class IoTExample:
    def __init__(self):
        self._establish_mqtt_connection()

    def start(self):
        self.client.loop_forever() 
    
    def disconnect(self, args=None):
        self.client.disconnect()

    def _establish_mqtt_connection(self):
        self.client = mqtt.Client
        self.client.on_log = self._on_log
        client.username_pw_set('iotlesson', 'YGK0tx5pbtkK2WkCBvJlJWCg')
        self.client.connect('phoenix.medialab.ntua.gr', 8883)
        client.subscribe('hscnl/hscnl02/state/ZWaveNode005_Switch/state')
        self.client.publish('hscnl/hscnl02/sendcommand/ZWaveNode005_Switch', 'ON')
        self.client.loop_forever()

    def _on_connect(self, client, userdata, flags, rc):
        self.client.on_connect = self._on_connect

    def _on_message(self, client, userdata, msg):
        self.client.on_message = self.on_message
        print(msg.topic ' ' str(msg.payload))

    def _on_log(self, client, userdata, level, buf):
        self.client.on_log = self._on_log
        print('log: ', buf)

try:
    iot_example = IoTExample()
    iot_example.start()
except KeyboardInterrupt:
    print('Interrupted')
    try:
        iot_example.disconnect()
        sys.exit(0)
    except SystemExit:
        os._exit(0)
  

Я получил следующие ошибки:

 python /home/mina/paho.mqtt.python/iot_example.py
Traceback (most recent call last):
  File "/home/mina/paho.mqtt.python/iot_example.py", line 41, in <module>
    iot_example = IoTExample()
  File "/home/mina/paho.mqtt.python/iot_example.py", line 13, in __init__
    self._establish_mqtt_connection()
  File "/home/mina/paho.mqtt.python/iot_example.py", line 24, in _establish_mqtt_connection
    self.client.connect('phoenix.medialab.ntua.gr', 8883)
TypeError: unbound method connect() must be called with Client instance as first argument (got str instance instead)
  

    def _establish_mqtt_connection(self):
        self.client = mqtt.Client()
  

Вам нужно добавить круглые скобки при создании Client экземпляра.

Ошибка типа: несвязанный метод connect() должен вызываться с экземпляром клиента в качестве первого аргумента (вместо этого есть экземпляр str)

Тот факт, что он говорит о несвязанном, указывает на то, что вы не создавали экземпляр. Вместо self.client этого было просто другое имя для самого Client класса.