Monitoramento e alertas de Atlas Stream Processing
O Atlas Stream Processing fornece monitoramento e alertas para que os usuários possam aproveitar as percepções de desempenho e status para refinar seus fluxos de trabalho.
Métodos de monitoramento do processador de fluxo
O Atlas Stream Processing fornece os seguintes métodos para geração de relatórios sob demanda sobre seus processadores de fluxo:
O método sp.processor.sample() permite que você veja uma pequena amostra da saída de documentos por um processador de fluxo em execução no momento de sua escolha. Os usuários podem comparar os resultados amostrados com os resultados esperados para diagnosticar erros no design do pipeline de agregação.
O método sp.processor.stats() retorna uma variedade de estatísticas de tempo de execução sobre um processador de stream de sua escolha, incluindo, mas não se limitando a:
Número de mensagens ingeridas
Número de mensagens processadas com êxito
Número de mensagens enviadas para sua Fila de mensagens não entregues (DLQ)
Tamanho na memória do estado do pipeline
Definição de pipeline
Alertas do processador de fluxo
O Atlas Stream Processing aciona alertas quando os processadores mudam de estado ou quando um processador atinge vários limites de ingestão ou saída. Para obter uma lista de alertas disponíveis do Atlas Stream Processing, consulte Alertas do Atlas Stream Processing. Para saber mais sobre a configuração de alertas, consulte Definir configurações de alerta.
Você pode direcionar os alertas do Atlas Stream Processing das seguintes maneiras:
Todos os processadores de fluxo dentro de um projeto
Todos os processadores de fluxo dentro de uma instância de processamento de fluxo que correspondam ao predicado configurado
Todos os processadores de fluxo cujos nomes correspondem ao predicado configurado
Para destinos que não sejam todos os processadores de fluxo, é possível configurar vários destinos para o mesmo alerta.