地域管理接口
API 描述 OnsRegionList 使用 OnsRegionList 获取消息队列 RocketMQ 版(目前开放服务的地域(Region)信息列表。 实例管理接口
API 描述 OnsInstanceBaseInfo 使用 OnsInstanceBaseInfo 查询实例基本信息和收发消息的接入点。 OnsInstanceCreate 使用 OnsInstanceCreate 创建实例。 OnsInstanceDelete 使用 OnsInstanceDelete 删除实例。 OnsInstanceInServiceList 使用 OnsInstanceInServiceList 查询当前用户账号下某地域所有实例的信息。 OnsInstanceUpdate 使用 OnsInstanceUpdate 更新实例名称和描述。 Topic 管理接口
API 描述 OnsTopicCreate 使用 OnsTopicCreate 创建 Topic。 OnsTopicDelete 使用 OnsTopicDelete 删除您账号下指定的 Topic。 OnsTopicList 使用 OnsTopicList 查询账号下所有 Topic 的信息列表。 OnsTopicStatus 使用 OnsTopicStatus 查询当前 Topic 下的消息总量以及 Topic 的最后更新时间。 OnsTopicUpdate 使用 OnsTopicUpdate 配置 Topic 的读写模式。 OnsTopicSubDetail 一般使用 OnsTopicSubDetail 查看有哪些在线订阅组订阅了这个 Topic。 Group 管理接口
API 描述 OnsGroupCreate 使用 OnsGroupCreate 创建客户端 Group ID。 OnsGroupDelete 使用 OnsGroupDelete 删除之前使用 OnsGroupCreate 接口创建的 Group。 OnsGroupList 使用 OnsGroupList 展示您的 Group ID 资源的列表,并不用于具体的信息查询。 OnsGroupSubDetail 使用 OnsGroupSubDetail 查看 Group 订阅了哪些 Topic,如果 Group ID 对应的消费者实例不在线则查不到数据。 OnsGroupConsumerUpdate 使用 OnsGroupConsumerUpdate 配置指定 Group ID 对应的消费集群的消息读取权限。 消费管理接口
API 描述 OnsConsumerAccumulate 使用 OnsConsumerAccumulate 查询指定 Group ID 的消息消费堆积情况,包括当前消息堆积数量和消费延迟时间等。 OnsConsumerStatus 使用 OnsConsumerStatus 查询指定 Group ID 的详细状态数据,包含订阅关系检查、消费 TPS 统计、负载均衡状态、消费端连接等。 OnsConsumerGetConnection 使用 OnsConsumerGetConnection 查询指定 Group ID 下当前客户端的连接情况。 OnsConsumerResetOffset 使用 OnsConsumerResetOffset 重置指定的 Group ID 的消费位点到指定时间戳。 OnsConsumerTimeSpan 使用 OnsConsumerTimeSpan 查询当前 Group ID 订阅的 Topic 的最新消息时间戳以及消费的最新时间。 消息查询接口
API 描述 OnsMessageTrace 使用 OnsMessageTrace 根据 Message ID 来判断目标消息是否曾被消费过。 OnsMessageGetByMsgId 使用 OnsMessageGetByMsgId 通过传入 Message ID 查询指定消息的信息以及判断该指定的消息是否曾被消费过。查询到的信息包括发送时间、存储服务器和消息的 Key 和 Tag 等属性。 OnsMessageGetByKey 使用 OnsMessageGetByKey 通过传入 Topic 名称和 Message Key 进行模糊查询,得到符合条件的消息的信息列表。 OnsMessagePageQueryByTopic 使用 OnsMessagePageQueryByTopic 通过传入 Topic 名称和时间段,分页查询指定时间段内该 Topic 内存在的所有消息。 发布订阅统计接口
API 描述 OnsTrendTopicInputTps 使用 OnsTrendTopicInputTps 查询一段时间内指定的 Topic 的消息写入报表数据。 OnsTrendGroupOutputTps 使用 OnsTrendGroupOutputTps 查询指定的 Group ID 在一段时间内消费消息的统计信息。 消息轨迹接口
API 描述 OnsTraceGetResult 使用 OnsTraceGetResult 通过传入轨迹查询任务的 ID 获取之前的轨迹查询结果。 OnsTraceQueryByMsgId 使用 OnsTraceQueryByMsgId 通过传入 Topic 名称和 Message ID 创建轨迹查询任务,得到该查询任务的 ID。 OnsTraceQueryByMsgKey 使用 OnsTraceQueryByMsgKey 通过传入 Topic 名称和 Message Key 创建轨迹查询任务,得到该查询任务的 ID。 死信队列接口
API 描述 OnsDLQMessageGetById 使用 OnsDLQMessageGetById 通过传入 Message ID 查询指定的死信消息。查询到的信息包括死信消息的存储时间、消息体、Key 和 Tag 等属性。 OnsDLQMessagePageQueryByGroupId 使用 OnsDLQMessagePageQueryByGroupId 通过传入 Group ID 和时间段,分页查询指定时间段内该 Group ID 内存在的所有死信消息。 OnsDLQMessageResendById 使用 OnsDLQMessageResendById 通过传入 Message ID 重发指定的死信消息,使该消息能够被 Consumer 再次消费。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/