设备连接物联网平台后，数据直接上报至物联网平台，平台上的数据可以通过AMQP通道流转至您的服务器。本文为您介绍配置AMQP服务端订阅设备消息的方法。

背景信息

创建AMQP服务端订阅消费组，用来消费设备产生的业务数据；使用规则引擎功能将指定Topic中的消息流转到AMQP服务端订阅消费组；您的云端应用可通过监听消费组获取消息。
物联网平台提供服务端订阅和云产品流转两种功能，实现企业服务器通过接入AMQP客户端，接收冷链运输追踪器上报的数据。本文描述两种配置方法，您可根据实际场景进行选择：
  • 订阅设备上报的自定义数据和物模型数据（属性上报、事件上报、属性设置响应和服务调用响应），请参见配置AMQP服务端订阅消息组。
  • 将设备上报的自定义数据或物模型数据进行处理后，再流转到AMQP服务端订阅。本示例提供自定义Topic数据的流转规则，请参见配置数据流转规则。

创建消费组

  1. 登录物联网平台控制台。
  2. 在实例概览页面，找到对应的企业版实例，单击实例进入实例详情页面。
  3. 在左侧导航栏，选择消息转发 > 服务端订阅，单击消费组列表页签。
  4. 单击创建消费组。
  5. 在创建消费组对话框中，输入组名（例如：冷链运输追踪器上报数据），单击确认。
    冷链运输追踪器上报数据

配置AMQP服务端订阅消息组

  1. 登录物联网平台控制台。
  2. 在实例概览页面，找到对应的企业版实例，单击实例进入实例详情页面。
  3. 在左侧导航栏，选择消息转发 > 服务端订阅。
  4. 在服务端订阅页面，单击创建订阅。
  5. 在创建订阅对话框中，完成配置，单击确认。
    参数说明
    产品选择冷链运输追踪器。
    订阅类型选择为AMQP。
    消费组单击选择目标消费组对话框右下角的创建消费组，新建消费组（例如：冷链运输追踪器上报数据）。消费组相关说明，请参见管理消费组。
    推送消息类型服务端要订阅的消息类型。本示例选择设备上报消息。详细说明，请参见设置订阅。

配置数据流转规则

  1. 登录物联网平台控制台。
  2. 在实例概览页面，找到对应的企业版实例，单击实例进入实例详情页面。
  3. 在左侧导航栏，选择消息转发 > 云产品流转。
  4. 在云产品流转页面，单击创建规则。
    重要 若当前页面显示新版功能，先单击右上角返回旧版，进入旧版功能页面，再单击创建规则。
  5. 填写参数后，单击确认。
    本案例规则名称为车厢数据流转到业务ECS，数据格式为JSON。其他参数自定义，更多信息，请参见设置数据流转规则。
  6. 规则创建成功后，单击对应规则后的查看，页面将跳转到数据流转规则页。您需编辑处理消息数据的SQL，设置数据转发目的地。
    流转规则
    1. 单击编写SQL，在弹出对话框中，输入SELECT的字段，并选择自定义的Topic，单击确认。
      如下所示，请您根据实际情况编写SQL。本示例完整SQL语句如下：
      SELECT  timestamp('yyyy-MM-dd HH:mm:ss') as timestamp,deviceName() as deviceName, Temperature, Humidity,Speed FROM "/YourProductKey/+/user/data/post"

      SQL编写方法，请参见SQL表达式和函数列表。

      编写SQL
    2. 单击转发数据一栏的添加操作，设置数据转发目的地为已创建的消费组（冷链运输追踪器上报数据）。具体操作，请参见数据转发到表格存储（Tablestore）。
      转到消费组
  7. 回到云产品流转页，单击规则对应的启动按钮，启动规则。

后续步骤

AMQP客户端接入