实时数据
更新时间: 2023-04-10
平台支持将设备数据实时推送给业务应用服务,业务应用可以接收设备实时数据进行处理进行告警、实时统计等。
实时数据推送有两种方式可选,两种方式的对比如下,用户可以根据需要选择适合的方式:
方式 | 使用场景 | 优缺点 |
---|---|---|
规则引擎 | 需将设备数据消息转发至其他Topic或其他云产品进行存储或处理的场景,以及海量吞吐量场景。 | 优点:功能相对完备。 支持在规则运行时,调整流转规则。 支持对数据进行简单过滤处理。 支持将数据流转至其他云产品。 缺点: 需编写查询语句和配置规则,使用相对复杂。 |
服务端订阅 | 仅需接收设备数据的场景。 服务端接收产品下已订阅的全部设备数据 | 优点:相对简单易用且高效。 缺点:缺少过滤和转换能力。 |
下面通过示例展示通过两种方式实现某个产品下所有设备上报的属性消息实时推送给业务服务器。
# 规则引擎
使用规则将消息推送给kafka或自定义http服务,详见《数据流转>规则引擎》章节
# 服务端订阅
开启产品的服务端订阅开关,平台推送产品下所有设备信息到消息队列中
获取消息消费组连接信息
详细操作可参考《数据流转>服务端订阅》和《快速入门>服务端订阅设备实时消息》两个章节