Benchmarks de Valkey Streams
Streams é o cenário principal para tarefas persistentes do Valkey Queue. Esta campanha mede o ciclo completo de uma mensagem:
XADD -> XREADGROUP -> XACKO que será medido
O benchmark usa um publicador, um consumidor e um consumer group. A capacidade é aprovada somente quando o ciclo completo tem zero perdas, zero erros, zero pendências e P99 de latência menor ou igual a 100 ms.
Serão executados dois cenários por plano e payload:
- ACK individual: uma mensagem por leitura e um
XACKpor mensagem; - ACK em lote: até 100 mensagens por leitura e um
XACKpara o lote.
A latência começa antes do XADD e termina depois da resposta bem-sucedida do
XACK. O relatório inclui P50, P90, P95 e P99, usando o pior valor de três
execuções de 30 segundos.
Retenção e armazenamento
Cada candidato usa um stream e consumer group exclusivos. As entradas são
criadas com XADD MAXLEN ~ para limitar a retenção, e o stream é removido após
a execução. O teste mede throughput, latência, XLEN, memória estimada e
pendências; ele não tenta preencher todo o armazenamento persistente do plano.
O armazenamento persistente suporta retenção e recuperação, mas não significa
que cada XADD aguarde fsync síncrono. A durabilidade de cada mensagem em uma
falha depende da forma como a persistência e as réplicas do plano são gerenciadas.
Status
Ainda não há resultados publicados para Streams. Os números por plano serão adicionados somente após a campanha confirmatória completa; nenhuma capacidade de Streams é inferida a partir dos resultados de Pub/Sub.
Limitações
Este cenário mede um produtor e um consumidor. Ele não representa escala com
quatro workers, recuperação com XAUTOCLAIM, dead-letter streams, retenção de
longo prazo ou preenchimento da cota de armazenamento.
Próximos passos
Última atualização em
Benchmarks do Valkey Queue
Resultados de throughput e latência do Valkey Queue nos planos queue-free a queue-enterprise, com Pub/Sub, mensagens JSON e p99 abaixo de 100 ms.
Analytics na Zenifra
Conheça o ClickHouse gerenciado para eventos e consultas analíticas, e siga o caminho de criação, planos, conexão, consultas e operação.