您可以通过日志服务控制台查看日志消费的状态并设置告警。

前提条件

已开通服务日志中的重要日志。具体操作,请参见开通服务日志

背景信息

一个消费组包含多个消费者,每个消费者消费Logstore中的一部分Shard。同一个消费组下面的消费者共同消费一个Logstore中的日志数据,消费者之间不会重复消费数据。

Shard数据模型可以简单理解为一个队列,新写入的数据被加到队尾,队列中的每条数据都会对应一个数据写入时间,下图是Shard的数据模型。 shard数据模型
消费组消费延迟告警中的基本概念:
  • 消费过程:消费者从队头开始顺序读取数据的过程。
  • 消费进度:消费者当前读取的数据对应的写入时间。
  • 消费落后时长:当前消费进度和队列中最新的数据写入时间的差值,单位为秒。

消费组的消费落后时长取其包含的所有Shard的消费落后时长的最大值,当超过您预设的阈值时,则认定消费落后太多,触发报警。

操作步骤

  1. 登录日志服务控制台
  2. 在Project列表区域,单击目标Project。
  3. 在左侧导航栏中,选择仪表盘 > 仪表盘列表
  4. 仪表盘列表,单击消费组监控
    在仪表盘中查看消费状态,包括消费组延时Top10、消费落后时长、消费组列表等。
  5. 可选:设置告警规则。
    1. 消费组监控页面右上角,选择告警 > 创建新版告警
    2. 告警规则面板,设置告警规则,然后单击确定
      告警规则设置,请参见设置告警