跳转至

火山引擎消息队列 RocketMQ

采集火山引擎消息队列 RocketMQ 指标数据

配置

安装 Func

推荐开通 观测云集成 - 扩展 - 托管版 Func: 一切前置条件都自动安装好, 请继续脚本安装

如果自行部署 Func 参考 自行部署 Func

安装脚本

提示:请提前准备好符合要求的火山引擎 AK(简单起见,可直接授予全局只读权限ReadOnlyAccess

同步消息队列 RocketMQ 资源的监控数据,我们安装对应的采集脚本:「观测云集成(火山引擎-RocketMQ 采集)」(ID:guance_volcengine_rocketmq)

点击【安装】后,输入相应的参数:火山引擎 AK、火山引擎账户名、地域Regions。

点击【部署启动脚本】,系统会自动创建 Startup 脚本集,并自动配置相应的启动脚本。

开启后可以在「管理 / 自动触发配置」里看到对应的自动触发配置。点击【执行】,即可立即执行一次,无需等待定期时间。稍等片刻,可以查看执行任务记录以及对应日志。

验证

  1. 在「管理 / 自动触发配置」确认对应的任务是否已存在对应的自动触发配置,同时可以查看对应任务记录及日志检查是否有异常
  2. 在观测云,「基础设施 - 资源目录」中查看是否存在资产信息
  3. 在观测云,「指标」查看是否有对应监控数据

指标

配置火山引擎消息队列 RocketMQ 监控指标,可以通过配置的方式采集更多的指标 火山引擎消息队列 RocketMQ 指标详情

火山引擎消息队列 RocketMQ 监控指标

消息队列 RocketMQ 指标位于 volcengine_VCM_RocketMQ 指标集下,这里介绍相关指标说明

MetricName Subnamespace 指标名称 MetricUnit Dimension
CapUtil Instance 实例磁盘使用率 Percent ResourceID
ConsumerConnectionCount Instance 消费者连接数 Count ResourceID
CpuUtil Instance CPU使用率 Percent ResourceID
InstanceBigMsgCount Instance 大消息数量 Count ResourceID
InstanceConnectionRate Instance 实例连接数使用率 Percent ResourceID
InstanceSendFailedMsgNum Instance 写入失败消息数量 Count ResourceID
InstanceTPSUsedRatio Instance 实例TPS使用率 Percent ResourceID
InstanceTopicNum Instance Topic数量 Count ResourceID
MaxDiskCapUtil BalanceStatus 最大磁盘使用率 Percent ResourceID
MemUtil BalanceStatus 内存使用率 Percent ResourceID
MinDiskCapUtil BalanceStatus 最小磁盘使用率 Percent ResourceID
MsgProductionRate Instance 消息生产速率 Count/Second ResourceID
MsgPutLatencyP99 Instance 消息生产P99耗时 Millisecond ResourceID
MsgPutTime Instance 消息生产平均耗时 Millisecond ResourceID
NodeMaxConnectionRate BalanceStatus 节点最大连接数使用率 Percent ResourceID
NodeMaxConsumeRate BalanceStatus 节点最大消费速率 Count/Second ResourceID
NodeMaxProduceRate BalanceStatus 节点最大生产速率 Count/Second ResourceID
NodeMaxQueueCount BalanceStatus 节点最大队列数 Count ResourceID
ProduceConnectionCount BalanceStatus 生产者连接数 Count ResourceID
QueueCountSkew BalanceStatus 队列数倾斜率 Percent ResourceID
TopicProductionSizeRate Topic 消息生产流量速率 Bytes/Second(IEC) ResourceID

对象

采集到的火山引擎 RocketMQ 对象数据结构, 可以从「基础设施 - 资源目录」里看到对象数据

  {
    "measurement": "volcengine_rocketmq",
    "tags": {
    "RegionId"        : "cn-beijing",
    "ComputeSpec"     : "rocketmq.n1.x2.micro",
    "ChargeDetail.ChargeType" : "PostPaid",
    "InstanceName"    : "test",
    "InstanceStatus"  : "Running",
    "SubnetId"        : "subnet-13fpvlahzboxsxxxxxxxxxx",
    "Version"         : "x.x.x",
    "StorageType"     : "300",
    "VpcId"           : "vpc-13fpvlahzboxsxxxxxxxxxx",
    "ZoneId"          : "cn-beijing-a",
    "EipId"           : "eip-2ze1j9xxxxxxxxxxxxxxxx",
    "ProjectName"     : "default",
    },
    "fileds": {
      "InstanceDescription": "cn-beijing-a",
      "AvailableQueueNumber": "333",
      "CreateTime": "2025-04-22T04:01:52Z",
      "FileReservedTime": "72",
      "StorageSpace": "300",
      "UsedGroupNumber": "0",
      "UsedTopicNumber": "0",
      "UsedStorageSpace": "1",
      "Tags": "[]"
    }
  }

注意:tagsfields中的字段可能会随后续更新有所变动

文档评价

文档内容是否对您有帮助? ×