De sinais a insights: construindo uma plataforma de streaming de dados em tempo real com o Fabric Eventstream

Por que o processamento de fluxo em tempo real é importante

Na era da IA, à medida que as organizações adotam sistemas inteligentes e tomadas de decisão baseadas em dados, a capacidade de agir com base nos dados no momento em que eles chegam está liberando novos níveis de agilidade e insights.  Da detecção de anomalias e otimização operacional à prevenção de fraudes e experiências personalizadas, os insights em tempo real estão impulsionando a próxima onda de inovação. Para empresas com visão de futuro, o processamento de fluxo em tempo real tornou-se uma capacidade fundamental.

Nesta publicação, exploraremos como a Contoso, uma operadora de edifícios inteligentes, usa a inteligência em tempo real do Microsoft Fabric para criar uma plataforma de dados de streaming que conecta sensores de ambiente, feeds meteorológicos e sistemas de alerta.

Visão geral da arquitetura

Cada edifício operado pela Contoso é equipado com sensores de ambiente que transmitem dados de temperatura e ocupação para um agente MQTT. Para enriquecer esses dados, a Contoso também ingere um feed meteorológico público, permitindo a correlação entre as condições internas e externas. Esses sinais em tempo real impulsionam o uso mais inteligente de energia, melhoram o conforto dos ocupantes e permitem respostas rápidas às mudanças ambientais.

Conforme demonstrado na Figura 1, esses sinais em tempo real fluem pela pilha de Inteligência em Tempo Real do Microsoft Fabric — da ingestão à transformação, alertas e visualização. A arquitetura inclui:

• Eventstream para ingestão de dados MQTT e meteorológicos.
• Operadores SQL e sem código para moldar os dados.
• Ativador de dados para disparar alertas.
• Eventhouse para armazenar e analisar dados de séries temporais.
• Painéis em tempo real para monitorar tendências atualizadas, anomalias etc.

Nas seções a seguir, abordaremos a implementação de cada estágio da arquitetura.

Mal pode esperar para saber mais? Confira o vídeo de demonstração completo .

Etapa 1: Ingerir dados com o Eventstream

A jornada em tempo real da Contoso começa com dados — muitos deles. Cada edifício transmite leituras de temperatura e ocupação de sensores de ambiente para um agente MQTT. Para tomar decisões mais inteligentes, a Contoso enriquece esses sinais com dados meteorológicos em tempo real do Azure Maps, permitindo correlacionar as condições internas com o ambiente externo. Essa combinação ajuda a otimizar o uso do HVAC, detectar leituras anômalas, antecipar problemas de conforto e responder proativamente — e não reativamente.

O Hub em Tempo Real do Microsoft Fabric facilita isso. Com conectores integrados para MQTT e Azure Maps Weather, a Contoso pode ingerir diversos fluxos de dados com apenas alguns cliques.

Abra o hub em tempo real e clique em “conectar fonte de dados”.
Selecione o conector MQTT e conecte
Crie uma nova conexão e preencha o nome do tópico.
Entre no modo de edição do Eventstream.Selecione ‘Adicionar fonte’ e ‘Conectar fontes de dados’.Selecione o conector de dados meteorológicos
Escolha o local (por exemplo, Londres)
Habilite o recurso de inferência de múltiplos esquemas na página Configurações do Eventstreams.
Navegue até a visualização de dados no fluxo padrão:Selecione o menu suspenso Esquema múltiplo.Cada esquema é inferido automaticamente a partir dos dados recebidos. Você pode alternar entre esquemas diferentes para revisar os detalhes.

Etapa 2: Processar e transformar dados de streaming com operadores SQL e sem código

Assim que os dados começam a fluir para um Fabric Eventstream, o próximo passo é moldá-los em um formato utilizável. Dados brutos de sensores e meteorológicos geralmente precisam ser filtrados, renomeados ou enriquecidos antes de estarem prontos para alertas ou painéis. Para a Contoso, isso significa extrair apenas os campos relevantes e remodelar os dados para se adequarem a um modelo de dados comum, por exemplo, temperaturas relatadas em graus Celsius em vez de Fahrenheit, etc.

O Fabric facilita isso com ferramentas de transformação integradas. Você pode usar operadores sem código para filtragem e modelagem rápidas ou migrar para SQL para lógica mais avançada — tudo dentro da mesma tela do Eventstream.

Clique em  + Adicionar transformação  na tela do Eventstream (Editar)Use transformações visuais para selecionar campos, renomear colunas e alterar tipos de dados.
Use SQL | Editar consulta para criar e testar consultas
Envie resultados para uma tabela do Eventhouse conectando o operador SQL a um destino do Eventhouse e finalizando a configuração do Eventhouse.

Usando as etapas que abordamos, a Contoso pode criar e testar rapidamente um pipeline de dados de streaming complexo, conforme demonstrado na Figura 2. 

Etapa 3: Agir com base nos dados de streaming – Alertas e painéis em tempo real

Depois que os dados do sensor e do clima são ingeridos, processados e transformados, o próximo passo é agir. Em alguns casos, isso significa disparar alertas em tempo real quando as condições excedem os limites — como uma temperatura ambiente acima de 38°C ou uma ocupação superior a 50 pessoas. Em outros, significa visualizar tendências em todos os edifícios para apoiar decisões operacionais. Sejam respostas automatizadas ou monitoramento humano, o valor do streaming de dados reside na rapidez e clareza com que ele impulsiona as ações.

O Fabric Real-Time Intelligence suporta ambos os modos de ação: automação orientada por eventos com o Data Activator e observabilidade em tempo real com os Painéis em Tempo Real do Eventhouse. Com o Data Activator, a Contoso consegue definir condições de alerta diretamente nos dados de streaming e acionar notificações ou fluxos de trabalho sem precisar escrever código. Com o Eventhouse e os Painéis em Tempo Real, a Contoso pode criar painéis ao vivo que refletem as condições atuais em seus edifícios — em tempo real.

Defina alertas ou ações de gatilho adicionando o Data Activator como destino para o EventstreamDefinir condições de alerta e configurar ações (por exemplo, notificações de equipes, e-mails, blocos de anotações)
Envie dados para o Eventhouse e crie um painel em tempo real.
Use consultas visuais e ative a atualização automática para manter os insights ativos.

Conclusão

A jornada da Contoso mostra como a Fabric Real-Time Intelligence pode transformar sinais brutos em insights acionáveis — sem precisar escrever códigos complexos ou unir várias ferramentas. Da ingestão de dados MQTT e meteorológicos ao disparo de alertas e à ativação de painéis em tempo real, a Fabric oferece um caminho unificado e de baixo atrito para a construção de aplicações inteligentes e orientadas a eventos.

Essa abordagem não se limita a edifícios inteligentes; o padrão de design ingerir, transformar e agir é aplicável em vários setores:

• Fabricação : monitore a saúde do equipamento e acione alertas de manutenção.
• Varejo : monitore o tráfego de pedestres e otimize a equipe em tempo real.
• Logística : Combine GPS e dados meteorológicos para redirecionar entregas.
• Finanças : detecte padrões de fraude conforme as transações ocorrem.

Seja gerenciando uma fábrica, uma rede de logística ou uma loja digital, a fórmula é a mesma: Transmita. Molde. Aja.

Arbit: 26 anos transformando tecnologia em valor

Pode não ser parecer fácil gerar valor para seus dados, mas a Arbit, pode ajudá-lo. Há 26 anos atuando com inteligência de dados, a Arbit possui especialistas para implementar as melhores soluções ao seu ambiente de negócios.  Fale conosco agora mesmo