来自 Kafka 消息的 Websocket
我正在开发一个物联网项目，该项目使用 MQTT 协议将传感器数据从嵌入式设备传输到应用程序。为此，我创建了
- 一个 MQTT 代理来从设备发送数据。
- 一个自定义桥，将数据从 MQTT 代理推送到我的 Kafka 代理
- Django 服务器，通过 websocket 将消息推送到应用程序
现在，我需要的是使用来自 django 的 Kafka 消息，保存到数据库，然后将此数据推送到客户端通过网络套接字。但我对如何使用 Django 的 Kafka 消息不太了解。 到目前为止，我想到的解决方案是使用 自定义管理命令，启动kafka消费者，将数据推送到DB，然后推送到websockets。
这是一个好方法吗？如果没有，有什么好的解决方案可以解决这个问题？
I am working on an IoT project that uses MQTT protocol to transport the sensor data from embedded devices to an App. For this i have created,
- A MQTT broker to send the data from the device.
- A custom bridge that push data from MQTT broker to my Kafka broker
- Django server to push the messages via websocket to the App
Right now, What i need is to consume the Kafka messages from django, save to the DB and then push this data to client via websockets. But i don't have much idea regarding how to consume Kafka messages from Django.
So far the solution in my mind is using custom management command, start a kafka consumer, push the data to DB and then to websockets.
Is this a good approach? If not, what would be a good solution to solve this?
如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱，如果其他用户或者作者回复了您的评论，将不能在第一时间通知您！
发布评论
评论（1）
您可以添加定期任务来使用主题并向数据库批量插入（或更新）（这会影响性能）。
You can add periodic task to consume a topic and bulk insert (or update) to database (it impact on the performance).