更新时间:2022-12-05 GMT+08:00

创建Topic

功能介绍

创建Topic。

URI

POST /v2/{project_id}/mqs/instances/{instance_id}/topics

表1 路径参数

参数

是否必选

参数类型

描述

project_id

String

租户的项目ID。

instance_id

String

实例ID。

请求参数

表2 请求Body参数

参数

是否必选

参数类型

描述

name

String

topic名称,以字母开头,仅能包含数字,字母,下划线(_),中划线(-),长度3-200字符。

app_id

String

集成应用key。

partition

Integer

topic分区数,设置消费的并发数。

取值范围:1-50。

默认值:3。

replication

Integer

副本数,配置数据的可靠性。

取值范围:1-3。

默认值:3。

说明:

体验版实例的副本数只能为1。

access_policy

String

权限类型。

  • all:发布+订阅

  • pub:发布

  • sub:订阅

sync_message_flush

Boolean

是否使用同步落盘。默认值为false。同步落盘会导致性能降低。

sync_replication

Boolean

是否开启同步复制,开启后,客户端生产消息时相应的也要设置acks=-1,否则不生效,默认关闭。

retention_time

Integer

消息老化时间。默认值为72。取值范围1~720,单位小时。

tag

String

权限类型对应的标签。

当权限类型是all时,发布和订阅的标签用符号“&”隔开。

当有多个标签时,标签用符号“||”隔开。

description

String

描述。长度0-1000字符。

sensitive_word

String

敏感字段。

当有多个敏感字段时,敏感字段用符号“||”隔开。

响应参数

状态码: 200

表3 响应Body参数

参数

参数类型

描述

name

String

topic名称。

请求示例

POST https://{endpoint}/v2/{project_id}/mqs/instances/{instance_id}/topics

{
  "name" : "topic-test-2",
  "app_id" : "c5abd910-02b1-4bc4-b587-c3fe4c49dab9",
  "partition" : 3,
  "access_policy" : "all",
  "replication" : 3,
  "retention_time" : 72,
  "sync_replication" : false,
  "sync_message_flush" : false,
  "tag" : "11 || 22 || aa || bb&11 || 22 || aa || bb",
  "description" : "test",
  "sensitive_word" : "sss || ddd"
}

响应示例

状态码: 200

OK

{
  "name" : "topic-mqs-test"
}

状态码

状态码

描述

200

OK

400

Bad Request

403

Forbidden

错误码

请参见错误码