sd-wavys
sistema distribuído de monitorização oceânica
código fonte: https://github.com/joaoesteves10/wavys
Contexto
Trabalho da UC de Sistemas Distribuídos, em duas fases: simula uma rede de boias oceânicas (WAVY) que recolhem dados de sensores, enviam-nos a um AGREGADOR que os pré-processa, e este reencaminha os dados a um SERVIDOR central que os persiste e analisa. A primeira fase usava sockets TCP ponto-a-ponto; a segunda evoluiu a comunicação entre a WAVY e o AGREGADOR para publicação/subscrição via RabbitMQ (um tópico por sensor) e introduziu dois microserviços gRPC independentes, de pré-processamento e análise estatística, mantendo o formato de mensagens e o padrão ACK/NACK da primeira fase para não quebrar compatibilidade. Além da interface de consola, o SERVIDOR expõe uma API REST consumida por um painel web em Blazor que permite filtrar os dados recebidos por sensor, WAVY ou intervalo de tempo, pedir novas análises e exportar os resultados filtrados em JSON.
Desafios técnicos
- pub/sub e RPC lado a lado — RabbitMQ para a ingestão assíncrona e desacoplada dos dados das WAVYs (um tópico por sensor); gRPC/Protobuf para as chamadas síncronas de pré-processamento e análise, aplicando cada paradigma onde a sua semântica encaixa melhor
- dados em falta — reamostragem a intervalos fixos com interpolação linear para estimar valores em timestamps sem leitura, antes de enviar ao servidor
- pré-processamento configurável — cada sensor pode pedir um formato diferente (float, json, csv, xml) ao microserviço de pré-processamento, definido por ficheiro de configuração
- compatibilidade entre fases — a mudança de sockets para RabbitMQ manteve o formato de mensagem plain text e as confirmações ACK/NACK da primeira fase
- painel web com exportação filtrada — dashboard em Blazor que consome a API REST do servidor para filtrar os dados por sensor, WAVY ou intervalo de tempo, pedir análises (média, outliers, picos, tendência) e descarregar o resultado filtrado em JSON