Pular para o conteúdo principal

Log Aggregation Pipeline Simulator

Follow production logs from applications through collection, parsing, filtering, buffering, sharded indexing, and search. Trigger traffic spikes, parser failures, and slow indexing to see where backpressure builds and logs can be lost.

Categoria: Observability

O que você vai aprender

  • Como logs de aplicação se movem por coletores, processadores, buffers, índices e busca
  • Por que parsing e filtragem acontecem antes da indexação durável
  • Como buffers limitados absorvem rajadas curtas mas eventualmente transbordam
  • Como picos de tráfego, incompatibilidades de parser e indexação lenta criam sinais de falha diferentes
  • Como o roteamento de documentos distribui logs indexados entre shards de busca
  • Por que eventos filtrados, rejeitados e descartados nunca aparecem nos resultados de busca

Tópicos abordados: logs, observability, elasticsearch, fluent-bit, parsing, backpressure, monitoring, sre, educational, interactive

// simulador

Log Aggregation Pipeline Simulator

Follow production logs from applications through collection, parsing, filtering, buffering, sharded indexing, and search. Trigger traffic spikes, parser failures, and slow indexing to see where backpressure builds and logs can be lost.

Pipeline de logs de produção

Pipeline está saudável

A capacidade está acompanhando e os logs aceitos estão progredindo até a busca.

Ciclo 1 · próximo estágio

Selecione um estágio para inspecionar o que ele faz.

1

Próximo: Apps e hosts

Pronto. Gere um lote para iniciar o pipeline.

Gerados

0

toda entrada

Em buffer

0

aguardando indexação

Indexados

0

pesquisáveis

Rejeitados

0

incompatibilidade de parser

Descartados

0

perdidos por transbordamento

Inspetor de estágio

Apps e hosts

Aplicações, containers e hosts emitem eventos de log brutos.

Sinal para o operador: Observe a taxa de entrada. Um aumento repentino costuma ser o primeiro sinal de um incidente.

Mudanças exigem uma nova execução.

Reduz o volume de armazenamento antes da indexação.

Três shards primários

Eventos são distribuídos por id de documento. Barras equilibradas significam trabalho de indexação equilibrado.

0 docs
shard-00 logs
shard-10 logs
shard-20 logs
Isso modela o roteamento de shards primários, não um cluster Elasticsearch completo. Réplicas, intervalos de refresh, e merges de segmento são omitidos de propósito para manter a primeira lição focada em fluxo e backpressure.

Como um pipeline de logs se mantém confiável

1. Colete perto da fonte

Agentes leves seguem (tail) arquivos ou a saída de containers e encaminham eventos. Filas locais evitam que um problema breve de rede perca logs imediatamente.

2. Estruture antes do armazenamento

Parsers extraem campos pesquisáveis, enriquecimento adiciona contexto, e filtros removem ruído conhecido. Contadores de rejeição expõem mudanças de formato antes que virem pontos cegos.

3. Faça buffer da diferença de ritmo

Coleta e indexação raramente rodam exatamente no mesmo ritmo. Um buffer durável e limitado absorve rajadas enquanto alertas de fila dão tempo aos operadores para restaurar capacidade.

O que alertar em produção

Monitore a taxa de entrada, idade e profundidade da fila, taxa de rejeição do parser, utilização do buffer, eventos descartados, latência de indexação, e balanço de shards juntos. Uma única consulta de busca saudável não prova que o pipeline está completo: logs faltando podem ter sido rejeitados bem antes de chegar ao índice.

Experimente também

Sponsored
Carbon Ads
$ cd /games
// compartilhar