赛尔校园公共服务平台 Logo
平台使用
阿里云
百度云
移动云
智算服务
教育生态
登录 →
赛尔校园公共服务平台 Logo
平台使用 阿里云 百度云 移动云 智算服务 教育生态
登录
  1. 首页
  2. 阿里云
  3. 日志服务
  4. 操作指南
  5. 查询与分析
  6. 最佳实践
  7. 查询轻量消息队列(原MNS)日志

查询轻量消息队列(原MNS)日志

  • 最佳实践
  • 发布于 2025-04-22
  • 0 次阅读
文档编辑
文档编辑

轻量消息队列(原 MNS)日志推送到日志服务后,可进行实时查询,本文介绍实时查询的常用场景及操作步骤,您也可以通过多个关键字组合方式实现更加复杂的查询。

前提条件

  • 已采集轻量消息队列(原 MNS)日志。具体操作,请参见轻量消息队列(原 MNS)日志。

  • 已配置索引。具体操作,请参见创建索引。

背景信息

轻量消息队列(原 MNS)日志包括队列消息操作日志和主题消息操作日志,日志内容包含消息生命周期的所有信息,例如时间、客户端、操作等。您可以通过实时查询、实时计算和离线计算三种方式对日志进行分析计算。

  • 实时查询:在日志服务控制台上进行实时查询,例如:查询消息轨迹、写入量、删除量等。

  • 实时计算:使用Spark、Storm、StreamCompute、Consumer Library等方式对轻量消息队列(原 MNS)日志进行实时计算。例如:计算某个队列中,Top 10消息的产生者和消费者;计算生产和消费的速度,确认是否均衡;计算某些消费者的处理延时,确认是否存在瓶颈等。

  • 离线计算:使用MaxCompute、E-MapReduce、Hive进行长时间跨度的计算,例如:计算最近一周内消息从发布到被消费的平均延迟。

查询队列消息的消息轨迹

  1. 登录日志服务控制台。

  2. 在Project列表区域,单击目标Project。

    image

  3. 在控制台左侧,单击日志存储,在日志库列表中单击目标Logstore。

    image

  4. 输入查询语句,然后单击最近15分钟,设置查询的时间范围。

    本案例要查询队列消息的消息轨迹,即输入队列名称和消息ID,格式为$QueueName and $MessageId,例如log and EED287A265726135146E6A9CADC880FA。

    查询结果如下所示,记录了某条消息从发送到接收的过程。查看队列消息的消息轨迹

查询队列消息发送量

  1. 登录日志服务控制台。

  2. 在Project列表区域,单击目标Project。

    image

  3. 在控制台左侧,单击日志存储,在日志库列表中单击目标Logstore。

    image

  4. 输入查询语句,然后单击最近15分钟,设置查询的时间范围。

    本案例要查询队列消息发送量,即输入队列名称和发送操作,查询语句格式为$QueueName and (SendMessage or BatchSendMessage),例如log and (SendMessage or BatchSendMessage)。

    查询结果如下所示,当前查询时段内,生产者向log队列发送了3条队列消息。查看队列消息写入量

查询队列消息消费量

  1. 登录日志服务控制台。

  2. 在Project列表区域,单击目标Project。

    image

  3. 在控制台左侧,单击日志存储,在日志库列表中单击目标Logstore。

    image

  4. 输入查询语句,然后单击最近15分钟,设置查询的时间范围。

    本案例要查询队列消息消费量,即输入队列名称和消费操作,查询语句格式为$QueueName and (ReceiveMessage or BatchReceiveMessage),例如log and (ReceiveMessage or BatchReceiveMessage)。

    查询结果如下所示,当前查询时段内,log队列中有12条消息被消费。查看队列消息消费量

查询队列消息删除量

  1. 登录日志服务控制台。

  2. 在Project列表区域,单击目标Project。

    image

  3. 在控制台左侧,单击日志存储,在日志库列表中单击目标Logstore。

    image

  4. 输入查询语句,然后单击最近15分钟,设置查询的时间范围。

    本案例要查询队列消息删除量,即输入队列名称和删除操作,查询语句格式为$QueueName and (DeleteMessage or BatchDeleteMessage),例如log and (DeleteMessage or BatchDeleteMessage)。

    查询结果如下所示,当前查询时段内,61条log队列消息被删除。查看队列消息删除量

查询主题消息的消息轨迹

  1. 登录日志服务控制台。

  2. 在Project列表区域,单击目标Project。

    image

  3. 在控制台左侧,单击日志存储,在日志库列表中单击目标Logstore。

    image

  4. 输入查询语句,然后单击最近15分钟,设置查询的时间范围。

    本案例要查询主题消息的消息轨迹,即输入主题名称和MessageId,查询语句格式为$TopicName and $MessageId,例如logtest and 8798453B65727FC6433E6AB4F746D4CE。

    查询结果如下图所示,记录了某条消息从发送到通知的过程。查看主题消息的消息轨迹

查询主题消息发布量

  1. 登录日志服务控制台。

  2. 在Project列表区域,单击目标Project。

    image

  3. 在控制台左侧,单击日志存储,在日志库列表中单击目标Logstore。

    image

  4. 输入查询语句,然后单击最近15分钟,设置查询的时间范围。

    本案例要查询主题消息发布量,即输入主题名称和发布操作,查询语句格式为$TopicName and PublishMessage,例如logtest and PublishMessage。

    查询结果如下图所示,当前查询时段内,生产者向logtest主题发布了3条消息。查看主题消息发布量

查询某个客户端消息处理量

  1. 登录日志服务控制台。

  2. 在Project列表区域,单击目标Project。

    image

  3. 在控制台左侧,单击日志存储,在日志库列表中单击目标Logstore。

    image

  4. 输入查询语句,然后单击最近15分钟,设置查询的时间范围。

    本案例要查询某个客户端消息处理量,即输入客户端IP地址,查询语句格式为$ClientIP,例如10.10.10.0。

    如果您要查询某个客户端的某类操作日志,可使用多个关键字组合方式,例如$ClientIP and (SendMessage or BatchSendMessage)。

    查询结果如下图所示,当前查询时段内,该客户端处理了66条消息。查看某个客户端消息处理量

相关文章

常见分析案例 2025-04-22 10:56

本文为您提供日志数据分析的一些案例。 5分钟错误率超过40%时触发报警 统计每分

提高查询分析日志速度的方法 2025-04-22 10:56

您可以使用以下方式,提高日志查询分析的速度。 增加Shard数量或开启SQL独享版

使用SQL语句查询分析日志 2025-04-22 10:56

当您需要使用SQL查询和分析日志服务中的数据时,可以通过JDBC、Python MySQLdb、MySQL命令行工具等方式连接日志服务来实现。本文主要为您介绍JDBC、Python MySQLdb、MySQL命令行工具连接日志服务的操作步骤。 使用限制

查询和分析网站日志 2025-04-22 10:56

本文以查询和分析网站日志为例,帮助您快速上手查询和分析操作。 前提条件 已采集到网站访问日志。配置Logtail采集配置的步骤,请参见采集主机文本日志。

查询和分析JSON日志 2025-04-22 10:56

本文以JSON类型的网站日志为例,介绍查询和分析的步骤,并提供SQL示例。 前提条件 为了进行后续的日志分析,您需要先采集JSON格式文本日志。

关联Logstore与MySQL数据库进行查询分析 2025-04-22 10:56

本文以游戏公司数据分析场景为例,介绍日志服务Logstore与MySQL数据库关联分析功能。 前提条件

目录
Copyright © 2025 your company All Rights Reserved. Powered by 赛尔网络.
京ICP备14022346号-15
gongan beian 京公网安备11010802041014号