管理AMQP消费组

重要

本文中含有需要您注意的重要提示信息,忽略该信息可能对您的业务造成影响,请务必仔细阅读。

消费组是消息消费端的身份标识。消息消费端以消费组身份接入物联网平台,并接收物联网平台转发到消费组的消息。IoT孪生引擎中支持配置AMQP消费组,实现企业服务器订阅IoT孪生引擎中孪生节点的属性数据。本文介绍如何在IoT孪生引擎中添加、查看和删除消费组。

使用说明

将消费组ID配置到AMQP客户端上,AMQP客户端以消费组身份接入物联网平台,接收消息。AMQP客户端接入方法请参考物联网平台下消息转发中AMQP客户端接入方法。具体内容,请参见AMQP客户端接入说明

重要

配置消费组ID时,需使用IoT孪生引擎中添加的消费组ID。

多个AMQP客户端(最多64个)可以使用同一个消费组ID,组成消息消费集群。当设备消息到达时,物联网平台将消息随机发往消费组ID中的任一个客户端。

创建消费组

  1. 进入孪生空间页面。具体操作,请参见查看孪生空间

  2. 在孪生空间页面左侧导航栏,单击数据流转

  3. 单击AMQP消费组页签。

  4. 单击创建消费组

  5. 在弹出的对话框中,输入消费组名称。

    消费组名称支持中文、英文字母、日文、数字和下划线(_),长度范围为4~30个字符。一个中文或日文占2个字符。

  6. 单击确认

    根据页面提示,可直接进入消费组详情页面。您可单击右上角编辑,修改消费组名称。

    image

查看和监控消费组

您可以查看消费组内的消息消费速率、消息堆积量,也可以设置云监控报警规则来监控消费组。

  1. AMQP消费组页签,找到要查看的消费组,并单击对应的查看

  2. 消费组状态页签,查看订阅消息的实时消息消费速率堆积消息消费速率消息堆积量最近消费时间和在线客户端列表。

    image
  3. 消费组状态页签,单击报警配置,然后在创建报警规则页面,配置云监控阈值报警规则,监控消费组消息堆积数、消费组消息消费速率,并接收报警消息。

    具体操作,请参见创建阈值报警规则

  4. 单击消费日志页签,可查看具体的消费记录。

    image

删除消费组

删除消费组后,该组内的所有消费端会停止接收消息。

警告

删除消费组成功后,如果AMQP服务端订阅中使用了该消费组,会导致AMQP服务端订阅服务不可用、用户业务中断。请谨慎操作。

  1. AMQP消费组页签下,单击消费组对应的删除

    image
  2. 单击确认

后续操作

配置孪生节点属性数据转发到AMQP服务端的消费组。具体操作,请参见: