Redis Xinfo

Redis Xinfo

Redis Streams

Redis Streams podem realizar uma série de eventos gerados por vários produtores ou fontes. Geralmente, um fluxo Redis tem uma chave que determina cada fluxo exclusivamente no armazenamento de dados. Um fluxo carrega várias entradas onde cada entrada é um par de valores-chave. Redis Streams têm grupos de consumidores anexados a eles. Cada grupo de consumidores pode ter vários consumidores lendo o fluxo. A figura a seguir resume a imagem de alto nível de um riacho Redis e entidades relacionadas:

Há muitas informações sobre o riacho redis, grupos de consumidores e consumidores. A ilustração anterior resume essas informações até certo ponto. Redis permite que seus usuários consultem todos esses detalhes usando o comando Xinfo.

Informações sobre Redis Streams: Xinfo Command

O comando xinfo é um comando de alto nível de contêiner para consultar todos os detalhes relacionados ao fluxo, seus grupos de consumidores e consumidores. Este comando suporta vários subcomandos a serem chamados, conforme mostrado no seguinte:

Sintaxe:

Xinfo

Subcomando Xinfo

Existem quatro subcomandos principais disponíveis para uso com o comando xinfo. O comando mais básico é o AJUDA comando que liste todos os outros subcomando disponíveis. Além disso, descreve o objetivo de cada subcomando com sua sintaxe.

Sintaxe:

Xinfo ajuda

Saída:

Xinfo Stream

O FLUXO Subcomando exibirá os detalhes do fluxo armazenado na chave especificada.

Sintaxe:

Xinfo Stream [Full [contagem contagem]]

Este comando exibirá detalhes relacionados ao fluxo especificado, como comprimento, grupos anexados, id de última geração, primeira entrada, última entrada, etc.

Exemplo: Informações sobre informações de classificação de localização com fluxos Redis

Vamos adicionar um novo fluxo de identificação LocationRatingStream. Além disso, algumas entradas serão adicionadas, conforme mostrado no seguinte:

Xadd LocationRatingStream * estrelas 5 Comentário ótimo
Xadd LocationRatingStream * estrelas 3 Comentário bom
Xadd LocationRatingStream * estrelas 1 Comentário pior

Vamos adicionar dois grupos de consumidores ao LocationRatingStream, Como mostrado no seguinte:

XGROUP CREATE LOCALIDADERATINGSTREAM O Canadagroup $
XGROUP Crie locationRatingStream BrazilGroup $

Finalmente, vamos ler do grupo de consumidores por meio de um consumidor, Alex.

XReadGroup Group Canadagroup Alex Streams LocationRatingStream>

Isso criaria um novo consumidor, Alex, também.

Agora, podemos experimentar o Xinfo Stream Subcomando, conforme mostrado no seguinte:

Xinfo Stream LocationRatingStream

Saída:

Podemos usar o COMPLETO parâmetro para ver todas as entradas e grupos armazenados no fluxo. Além disso, isso mostraria duas novas propriedades, entradas e grupos, como mostrado no seguinte.

O CONTAR é outro parâmetro opcional que podemos especificar com o COMPLETO parâmetro. Ele limitará o número de linhas retornadas por fluxo e matrizes de entrada PEL.

Grupos Xinfo

O Grupos Xinfo Subcomando exibe todos os grupos de consumidores anexados a um fluxo armazenado em uma chave especificada. Este comando exibe vários detalhes, como o nome do grupo, número de consumidores por grupo, duração do PEL, Última entrega, lag, etc.

Sintaxe:

Grupos Xinfo

Vamos usar o fluxo criado anteriormente LocationRatingStream Para verificar as informações de seus grupos de consumidores anexados.

Xinfo Grupos LocationRatingStream

Saída:

Como esperado, o Grupos Xinfo O comando lista dois grupos de consumidores relacionados ao fluxo armazenado na chave LocationRatingStream. Além disso, ele lista o número de consumidores e a duração do PEL para ambos os grupos.

Xinfo consumidores

Cada grupo de consumidores contém um ou mais consumidores. Portanto, o Xinfo consumidores Subcomando mostra informações relacionadas a todos os consumidores em um grupo de consumidores, onde o grupo pertence a um fluxo identificado pela chave especificada. Este comando lista as seguintes informações sobre os consumidores:

  • Nome: O nome do consumidor.
  • Pendente: O número de mensagens que o consumidor não reconhece.
  • Parado: O número de milissegundos passou desde a última interação ativa do consumidor com o servidor.

Sintaxe:

Xinfo consumidores

Vamos usar o fluxo criado anteriormente LocationRatingStream e o grupo de consumidores Canadagroup Para obter os detalhes sobre seus consumidores.

Xinfo Consumidores LocalizaçãoRatingStream CanadArproup

Saída:

Como esperado, o grupo de consumidores Canadagroup tem um consumidor chamado Alex, com duas mensagens ainda a serem reconhecidas. Além disso, o consumidor não tinha interação com o servidor Redis para 4550962 milissegundos.

Conclusão

Redis Streams podem realizar uma sequência de eventos gerados por várias fontes. Além disso, cada fluxo pode ter vários grupos de consumidores e consumidores lendo dele. Há muitas informações valiosas disponíveis sobre essas entidades. Portanto, o Redis fornece um comando de contêiner Xinfo para usar com diferentes subcomandos para vários fins. O Xinfo ajuda O comando lista todos os subcomandos disponíveis, como Xinfo Stream, Grupos Xinfo, e Xinfo consumidores. Cada subcomando fornece uma grande quantidade de informações sobre um fluxo específico, seus grupos de consumidores e consumidores relacionados.