一种从MQTT消息系统到Pulsar流数据平台的桥接实现方法

摘要

本发明公开了一种从MQTT消息系统到Pulsar流数据平台的桥接实现方法，构建MQTT+Pulsar主题，包括创建主题和规则；描述基于SQL的业务规则，并通过API的方式传入到数据处理规则管理引擎中，并将这些业务规则翻译为Pulsar中对应的Source、Functions和Sink；根据系统闲置资源，桥接Pulsar，通过扩展Pulsar的Functions对消息进行实时处理，处理完后发送到外部系统中并存储日志消息。使用MQTT和Pulsar使消息服务平台实现了物联网设备数据接入、设备管理、数据存储和数据分析等功能，并且提供了灵活的编程接口。