本产品(
云消息队列 RocketMQ 4.0 版/2019-02-14
)的OpenAPI采用RPC签名风格,签名细节参见签名机制说明。我们已经为开发者封装了常见编程语言的SDK,开发者可通过下载SDK直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求,可通过签名机制进行自签名对接。由于自签名细节非常复杂,需花费 5个工作日左右。因此建议加入我们的服务钉钉群(78410016550),在专家指导下进行签名对接。在使用API前,您需要准备好身份账号及访问密钥(AccessKey),才能有效通过客户端工具(SDK、CLI等)访问API。细节请参见获取AccessKey。
服务
API | 标题 | API概述 |
---|---|---|
OpenOnsService | 开通服务 | 调用OpenOnsService开通云消息队列 RocketMQ 版服务。 |
消息
API | 标题 | API概述 |
---|---|---|
OnsMessageTrace | 查看消息消费结果 | 调用OnsMessageTrace根据Message ID来判断目标消息是否曾被消费过。 |
OnsMessageGetByMsgId | 通过MsgId查询消息 | 通过传入 Message ID 查询指定消息的信息以及判断该指定的消息是否曾被消费过。 |
OnsMessageGetByKey | 根据Message Key查询消息 | 根据 Topic 和 Message Key 模糊查询消息信息列表。 |
OnsMessagePageQueryByTopic | 查询Topic内所有消息 | 分页查询指定时间段内指定Topic内存在的所有消息。 |
OnsMessageDetail | 查询消息详细信息 | 调用OnsMessageDetail查询某条消息的具体信息。 |
地域
API | 标题 | API概述 |
---|---|---|
OnsRegionList | 获取地域信息列表 | 调用OnsRegionList获取云消息队列 RocketMQ 版目前开放服务的地域(Region)信息列表。 |
实例
API | 标题 | API概述 |
---|---|---|
OnsInstanceCreate | 创建实例 | 调用OnsInstanceCreate接口创建实例。 |
OnsInstanceBaseInfo | 查询实例基本信息和收发消息的接入点 | 调用OnsInstanceBaseInfo接口查询实例基本信息和收发消息的接入点。 |
OnsInstanceUpdate | 更新实例名称和描述 | 调用OnsInstanceUpdate接口更新实例名称和描述。 |
OnsInstanceInServiceList | 查询指定地域下实例列表 | 查询当前账号在指定地域(Region)下所有的云消息队列 RocketMQ 版4.x实例信息。 |
OnsInstanceDelete | 删除实例 | 调用OnsInstanceDelete接口删除云消息队列 RocketMQ 版实例。 |
Topic
API | 标题 | API概述 |
---|---|---|
OnsTopicCreate | 创建Topic | 调用OnsTopicCreate接口创建Topic。 |
OnsTopicStatus | 查询Topic状态 | 查询当前Topic下的消息总量以及Topic的状态。 |
OnsTopicList | 获取Topic列表信息 | 查询账号下所有Topic的信息列表。 |
OnsTopicSubDetail | 查看Topic的订阅信息 | 查看有哪些在线订阅组订阅了这个Topic。 |
OnsTopicDelete | 删除Topic | 调用OnsTopicDelete接口删除指定的Topic。 |
Group
API | 标题 | API概述 |
---|---|---|
OnsGroupCreate | 创建客户端Group ID | 调用OnsGroupCreate创建客户端Group ID。 |
OnsGroupConsumerUpdate | 配置消费集群的消息读取权限 | 配置指定Group ID对应的消费集群的消息读取权限。本接口一般用于禁止特定Group ID读取消息的场景。 |
OnsGroupList | 获取Group ID列表信息 | 查询指定实例下所有的Group ID信息。 |
OnsGroupSubDetail | 查看Group ID的订阅信息 | 查看Group订阅了哪些Topic,如果Group ID对应的消费者实例不在线则查不到数据。 |
OnsGroupDelete | 删除Group | 调用OnsGroupDelete删除Group。 |
标签
API | 标题 | API概述 |
---|---|---|
ListTagResources | 查询资源绑定的标签列表 | 调用ListTagResources查询资源绑定的标签列表。 |
TagResources | 为资源绑定标签 | 调用TagResources为资源绑定标签。 |
UntagResources | 为资源解绑并删除标签 | 调用UntagResources为资源解绑并删除标签。 |
消费
API | 标题 | API概述 |
---|---|---|
OnsConsumerStatus | 查询Group ID消费状态 | 查询指定Group ID详细状态数据:订阅关系检查、消费TPS统计、负载均衡状态、消费端连接。 |
OnsConsumerAccumulate | 查询消息消费堆积情况 | 查询指定Group ID的消息消费堆积情况,包括当前消息堆积数量和消费延迟时间等。 |
OnsConsumerGetConnection | 查询Group ID客户端连接情况 | 查询指定 Group ID 下当前客户端的连接情况。 |
OnsConsumerResetOffset | 重置Group ID消费位点 | 重置指定的Group ID的消费位点到指定时间戳。 |
OnsConsumerTimeSpan | 查询Topic可重置时间范围 | 查询Topic可重置的时间范围,即该Topic中储存的最早的和最晚的消息的生产时间。 |
OnsMessagePush | 向指定的消费者推送消息 | 调用OnsMessagePush向指定的消费者推送消息。 |
消息收发数据统计
API | 标题 | API概述 |
---|---|---|
OnsTrendTopicInputTps | 统计消息生产数据 | 查询一段时间内指定的Topic的消息写入报表数据。 |
OnsTrendGroupOutputTps | 统计消息消费数据 | 查询指定的Group ID在一段时间内消费消息的统计信息。 |
轨迹
API | 标题 | API概述 |
---|---|---|
OnsTraceQueryByMsgId | 根据MsgId创建轨迹查询任务 | 通过传入Topic名称和Message ID创建轨迹查询任务,得到该查询任务的ID。您需要再调用OnsTraceGetResult接口,传入返回的查询任务ID,获取消息轨迹的详细结果。 |
OnsTraceQueryByMsgKey | 根据Message Key创建轨迹查询任务 | 通过传入Topic名称和Message Key创建轨迹查询任务,得到该查询任务的ID。您需要再调用OnsTraceGetResult接口,传入返回的查询任务ID,获取消息轨迹的详细结果。 |
OnsTraceGetResult | 获取轨迹查询结果 | 通过传入轨迹查询任务的ID获取之前的轨迹查询结果。 |
死信
API | 标题 | API概述 |
---|---|---|
OnsDLQMessagePageQueryByGroupId | 查询Group ID内所有死信消息 | 通过传入Group ID和时间段,分页查询指定时间段内该Group ID内存在的所有死信消息。 |
OnsDLQMessageGetById | 根据Message ID查询死信消息 | 通过传入Message ID查询指定的死信消息。包括存储时间、消息体、Key和Tag。 |
OnsDLQMessageResendById | 重发指定的死信消息 | 重发指定Message ID的死信消息,使该消息能够被Consumer再次消费。 |