OnsConsumerTimeSpan - : Central de Documentação do Alibaba Cloud

Consulta o intervalo de tempo no qual é possível especificar um ponto para redefinir o offset do consumidor de um tópico específico. Esse intervalo abrange desde a publicação mais antiga até a publicação mais recente de mensagens no tópico.

Observação

Esta operação permite consultar o momento da primeira e da última publicação de mensagem em um tópico. Também é possível obter o horário do consumo mais recente de uma mensagem nesse tópico. Ao combinar esta chamada com a operação OnsConsumerAccumulate, você obtém informações completas sobre o progresso de consumo de um grupo de consumidores.

Limite de requisições

Cada conta Alibaba Cloud pode invocar esta operação até 10 vezes por segundo. Se o volume de requisições em um único segundo atingir esse limite, as novas tentativas falharão, o que pode interromper seus serviços. Para obter detalhes sobre os limites de cada operação, consulte Limites de requisição de API.

Autorização

Contas Alibaba Cloud têm acesso padrão a esta operação. Usuários do Resource Access Management (RAM) precisam receber permissões específicas antes de executá-la. A tabela a seguir descreve as permissões necessárias para usuários RAM. Para saber como conceder essas permissões, consulte Políticas.

API

Action

Recurso em instância com namespace

Recurso em instância sem namespace

OnsConsumerTimeSpan

mq:QueryInstanceBaseInfo

mq:QueryConsumerTimeSpan

acs:mq:::{instanceId}%{topic}

acs:mq:::{topic}

Parâmetros da requisição

Parâmetro	Tipo	Obrigatório	Exemplo	Descrição
Action	String	Sim	OnsConsumerTimeSpan	Operação a ser executada. Defina o valor como OnsConsumerTimeSpan.
GroupId	String	Sim	GID_test_group_id	ID do grupo de consumidores a ser consultado.
Topic	String	Sim	test-mq_topic	Tópico ao qual o grupo de consumidores está inscrito.
InstanceId	String	Sim	MQ_INST_111111111111_DOxxxxxx	ID da instância do Message Queue for Apache RocketMQ à qual o grupo de consumidores pertence.

Parâmetros de resposta

Parâmetro	Tipo	Exemplo	Descrição
RequestId	String	A07E3902-B92E-44A6-B6C5-6AA111111****	ID da requisição. O sistema gera um identificador único para cada solicitação, útil para solução de problemas.
Data	Object		Dados retornados pela operação.
MaxTimeStamp	Long	1570761026804	Momento da publicação mais antiga de mensagem no tópico.
ConsumeTimeStamp	Long	1570761026400	Horário do consumo mais recente de mensagem no tópico.
Topic	String	test-mq_topic	Nome do tópico.
MinTimeStamp	Long	1570701231122	Momento da publicação mais recente de mensagem no tópico.
InstanceId	String	MQ_INST_111111111111_DOxxxxxx	ID da instância do Message Queue for Apache RocketMQ à qual o grupo de consumidores pertence.

Exemplos

Exemplo de requisição

http(s)://ons.cn-hangzhou.aliyuncs.com/?Action=OnsConsumerTimeSpan
&GroupId=GID_test_group_id
&InstanceId=MQ_INST_111111111111_DOxxxxxx
&Topic=test-mq_topic
&<Common request parameters>

Exemplo de resposta de sucesso

Formato XML

HTTP/1.1 200 OK
Content-Type:application/xml

<OnsConsumerTimeSpanResponse>
<Data>
    <MinTimeStamp>1570701231122</MinTimeStamp>
    <ConsumeTimeStamp>1570761026400</ConsumeTimeStamp>
    <InstanceId>MQ_INST_111111111111_DOxxxxxx</InstanceId>
    <Topic>test-mq_topic</Topic>
    <MaxTimeStamp>1570761026804</MaxTimeStamp>
</Data>
<RequestId>A07E3902-B92E-44A6-B6C5-6AA111111****</RequestId>
</OnsConsumerTimeSpanResponse>

Formato JSON

HTTP/1.1 200 OK
Content-Type:application/json

{
  "Data" : {
    "MinTimeStamp" : 1570701231122,
    "ConsumeTimeStamp" : 1570761026400,
    "InstanceId" : "MQ_INST_111111111111_DOxxxxxx",
    "Topic" : "test-mq_topic",
    "MaxTimeStamp" : 1570761026804
  },
  "RequestId" : "A07E3902-B92E-44A6-B6C5-6AA111111****"
}

Códigos de erro

Para consultar a lista de códigos de erro, acesse a Central de Erros de API.