MQTT 代理 + mongoDB

Question

如何将 MQTT 代理与 mongoDB 集成？

我将 GPS 坐标从客户端发布到代理，并希望使用 mongoDB 将其存储在 MQTT 代理中，

如果共享一些相同的指针，将不胜感激

Answer 1

如果您希望代理将消息直接可靠地存储到数据库，您可以使用HiveMQ并编写 MongoDB 插件。这篇博文描述了这个概念。

另一个想法是使用通配符订阅者来获取所有消息并将其存储到 MongoDB。这不是直接集成，但如果您不想横向扩展，则可以使用。

Answer 2

我四处搜索，没有找到任何适合自己的解决方案，因此我创建了一个：https: //github.com/izmailoff/mqtt-mongo。

有关所有详细信息，请参阅自述文件。本质上，它是一个独立的服务，连接到 MQTT 代理和 MongoDB 并订阅您感兴趣的主题。您可以在配置中为每个主题选择一个集合。

设计目标是提供弹性、轻量级和快速的服务，您还可以使用 Java/Scala 或任何支持此类集成的 JVM 语言中的代码进行自定义。

Answer 3

可能最简单的方法是使用 Node-Red ( http://nodered.org )

如果 MQTT 有效负载是格式正确的 json 对象，则链接到 mongodb 节点的一个 MQTT 输入节点将执行此操作。

如果您需要在插入之前更改有效负载，您可以包含一个功能节点来重新映射它。