一尘不染

有没有一种方法可以将Mosquitto有效载荷存储到MySQL数据库中以进行历史记录?

mysql

我正在使用Mosquitto MQTT代理,并且希望将每个发布的消息存储到MySQL数据库中,而无需创建客户端和订阅#通配符。

我发现了这个https://github.com/jpmens/mosquitto-auth-
plug,但是我的英语不够好,无法完全理解它…我认为这只是存储持久性消息,以便代理稍后再发送。我对吗 ?

谢谢


阅读 1063

收藏
2020-05-17

共1个答案

一尘不染

mosquitto-auth-plugin使用数据库存储用户名/密码和ACL信息,而不是消息内容。

从任何MQTT代理编写一些代码以将消息存储在数据库中相对简单。

有几种方法:

  1. 您可以编写一个小型java / python / nodejs应用程序来使用给定语言的MQTT 之一来执行此操作。
  2. 您可以使用诸如Node-RED之类的东西来创建将消息写入数据库的流。
  3. 您可以使用HiveMQ代理而不是Mosquitto,该代理具有支持将消息存储在数据库中的插件机制。
2020-05-17