您可以使用规则引擎数据流转功能,将设备数据转发到消息服务主题中,服务端再从消息服务主题中订阅消息,实现设备端与服务端之间高性能的消息闭环传输。

前提条件

  • 已创建消息服务主题,并在该主题下创建推送类型为HTTP或队列的订阅。消息服务使用方法,请参见消息服务MNS文档
  • 已创建数据转发规则和编写处理数据的SQL,请参见设置数据流转规则

数据转发流程

  • 设备发送数据到服务端。

    设备发布消息到物联网平台中,物联网平台通过规则引擎将消息进行处理并转发到消息服务的主题中。然后,您的应用服务器调用消息服务的接口订阅消息。

    这种方式优势是消息服务可以保证消息的可靠性,避免了服务端不可用时导致消息丢失。同时,消息服务在处理大量消息并发时,有削峰填谷的作用,保证服务端不会因为突然的并发压力导致服务不可用。物联网平台与消息服务的结合,可以实现设备端与服务端之间高性能的消息闭环传输。

  • 服务端发送数据到设备。

    您的应用服务器调用物联网平台的云端 API,发布数据到物联网平台中,然后设备从物联网平台中订阅消息。

数据流转示意图如下。

设备数据流转

操作步骤

  1. 登录物联网平台控制台
  2. 在左侧导航栏,选择规则引擎 > 云产品流转
  3. 单击规则对应的查看,进入数据流转规则页。
  4. 单击转发数据一栏对应的添加操作
  5. 添加操作对话框中,选择操作为发送数据到消息服务(MNS)中。按照界面提示,设置其他信息,单击确认
    参数 描述
    选择操作 选择发送数据到消息服务(MNS)中
    地域 选择消息服务所在地域。
    主题 选择接收数据的消息服务主题。

    消息服务会将接收到的消息发送给该主题下的HTTP和队列类型的订阅。目前,物联网平台推送至消息服务主题的消息,仅可以通过HTTP或队列两种方式订阅。

    您可以单击创建主题,跳转到消息服务MNS控制台,创建消息服务主题以及订阅。请参见消息服务MNS文档

    角色 授权物联网平台将数据写入消息服务。

    如您还未创建相关角色,单击创建RAM角色,跳转到RAM控制台,创建角色和授权策略,请参见创建RAM角色

  6. 回到云产品流转页,单击规则对应的启动按钮启动规则。