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

前提条件

已开通服务日志的重要日志,开通步骤请参见开通、修改和关闭服务日志

背景信息

消费组包含多个消费者,每个消费者消费Logstore中的一部分Shard。

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

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

操作步骤

  1. 登录日志服务控制台,单击Project名称。
    当前Project为存储服务日志的Project。
  2. 在左侧导航栏单击仪表盘
  3. 在仪表盘列表中单击消费组监控仪表盘。
    在仪表盘中查看消费状态,包括Shard的消费数据、消费的落后时间、消费组列表等。
    图 2. 消费组监控
    消费组监控
  4. 可选: 单击右上角告警列表 > 新建进入告警创建页面。
  5. 可选: 设置告警规则。
    选择图表名称为消费组延迟,触发条件为当延迟大于100秒时告警。 关于告警设置的详细操作请参见设置告警
    图 3. 设置告警规则
    设置报警规则