ApsaraMQ for RocketMQ の Topic を作成します。Topic は ApsaraMQ for RocketMQ におけるメッセージ送信およびストレージの最上位レベルのコンテナであり、同じビジネスロジックを持つメッセージを識別するために使用されます。メッセージングモデルでは、プロデューサーは Topic にメッセージを送信し、コンシューマーは指定された Topic をサブスクライブしてメッセージを消費します。
今すぐお試しください
テスト
RAM 認証
|
アクション |
アクセスレベル |
リソースタイプ |
条件キー |
依存アクション |
|
rocketmq:CreateTopic |
create |
*Topic
|
なし | なし |
リクエスト構文
POST /instances/{instanceId}/topics/{topicName} HTTP/1.1
パスパラメーター
|
パラメーター |
型 |
必須 / 任意 |
説明 |
例 |
| instanceId |
string |
必須 |
作成する Topic が属するインスタンスの ID。 |
rmq-cn-7e22ody**** |
| topicName |
string |
必須 |
作成する Topic の名前。この名前は Topic を識別するために使用され、グローバルに一意である必要があります。 命名規則:
予約文字の制限については、「パラメーターの使用制限」を参照してください。 |
topic_test。 |
リクエストパラメーター
|
パラメーター |
型 |
必須 / 任意 |
説明 |
例 |
| body |
object |
任意 |
Topic の情報。 |
|
| messageType |
string |
必須 |
作成する Topic のメッセージタイプ。 重要 Topic のタイプは、送信されるメッセージのタイプと一致している必要があります。たとえば、順序付きメッセージタイプの Topic を作成した場合、その Topic は順序付きメッセージの送受信にのみ使用でき、他のタイプのメッセージには使用できません。 列挙値:
|
NORMAL。 |
| remark |
string |
任意 |
作成する Topic の備考。 |
This is the remark for test. |
| maxSendTps |
integer |
任意 |
メッセージ送信の 1 秒あたりのトランザクション数の最大値。 |
1500 |
| liteTopicExpiration |
integer |
任意 |
軽量 Topic の有効期限時間 (分単位)。 有効な値: 30 ~ 720。 デフォルト値: -1 (Topic が無期限であることを示します)。 |
60 |
レスポンスフィールド
|
フィールド |
型 |
説明 |
例 |
|
object |
結果。 |
||
| requestId |
string |
リクエスト ID。各リクエストには一意の ID が割り当てられ、問題のトラブルシューティングに使用できます。 |
AF9A8B10-C426-530F-A0DD-96320B39**** |
| success |
boolean |
操作が成功したかどうかを示します。 |
true。 |
| data |
boolean |
返されたデータ。 |
true。 |
| code |
string |
エラーコード。 |
Topic.Existed。 |
| message |
string |
エラーメッセージ。 |
The topic already exists. |
| httpStatusCode |
integer |
HTTP 状態コード。 |
400 |
| dynamicCode |
string |
動的エラーコード。 |
TopicName。 |
| dynamicMessage |
string |
動的エラーメッセージ。 |
topicName。 |
例
成功レスポンス
JSONJSON
{
"requestId": "AF9A8B10-C426-530F-A0DD-96320B39****",
"success": true,
"data": true,
"code": "Topic.Existed",
"message": "The topic already exists.",
"httpStatusCode": 400,
"dynamicCode": "TopicName",
"dynamicMessage": "topicName"
}
エラーコード
完全なリストについては、「エラーコード」をご参照ください。
変更履歴
完全なリストについては、「変更履歴」をご参照ください。