在服务器端处理 MQTT 消息的最佳方法是什么?

What's the best approach for processing MQTT message in server side?

我正在编写一个 Web 应用程序以在处理后将 MQTT 数据记录到数据库中,然后仪表板将查询数据库并可视化数据。

我正在使用 python 脚本,该脚本始终与 Paho MQTT 客户端一起运行,以处理 MQTT 数据并将其存储在数据库中。

我认为应该有更好且可扩展的方式来处理 MQTT 负载。谁能提出更好的方法?

我以前也有过同样的疑惑,但我觉得你做的是对的。

如果我们进一步考虑 MQTT 的本质,在 MQTT 上下文中没有传统的“服务器端”。很可能,人们将“代理”视为服务器端,但它完全不同,MQTT 核心概念中的代理应为 content-agnostic,因此不应直接处理消息。

当然,您始终可以将用于数据处理功能的内部订阅者与代理捆绑在一起,使其看起来像一个完整的“服务器”解决方案,就像一些商业 MQTT 代理所做的那样。但从概念上讲,它仍然由订户处理,与您提出的方式没有太大区别。