Pode explicar o que se entende por processamento de dados em tempo real através de tecnologias de streaming?

O processamento de dados em tempo real através de tecnologias de streaming significa a receção, processamento e análise contínuos de dados logo após a sua aparição, sem atrasos significativos.

Em Go, isto é frequentemente implementado com goroutines e canais, que permitem processar fluxos de dados de forma assíncrona e paralela.

Exemplo: se tiver um fluxo de eventos (por exemplo, mensagens de utilizadores), pode lê-los do canal e executar imediatamente as operações necessárias — filtragem, agregação, gravação numa base de dados ou envio de notificações.

Isto difere do processamento por lotes, onde os dados são recolhidos e processados em blocos grandes com atraso.

Exemplo de código em Go:

ch := make(chan string)

// Goroutine para processamento de dados
go func() {
    for msg := range ch {
        fmt.Println("Processamento de mensagem:", msg)
    }
}()

// Envio de dados para o fluxo
ch <- "Novo evento"
close(ch)