質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

新規登録して質問してみよう
ただいま回答率
85.50%
Windows 10

Windows 10は、マイクロソフト社がリリースしたOSです。Modern UIを標準画面にした8.1から、10では再びデスクトップ主体に戻され、UIも変更されています。PCやスマホ、タブレットなど様々なデバイスに幅広く対応していることが特徴です。

Python 3.x

Python 3はPythonプログラミング言語の最新バージョンであり、2008年12月3日にリリースされました。

MQTT

MQTT(Message Queue Telemetry Transport)とは、TCP/IPネットワークで利用可能な通信プロトコルの一つで、IoT/M2M向けに開発された軽量なプロトコルです。ヘッダ部分は最小2バイトと小さく、通信量・CPU負荷・電力消費量などを抑えることができます。

Q&A

解決済

1回答

5751閲覧

MQTT/Subscribeで途中でプログラムが停止する

BuhKeil

総合スコア34

Windows 10

Windows 10は、マイクロソフト社がリリースしたOSです。Modern UIを標準画面にした8.1から、10では再びデスクトップ主体に戻され、UIも変更されています。PCやスマホ、タブレットなど様々なデバイスに幅広く対応していることが特徴です。

Python 3.x

Python 3はPythonプログラミング言語の最新バージョンであり、2008年12月3日にリリースされました。

MQTT

MQTT(Message Queue Telemetry Transport)とは、TCP/IPネットワークで利用可能な通信プロトコルの一つで、IoT/M2M向けに開発された軽量なプロトコルです。ヘッダ部分は最小2バイトと小さく、通信量・CPU負荷・電力消費量などを抑えることができます。

0グッド

0クリップ

投稿2021/03/16 06:13

MQTT通信が途中で止まる

概要

 同じLAN内に設置したmqttサーバ(Broker)にアクセスして複数のトピックスを購読(Subscribe)し、受信したメッセージを(先ずは)画面に表示し、通信が安定してできているかチェックしている状態です。プログラムを実行すると、最初のうちは問題なくデータを表示できているのですが、しばらく経過すると同じエラーで停止します。開発環境を示した後に、Pythonコード、出力されるエラーメッセージ、参考にしたサイトを掲示します。

client.loop_forever()がトラブルの根源なのかと思ったのですが、エラーメッセージの最後を見ると、on_disconnection関数のrcという変数が指定の場所にない、と言われおり、何を修正すれば良いのか判りません。どのように修正すればよいのか教えて下さい。

環境

  • Windows10 64bit
  • WinPython (Python v=3.8.3)
  • module : paho-mqtt のバージョン= 1.5.1

Pythonプログラム(ファイル名は、sub.py)

Pyhon3

1import paho.mqtt.client as mqtt 2import sys 3 4def on_connect(client, userdata, flag, rc): 5 if rc == 0: 6 print("Connected with Broker") 7 else: 8 print("Not Connected with rc=",str(rc)) 9 sys.exit() 10 11 client.subscribe("AAA/BBB/CCC") 12 client.subscribe("AAA/BBB/DDD") 13 14def on_message(client, userdata, msg): 15 if msg.topic == "AAA/BBB/CCC": 16 print("CCC=", str(msg.payload)) 17 if msg.topic == "AAA/BBB/DDD": 18 print("DDD=", str(msg.payload)) 19 20def on disconnect(client, userdata, flag, rc): 21 if rc == 1: 22 print("Connection Refused : incorrect protocol version") 23 sys.exit() 24 elif rc == 2: 25 print("Connection Refused : invalid client identifier") 26 sys.exit() 27 elif rc == 3: 28 print("Connection Refused : Server unavailable") 29 sys.exit() 30 elif rc == 4: 31 print("Connection Refused : bad username or password") 32 sys.exit() 33 elif rc == 5: 34 print("Connection Refused : not authorised") 35 sys.exit() 36 else: 37 print("Currently Unused") 38 sys.exit() 39 40client = mqtt.Client() 41client.on_connect = on_connect 42client.on_message = on_message 43client.on_disconnect = on_disconnect 44client.connect(host="BROKER_IP_ADDR", port=1883, keepalive=60) 45client.loop_forever()

出力されるエラーメッセージ

Error

1Traceback (most recent call last): 2File sub.py, line xxx, in <module> client.loop_forever() 3File ".../python-3.8.6.amd64\lib\site-packages\paho\mqtt\client.py", line 1779, in loop_forever rc = self.loop(timeout, max_packets) 4File ".../python-3.8.6.amd64\lib\site-packages\paho\mqtt\client.py", line 1201, in loop return self.loop_misc() 5File ".../python-3.8.6.amd64\lib\site-packages\paho\mqtt\client.py", line 1644, in loop_misc self._do_on_disconnect(rc) 6File ".../python-3.8.6.amd64\lib\site-packages\paho\mqtt\client.py", line 3360, in _do_on_disconnect self.on_disconnect(self, self._userdata, rc) 7 8TypeError : on_disconnect() missing 1 required positional argument: "rc" 9

参考にしたサイト

pythonでMQTT送受信

気になる質問をクリップする

クリップした質問は、後からいつでもMYページで確認できます。

またクリップした質問に回答があった際、通知やメールを受け取ることができます。

バッドをするには、ログインかつ

こちらの条件を満たす必要があります。

guest

回答1

0

ベストアンサー

on_disconnect の引数は client, userdata, rc の3つです。flag はありません。

Callbacks より

on_disconnect(client, userdata, rc) Called when the client disconnects from the broker. client the client instance for this callback userdata the private user data as set in Client() or user_data_set() rc the disconnection result

投稿2021/03/16 09:46

編集2021/03/16 09:50
yuki23

総合スコア1448

バッドをするには、ログインかつ

こちらの条件を満たす必要があります。

yuki23

2021/03/16 09:54

ここでエラーが起きるのは、何か問題があってブローカーとの通信が切断されたということです。 その原因はご質問の情報ではわかりません。ただ、通信切断時のエラー処理の実装が誤っているので、切断の原因を表示する前に強制終了しているということです。
BuhKeil

2021/03/17 01:48

yuki23さま、回答ありがとうございます。 公式のドキュメントで、 https://www.eclipse.org/paho/index.php?page=clients/python/docs/index.php#connect-reconnect-disconnect ばかりを見ていて、引数がなく、どうしてかとずっと悩んでいました。 探したら指摘して頂いたように、同ドキュメントの後ろの方にありましたね。 on_disconnect(client, userdata, rc)の記述がありました。 positional argumentという意味もやっと分かりました。 ご指摘ありがとうございました。
guest

あなたの回答

tips

太字

斜体

打ち消し線

見出し

引用テキストの挿入

コードの挿入

リンクの挿入

リストの挿入

番号リストの挿入

表の挿入

水平線の挿入

プレビュー

15分調べてもわからないことは
teratailで質問しよう!

ただいまの回答率
85.50%

質問をまとめることで
思考を整理して素早く解決

テンプレート機能で
簡単に質問をまとめる

質問する

関連した質問