Como consultar o pico de TPS de uma instância - ApsaraMQ for RabbitMQ: Central de Documentação do Alibaba Cloud

Você pode consultar o pico de TPS (Transações Por Segundo) de uma instância do ApsaraMQ for RabbitMQ para monitorar o tráfego e evitar a limitação de taxa.

Informações de contexto

Se o pico de TPS do seu tráfego real exceder o limite de TPS da sua instância, a instância do ApsaraMQ for RabbitMQ sofrerá limitação de taxa.

Para evitar que a limitação de taxa interrompa sua operação, monitore o pico de TPS da instância como uma métrica essencial de O&M. Acompanhar as tendências do pico de TPS ajuda a receber alertas antecipados antes de exceder as especificações da instância e a determinar se o tipo de instância atual atende às necessidades da sua operação.

Métodos de consulta

O ApsaraMQ for RabbitMQ oferece os seguintes métodos para consultar o pico de TPS da instância.

Método de consulta	Descrição	Granularidade de tempo	Nível de recurso
(Recomendado) Consultar o pico de TPS da instância e configurar alertas usando o Cloud Monitor	Vantagens: Os resultados da consulta cobrem até 14 dias de alterações no pico de TPS, o que ajuda a identificar anomalias rapidamente. Permite a configuração de alertas usando o pico de TPS da instância como métrica de monitoramento. Uso gratuito.	Pico de TPS no nível de minuto O valor representa o TPS máximo por segundo dentro de uma janela de 1 minuto.	Pico de TPS no nível da instância
(Recomendado) Consultar o pico de TPS da instância na página de detalhes da instância	Vantagens: Suporta consultas de pico de TPS no nível de segundo, ajudando a identificar anomalias com precisão. Permite visualizar o pico de TPS de operações de API específicas. Uso gratuito. Desvantagem: A interface exibe apenas os dados dos últimos 10 minutos, para evitar a exibição de uma quantidade excessiva de informações.	Pico de TPS no nível de segundo	Pico de TPS no nível da instância Pico de TPS de uma operação de API específica dentro da instância
Consultar o pico de TPS da instância usando a consulta de logs	Vantagem: Suporta instruções analíticas do SLS e é ideal para cenários complexos de solução de problemas. Desvantagens: Operação mais complexa e menos intuitiva em comparação com os dois primeiros métodos. O Simple Log Service possui cobrança separada. Para mais informações sobre faturamento, consulte Itens de faturamento do Simple Log Service.	Pico de TPS no nível de segundo	Pico de TPS no nível da instância

Consultar o pico de TPS da instância e configurar alertas usando o Cloud Monitor

Consultar o pico de TPS da instância

Acesse o console do ApsaraMQ for RabbitMQ. No painel de navegação à esquerda, clique em Instances.
Na barra de navegação superior da página Instances, selecione a região da instância que você deseja gerenciar. Em seguida, na lista de instâncias, clique no nome da instância que deseja gerenciar.
No menu lateral esquerdo, clique em Monitoring and Alerting.
Na página Monitoring and Alerting, selecione Instance na lista suspensa Group e especifique um intervalo de tempo para a consulta.

Visualize os dados de monitoramento do pico de TPS da instância no painel Instance API Request Rate Peak (Max per Minute) (count/s).

Configurar alertas para o pico de TPS da API

Acesse o console do ApsaraMQ for RabbitMQ. No painel de navegação à esquerda, clique em Instances.
Na barra de navegação superior da página Instances, selecione a região da instância que você deseja gerenciar. Em seguida, na lista de instâncias, clique no nome da instância que deseja gerenciar.
No painel de navegação à esquerda, clique em Monitoring and Alerting.
No canto superior direito da página Monitoring and Alerting, clique em Create Alert Rule.

O sistema redireciona você para o painel Create Alert Rule no Cloud Monitor.
No painel Set Rule Description, configure a regra de alerta. Na lista suspensa Monitoring Metric, selecione Instance > Instance API Request Rate Peak (Max per minute). Para mais informações, consulte Serviço de alertas.

Consultar o pico de TPS da instância na página de detalhes da instância

Acesse o console do ApsaraMQ for RabbitMQ. No painel de navegação à esquerda, clique em Instances.
Na barra de navegação superior da página Instances, selecione a região da instância que você deseja gerenciar. Em seguida, na lista de instâncias, clique no nome da instância que deseja gerenciar.
Na página Instance Details, clique na aba Peak TPS Query.

Nota
É possível consultar os dados de pico de TPS dos últimos 15 dias com granularidade de segundos. Para evitar a exibição de uma quantidade excessiva de dados, a interface mostra apenas as informações dos últimos 10 minutos.

Se não houver dados ou se os dados estiverem inconsistentes no monitoramento de TPS durante um pico, isso geralmente ocorre por diferenças na granularidade de agregação do monitoramento. Consultas em grandes intervalos de tempo (por exemplo, 24 horas) podem exibir valores médios, enquanto consultas em intervalos menores (por exemplo, 3 horas) fornecem dados mais precisos. Para investigar anomalias com precisão, reduza o intervalo de tempo da consulta para o período em torno do pico (por exemplo, selecione uma janela de tempo de 10 minutos ou menos) para obter dados precisos do pico de TPS por segundo.
- Para consultar o pico de TPS no nível da instância:
  
  Clique na aba Query by Instance, selecione um intervalo de tempo e clique em Query.
- Para consultar o pico de TPS no nível da API:
  
  Clique na aba Query by API, selecione um intervalo de tempo e clique em Query.
  
  Selecione a API de destino (por exemplo, SendMessage) na lista suspensa API. O resultado da consulta exibe o API-level TPS curve chart by second.

Consultar o pico de TPS da instância usando a consulta de logs

Para mais informações, consulte Guia de início rápido para consulta e análise.

Veja a seguir um exemplo de instrução analítica:

(Action : ConnectionOpen or Action : ChannelOpen or Action: ExchangeDeclare or Action: QueueBind or Action : QueueDeclare or Action : QueueDelete or Action : ExchangeDelete or Action : QueueUnBind or Action : ExchangeBind or Action : ExchangeUnBind or Action : BasicConsume or Action : BasicReject or Action : BasicRecover or Action : SendMessage or Action : BasicAck or Action : BasicNack or Action : BasicGet ) | select from_unixtime(cast(microtime as bigint)/1000/1000) as time, COUNT(*) as count GROUP by time ORDER by time limit 90000000

Perguntas frequentes

Por que a latência de consumo de mensagens varia significativamente em diferentes períodos (por exemplo, rápida pela manhã e lenta à tarde)?

Geralmente, isso não ocorre por atrasos de distribuição da plataforma. Em horários de pico, se a taxa de envio de mensagens exceder a capacidade de processamento dos seus consumidores, a fila acumula mensagens. Somado ao processamento lento de ACK no lado do consumidor, isso resulta em uma latência de consumo significativamente maior. O pico de TPS da instância é uma métrica no nível da instância que reflete o throughput geral de mensagens e não indica diretamente problemas de desempenho no lado do consumidor.

Para resolver o problema, considere as seguintes otimizações:

Aumente o número de consumidores para melhorar a capacidade de consumo paralelo.
Otimize a lógica de processamento de ACK para reduzir a latência de processamento por mensagem.