API概览

更新时间:
复制 MD 格式

API标准及多语言预置SDK

本产品(Ons/2019-02-14)的OpenAPI采用RPC签名风格。我们已经为开发者封装了常见编程语言的SDK,开发者可通过下载SDK直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求,可通过签名机制进行自签名对接。由于自签名细节非常复杂,需花费 5个工作日左右。因此建议加入我们的服务钉钉群(147535001692),在专家指导下进行签名对接。

在使用API前,您需要准备好身份账号及访问密钥(AccessKey),才能有效通过客户端工具(SDK、CLI等)访问API。细节请参见获取AccessKey

自定义签名场景

若您的业务场景有特殊需求,需通过自签名方式对接 API,建议优先咨询我们的技术支持团队(服务钉钉群:147535001692),获取专业指导以确保高效接入。

账号与安全准备

阿里云账号具备对所有资源的完全管理权限。一旦 AccessKey 泄露,所有相关资源都将面临未经授权访问的风险。为确保安全,建议创建一个仅具备 API 访问权限的RAM用户并配置其 AccessKey,同时基于最小权限原则 (PoLP) 配置 RAM 策略。仅在明确需要阿里云账号权限的特定场景下,才使用阿里云账号。

服务

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查询指定的死信消息。包括存储时间、消息体、KeyTag。
OnsDLQMessageResendById 重发指定的死信消息 重发指定Message ID的死信消息,使该消息能够被Consumer再次消费。

其他

API

标题

API概述