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查询指定的死信消息。包括存储时间、消息体、Key和Tag。 |
| OnsDLQMessageResendById | 重发指定的死信消息 | 重发指定Message ID的死信消息,使该消息能够被Consumer再次消费。 |
其他
|
API |
标题 |
API概述 |
该文章对您有帮助吗?