我尝试在 python3 中设置一个 mqtt 客户端。这不是我第一次这样做,但是我遇到了一个相当奇怪的行为。当尝试从回调函数之一(on_connect 或 on_message)调用包含错误的函数时,python 不会抛出异常(至少没有打印),它只是停在那里。我将一个简短的例子捆绑在一起,重现了这种行为。
有人有想法吗?
import paho.mqtt.client as mqtt
import re
import os.path
import json
from termcolor import colored
client = mqtt.Client()
def func():
test = 1 + "1"
print("Should never reach that")
def on_connect(client, userdata, flags, rc):
"""Establishes connection to broker
"""
print("Connected to broker with result code " + str(rc))
client.subscribe("test")
def on_message(client,userdata,msg):
print("Recieved message on " + msg.topic)
params = {}
if msg.topic == "test":
print("Invoke func")
func()
if __name__ == "__main__":
client.on_connect = on_connect
client.on_message = on_message
client.connect("localhost",1883,60)
client.loop_forever()
这是向主题“test”发送消息时的输出:
Connected to broker with result code 0
Recieved message on test
Invoke func
从 main 调用 func() 时,我得到正确的 TypeError 抛出。所以有些东西在 paho 中捕获了这个异常。我查看了一个较旧的项目(尽管是 python2)并尝试重新创建行为。在那里异常被正确抛出。我想念什么?
编辑 我可以通过将 func() 调用放在 try 块中来捕获异常。但是,当没有被捕获时,它不会停止程序的执行。我不明白为什么
神不在的星期二
元芳怎么了
白猪掌柜的
相关分类