Envia uma mensagem para um consumidor específico.
Observação
Use esta operação para verificar se os consumidores de um grupo específico conseguem consumir mensagens de um tópico determinado. O sistema obtém o corpo da mensagem identificado pelo parâmetro MsgId, reencapsula esse conteúdo para gerar uma nova mensagem e a envia ao consumidor indicado. Embora o conteúdo entregue seja idêntico ao da mensagem original, trata-se de mensagens distintas, pois possuem IDs diferentes.
Limite de requisições
Cada conta Alibaba Cloud pode chamar esta operação até 10 vezes por segundo. Se o volume de requisições atingir esse limite em um segundo, as novas requisições falharão, o que pode interromper seus serviços. Para mais informações sobre os limites de requisição de cada operação, consulte Limites de requisição de API.
Autorização
Contas Alibaba Cloud têm permissão padrão para chamar esta operação. Usuários do Resource Access Management (RAM) precisam receber as permissões necessárias antes de executá-la. A tabela a seguir descreve as permissões obrigatórias para um usuário RAM chamar esta operação. Para saber como conceder permissões, consulte Políticas.
|
API |
Action |
Recurso em uma instância com namespace |
Recurso em uma instância sem namespace |
|
OnsMessagePush |
mq:QueryInstanceBaseInfo mq:SUB |
acs:mq:::{instanceId}%{topic} |
acs:mq:::{topic} |
Parâmetros de requisição
|
Parâmetro |
Tipo |
Obrigatório |
Exemplo |
Descrição |
|
Action |
String |
Sim |
OnsMessagePush |
Operação a ser executada. Defina o valor como OnsMessagePush. |
|
GroupId |
String |
Sim |
GID_test_group_id |
ID do grupo de consumidores. Para entender o conceito de grupo de consumidores, consulte Termos. |
|
ClientId |
String |
Sim |
30.5.121.**@24813#-1999745829#-1737591554#453111174894656 |
ID do consumidor. Chame a operação OnsConsumerGetConnection para consultar o ID de cada consumidor em um grupo de consumidores. |
|
MsgId |
String |
Sim |
0BC1669963053CF68F733BB70396**** |
ID da mensagem. |
|
Topic |
String |
Sim |
test-mq_topic |
Tópico para o qual a mensagem será enviada. |
|
InstanceId |
String |
Sim |
MQ_INST_111111111111_DOxxxxxx |
ID da instância do Message Queue for Apache RocketMQ à qual o grupo de consumidores especificado pertence. |
Parâmetros de resposta
|
Parâmetro |
Tipo |
Exemplo |
Descrição |
|
RequestId |
String |
B8EDC90D-F726-4B9E-8BEF-F0DD25EC**** |
ID da requisição. O sistema gera um ID exclusivo para cada requisição. Use esse identificador para solucionar problemas. |
Exemplos
Exemplos de requisições
http(s)://ons.cn-zhangjiakou.aliyuncs.com/?Action=OnsMessagePush
&GroupId=GID_test_group_id
&ClientId=30.5.121.**@24813#-1999745829#-1737591554#453111174894656
&MsgId=0BC1669963053CF68F733BB70396****
&Topic=test-mq_topic
&InstanceId=MQ_INST_111111111111_DOxxxxxx
&<Common request parameters>Exemplos de respostas de sucesso
Formato XML
HTTP/1.1 200 OK
Content-Type:application/xml
<OnsMessagePushResponse>
<RequestId>B8EDC90D-F726-4B9E-8BEF-F0DD25EC****</RequestId>
</OnsMessagePushResponse>Formato JSON
HTTP/1.1 200 OK
Content-Type:application/json
{
"RequestId" : "B8EDC90D-F726-4B9E-8BEF-F0DD25EC****"
}Códigos de erro
Para obter uma lista de códigos de erro, visite a Central de Erros de API.