我在网站上工作,使用 Django 进行开发。我有一些使用 MQTT 与网站通信的设备,我打算使用 paho-mqtt 客户端。我的问题是,要使 paho-mqtt 正常运行,我必须调用一个永远循环的函数,同时 paho-mqtt 继续监听消息。调用此循环并将其包含在它自己的线程中的最佳方法是什么?
我可以只创建一个新线程,还是应该使用 celery 之类的东西?
最佳答案
改用 paho-mqtt 的线程接口(interface)。这会启动一个后台线程来处理网络处理,并且可以使用 loop_start()
进行访问。或者,您可以创建自己的线程,然后自己调用 loop()
。
关于python - 使用 Django 时如何处理 mqtt loop_forever 函数?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/26662422/