Fontes e destinos do fluxo de eventos
Em sua forma mais simples, os fluxos de eventos capturam dados em tempo real de uma fonte e carregam os dados capturados em um destino.
Fontes de fluxo de eventos
As fontes de eventos no Fabric Real-Time Hub podem incluir (entre outras):
- Hub de Eventos do Azure: os Hubs de Eventos do Azure são uma fonte que permite obter dados de eventos de um hub de eventos do Azure. Você pode especificar o formato de dados e o grupo de consumidores do seu hub de eventos do Azure. Você também pode criar uma conexão de nuvem para seu hub de eventos do Azure com o nível de autenticação e privacidade apropriado.
- Hub IoT do Azure: um serviço SaaS usado para conectar, monitorar e gerenciar milhões de ativos de IoT com uma experiência sem código.
- Captura de Dados de Alteração (CDC) do Banco de Dados SQL do Azure: processo de software que identifica e rastreia alterações em dados em um banco de dados, permitindo a movimentação de dados em tempo real ou quase em tempo real.
- PostgreSQL Database CDC: O conector PostgreSQL Database CDC (change data capture) para Microsoft Fabric Eventstreams captura um instantâneo atual e rastreia alterações futuras em um banco de dados PostgreSQL, permitindo processamento e análise em tempo real desses dados no Fabric.
- CDC do Banco de Dados MySQL: O conector de origem CDC do Banco de Dados MySQL do Azure para Microsoft Fabric Eventstreams captura um instantâneo do seu banco de dados MySQL e rastreia as alterações da tabela, permitindo o processamento e a análise em tempo real desses dados na malha.
- Azure Cosmos DB CDC: O conector CDC do Azure Cosmos DB para Microsoft Fabric Eventstreams captura e rastreia alterações de dados em tempo real no Cosmos DB para análise e processamento no Fabric.
- Google Cloud Pub/Sub: um serviço de mensagens para troca de dados de eventos entre aplicativos e serviços.
- Amazon Kinesis Data Streams: colete, processe e analise dados de streaming em tempo real.
- Confluent Cloud Kafka: Um serviço totalmente gerenciado baseado no Apache Kafka para processamento de fluxo.
- Eventos do espaço de trabalho de malha: os eventos do espaço de trabalho de malha são eventos acionados por alterações no espaço de trabalho de malha, como criar, atualizar ou excluir itens. Com os fluxos de eventos do Fabric, você pode capturar, transformar e rotear esses eventos para análise e monitoramento detalhados no Fabric. Essa integração oferece maior flexibilidade no acompanhamento e compreensão das atividades do espaço de trabalho.
- Eventos de armazenamento de blob do Azure: os eventos do Armazenamento de Blob do Azure são gatilhos do sistema para ações como criar, substituir ou excluir um blob. Os fluxos de eventos do Microsoft Fabric vinculam essas ações a eventos de malha, permitindo que você processe eventos de armazenamento de Blob como fluxos de dados contínuos para roteamento e análise dentro da malha. Uma característica exclusiva dos Eventos de Armazenamento de Blob do Azure é o suporte para eventos transmitidos ou não transmitidos.
- Ponto de extremidade personalizado: você pode usar a API REST ou os kits de desenvolvimento de software (SDKs) fornecidos pelo Microsoft Fabric para enviar dados de eventos do seu aplicativo personalizado para o fluxo de eventos. Você também pode especificar o formato de dados e o grupo de consumidores do seu aplicativo personalizado.
- Dados de exemplo: os dados de exemplo são uma fonte que permite usar os dados de exemplo prontos para uso fornecidos pelo Microsoft Fabric. Você pode escolher entre diferentes conjuntos de dados de exemplo, como IoT, Varejo ou Finanças. Também é possível ajustar a frequência e a duração da geração de dados de amostra.
Gorjeta
Para obter mais informações sobre fontes suportadas, consulte Fontes suportadas para o hub Fabric Real-Time.
Destinos Eventstream
Os fluxos de eventos do Microsoft Fabric também oferecem suporte à capacidade de enviar dados para os seguintes destinos no modo avançado.
- Eventhouse: Este destino oferece a capacidade de canalizar seus dados de eventos em tempo real para um banco de dados KQL, permitindo que você use a Kusto Query Language (KQL) para interrogação e análise de dados. Armazenar seus dados em um banco de dados KQL libera o potencial para uma melhor compreensão dos dados do seu evento e a criação de relatórios e painéis abrangentes.
- Lakehouse: Este destino permite-lhe pré-processar os seus eventos em tempo real antes da sua ingestão na sua casa do lago. Os eventos são transformados no formato Delta Lake e posteriormente armazenados em tabelas específicas do lakehouse, facilitando suas necessidades de armazenamento de dados.
- Ponto de extremidade personalizado: com esse recurso, você pode direcionar perfeitamente seu tráfego de eventos em tempo real para um aplicativo personalizado. Permite a integração das suas aplicações proprietárias com o fluxo de eventos, permitindo o consumo imediato de dados de eventos. Esse recurso é vantajoso quando você pretende transferir dados em tempo real para um sistema independente não hospedado no Microsoft Fabric.
- Fluxo derivado: o fluxo derivado é um destino especializado criado após a aplicação de operações de fluxo como Filtrar ou Gerenciar campos a um fluxo de eventos. Ele representa o fluxo padrão alterado após o processamento, que pode ser roteado para vários destinos dentro do Fabric e monitorado no hub em tempo real.
- Ativador de malha: esse destino permite que você use o ativador de malha para acionar ações automatizadas com base em valores em seus dados de streaming.
Gorjeta
Para obter mais informações sobre fontes suportadas, consulte Adicionar e gerenciar um destino em um fluxo de eventos.
Você pode anexar a vários destinos dentro de um fluxo de eventos ao mesmo tempo sem impactar ou colidir uns com os outros.