Exécute une opération spécifiée sur une tâche de migration spécifiée.
Testez maintenant
Testez cette API dans OpenAPI Explorer, sans signature manuelle. Les appels réussis génèrent automatiquement du code SDK correspondant à vos paramètres. Téléchargez-le avec une sécurité intégrée des identifiants pour une utilisation locale. Testez cette API dans OpenAPI Explorer, sans signature manuelle. Les appels réussis génèrent automatiquement du code SDK correspondant à vos paramètres. Téléchargez-le avec une sécurité intégrée des identifiants pour une utilisation locale.
Test
Autorisation RAM
|
rocketmq:ExecuteMigrationOperation |
update |
*Instance.
|
Aucune | Aucune |
Syntaxe de la requête
POST /migrations/{migrationId}/stages/{stageType}/operations/{operationId}/execute HTTP/1.1
Paramètres de chemin
|
Paramètre |
Type |
Requis |
Description |
Exemple |
| migrationId |
integer |
Oui |
L'identifiant de la migration. |
44 |
| stageType |
string |
Oui |
Le type d'étape de migration. Valeurs valides :
|
MIGRATE_MESSAGE |
| operationId |
integer |
Oui |
L'identifiant de l'opération de migration. |
2729 |
Paramètres de requête
|
Paramètre |
Type |
Requis |
Description |
Exemple |
| instanceId |
string |
Non |
L'identifiant de l'instance. |
rmq-cn-x0r37kel*** |
| body |
object |
Non |
La structure du corps de la requête. |
|
| operationParam |
object |
Non |
Le paramètre de l'opération. |
|
| paramData |
any |
Non |
Les informations sur le paramètre. Le type de paramètre est une chaîne JSON. Consultez les exemples ci-dessous. Les valeurs valides pour le champ action sont les suivantes :
Les valeurs valides pour le champ targetStage sont les suivantes :
Remarque
|
Migration vers l'avant : {"action":"MIGRATE_FORWARD","targetStage":"MIGRATE_FINISH"} Migration vers l'arrière : {"action":"MIGRATE_BACKWARD","targetStage":"MIGRATE_WAIT"} |
Éléments de réponse
|
Élément |
Type |
Description |
Exemple |
|
object |
Result |
||
| requestId |
string |
L'identifiant de la requête. |
814BCD66-2D76-5080-AAD2-E50E5BDB0995 |
| success |
boolean |
Indique si la requête a réussi. |
true |
| data |
object |
Le résultat renvoyé. |
|
| operationId |
integer |
L'identifiant de l'opération de migration. |
110 |
| migrationId |
integer |
L'identifiant de la migration. |
6 |
| stageType |
string |
Le type d'étape de migration. Valeurs valides :
|
MIGRATE_MESSAGE |
| operationType |
string |
Le type d'opération. |
MIGRATE_MESSAGE |
| operationStatus |
string |
L'état de l'opération. Valeurs valides :
|
DOING |
| operationKey |
string |
La clé primaire de l'objet d'opération. |
normal-topic-1 |
| businessStatus |
string |
L'état métier de l'opération. Valeurs valides :
|
MIGRATE_WAIT |
| operationParam |
object |
Le paramètre de l'opération. |
|
| paramData |
any |
Les informations sur le paramètre. |
{"action":"MIGRATE_FORWARD","targetStage":"MIGRATE_FINISH"} |
| operationResult |
object |
Le résultat de l'opération. |
|
| resultData |
any |
Le résultat de l'opération. |
{ "checkStatus": "WAIT_CHECK", "sourceTopicStatus": "PERM_6", "targetTopicStatus": "PERM_4", "checkResult": {}, "migrateStage": "DOUBLE_READ" } |
| createTime |
string |
L'heure de création, au format AAAA-MM-JJ HH:mm:ss. |
2022-08-01 20:05:50 |
| updateTime |
string |
L'heure de modification, au format AAAA-MM-JJ HH:mm:ss. |
2022-08-01 20:05:50 |
| code |
string |
Le code d'erreur. |
Topic.NotFound |
| message |
string |
Le message d'erreur. |
Le sujet existe déjà |
| httpStatusCode |
integer |
Le code d'état HTTP. |
200 |
| dynamicCode |
string |
Le code d'erreur dynamique. |
InstanceId |
| dynamicMessage |
string |
Le message d'erreur dynamique. |
instanceId |
Exemples
JSON format
{
"requestId": "814BCD66-2D76-5080-AAD2-E50E5BDB0995",
"success": true,
"data": {
"operationId": 110,
"migrationId": 6,
"stageType": "MIGRATE_MESSAGE",
"operationType": "MIGRATE_MESSAGE",
"operationStatus": "DOING",
"operationKey": "normal-topic-1",
"businessStatus": "MIGRATE_WAIT",
"operationParam": {
"paramData": "{\"action\":\"MIGRATE_FORWARD\",\"targetStage\":\"MIGRATE_FINISH\"}"
},
"operationResult": {
"resultData": "{\n \"checkStatus\": \"WAIT_CHECK\",\n \"sourceTopicStatus\": \"PERM_6\",\n \"targetTopicStatus\": \"PERM_4\",\n \"checkResult\": {},\n \"migrateStage\": \"DOUBLE_READ\"\n}"
},
"createTime": "2022-08-01 20:05:50",
"updateTime": "2022-08-01 20:05:50"
},
"code": "Topic.NotFound",
"message": "Le topic existe déjà",
"httpStatusCode": 200,
"dynamicCode": "InstanceId",
"dynamicMessage": "instanceId"
}
Codes d'erreur
Consultez Codes d'erreur pour la liste complète.
Notes de version
Consultez Notes de version pour la liste complète.