规则引擎支持用户配置规则将符合条件的设备上报数据转发到 消息队列 CKAFKA (以下简称 CKAFKA ),用户的应用服务器再从 CKAFKA 中读取数据内容进行处理。以此利用 CKAFKA 高吞吐量的优势,为用户打造高可用性的消息链路。
下图展示了规则引擎将数据转发给 CKAFKA 的整个过程:
登录 物联网通信控制台,单击左侧菜单【规则引擎】。
进入规则引擎页面,单击需要配置的规则。
在规则详情页面,单击【添加行为操作】。
说明:第一次使用时会提示用户授权访问 CKAFKA,您需单击【授权访问】才能继续创建。
在弹出的“添加规则”窗口,选择行为“数据转发到消息队列(CKAFKA)”;依次选择 CKAFKA 实例和 Topic,单击【保存】即可。
完成以上配置后,物联网通信平台会将符合规则条件的设备上报数据转发至用户配置的 CKAFKA 。您可以参考 创建实例和 Topic 文档,在应用服务器上读取数据并进行处理。
重发机制用于在消息转发过程中发生失败的情况下,进行再次重发以达到接受消息的目的,具体说明如下:
本页内容是否解决了您的问题?