如何在Django中处理mqtt的loop_forever函数？

Question

我正在开发一个网站，使用Django这个框架。我有一些设备通过MQTT协议和网站进行通信，我打算使用paho-mqtt这个客户端。我的问题是，为了让paho-mqtt正常工作，我必须调用一个会一直循环的函数，这样paho-mqtt才能持续监听消息。那么，如何才能让这个循环在自己的线程中运行呢？

我可以直接创建一个新线程吗，还是应该使用像celery这样的工具呢？

Answer 1

建议使用paho-mqtt的线程接口。这样可以启动一个后台线程来处理网络相关的工作，你可以通过调用 loop_start() 来使用它。或者，你也可以自己创建一个线程，然后直接调用 loop() 来处理。