ApsaraMQ for RocketMQ で Topic を作成します。Topic は、メッセージの転送とストレージのプライマリコンテナーです。同じビジネスロジックを共有するメッセージを分類するために使用されます。プロデューサー/コンシューマーモデルでは、プロデューサーは 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 |
任意 |
メッセージを送信するための最大 TPS (トランザクション/秒)。 |
1500 |
| liteTopicExpiration |
integer |
任意 |
ライト Topic の生存時間 (TTL) (分単位)。 有効値: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"
}
エラーコード
完全なリストについては、「エラーコード」をご参照ください。
変更履歴
完全なリストについては、「変更履歴」をご参照ください。