Een gebeurtenisbron toevoegen en beheren in een eventstream
Nadat u een eventstream hebt gemaakt, kunt u deze verbinden met verschillende gegevensbronnen en bestemmingen.
Notitie
Verbeterde mogelijkheden zijn standaard ingeschakeld wanneer u nu eventstreams maakt. Als u eventstreams hebt die zijn gemaakt met behulp van standaardmogelijkheden, blijven deze eventstreams werken. U kunt ze nog steeds bewerken en gebruiken zoals gebruikelijk. U wordt aangeraden een nieuwe eventstream te maken om standaard eventstreams te vervangen, zodat u kunt profiteren van extra mogelijkheden en voordelen van verbeterde eventstreams.
Zodra u een eventstream hebt gemaakt, kunt u deze verbinden met verschillende gegevensbronnen en bestemmingen.
Eventstream biedt niet alleen de mogelijkheid om gegevens uit Microsoft-bronnen te streamen, maar biedt ook ondersteuning voor opname van platformen van derden, zoals Google Cloud en Amazon Kinesis met nieuwe berichtenconnectors. Deze uitgebreide mogelijkheid biedt naadloze integratie van externe gegevensstromen in Fabric, waardoor u meer flexibiliteit hebt en u realtime inzichten kunt verkrijgen uit meerdere bronnen.
In dit artikel krijgt u informatie over de gebeurtenisbronnen die u kunt toevoegen aan een eventstream.
Vereisten
- Toegang tot een werkruimte in de licentiemodus voor infrastructuurcapaciteit (of) de modus Voor proeflicenties met inzender- of hogere machtigingen.
- Vereisten die specifiek zijn voor elke bron die worden beschreven in de volgende bronspecifieke artikelen.
Ondersteunde bronnen
Gebeurtenisstromen voor infrastructuur met verbeterde mogelijkheden ondersteunen de volgende bronnen. Elk artikel bevat details en instructies voor het toevoegen van specifieke bronnen.
| Bronnen | Beschrijving |
|---|---|
| Azure Event Hubs | Als u een Azure Event Hub hebt, kunt u event hub-gegevens opnemen in Microsoft Fabric met behulp van Eventstream. |
| Azure IoT Hub | Als u een Azure IoT-hub hebt, kunt u IoT-gegevens opnemen in Microsoft Fabric met behulp van Eventstream. |
| Azure SQL Database Change Data Capture (CDC) | Met de Azure SQL Database CDC-bronconnector kunt u een momentopname van de huidige gegevens in een Azure SQL-database vastleggen. De connector bewaakt en registreert toekomstige wijzigingen op rijniveau in deze gegevens. |
| PostgreSQL-database-CDC | Met de Bronconnector PostgreSQL Database Change Data Capture (CDC) kunt u een momentopname van de huidige gegevens in een PostgreSQL-database vastleggen. De connector bewaakt en registreert toekomstige wijzigingen op rijniveau in deze gegevens. |
| MySQL-database-CDC | Met de Bronconnector azure MySQL Database Change Data Capture (CDC) kunt u een momentopname van de huidige gegevens in een Azure Database for MySQL-database vastleggen. U kunt de tabellen opgeven die moeten worden bewaakt en de eventstream registreert toekomstige wijzigingen op rijniveau in de tabellen. |
| Azure Cosmos DB CDC | Met de Azure Cosmos DB Change Data Capture-bronconnector (CDC) voor Microsoft Fabric-gebeurtenisstromen kunt u een momentopname van de huidige gegevens in een Azure Cosmos DB-database vastleggen. De connector bewaakt en registreert toekomstige wijzigingen op rijniveau in deze gegevens. |
| SQL Server op virtuele machine (VM) Database (DB) CDC | Met de SQL Server op DE CDC-bronconnector (VM DB) voor Fabric-gebeurtenisstromen kunt u een momentopname van de huidige gegevens in een SQL Server-database op de VM vastleggen. De connector bewaakt en registreert toekomstige wijzigingen op rijniveau in de gegevens. |
| Azure SQL Managed Instance CDC | Met de CDC-bronconnector van Azure SQL Managed Instance voor Microsoft Fabric-gebeurtenisstromen kunt u een momentopname van de huidige gegevens in een SQL Managed Instance-database vastleggen. De connector bewaakt en registreert toekomstige wijzigingen op rijniveau in deze gegevens. |
| Google Cloud Pub/Sub | Google Pub/Sub is een berichtenservice waarmee u streams van gebeurtenissen kunt publiceren en abonneren. U kunt Google Pub/Sub als bron toevoegen aan uw eventstream om realtime gebeurtenissen vast te leggen, te transformeren en te routeren naar verschillende bestemmingen in Fabric. |
| Amazon Kinesis-gegevensstromen | Amazon Kinesis-gegevensstromen is een zeer schaalbare, zeer duurzame gegevensopname en verwerkingsservice die is geoptimaliseerd voor streaminggegevens. Door Amazon Kinesis-gegevensstromen te integreren als bron in uw eventstream, kunt u realtime gegevensstromen naadloos verwerken voordat u ze doorsturen naar meerdere bestemmingen in Fabric. |
| Confluent Cloud Kafka | Confluent Cloud Kafka is een streamingplatform dat krachtige functies voor gegevensstreaming en -verwerking biedt met behulp van Apache Kafka. Door Confluent Cloud Kafka te integreren als bron in uw eventstream, kunt u realtime gegevensstromen naadloos verwerken voordat u ze doorsturen naar meerdere bestemmingen in Fabric. |
| Amazon MSK Kafka | Amazon MSK Kafka is een volledig beheerde Kafka-service die het instellen, schalen en beheren vereenvoudigt. Door Amazon MSK Kafka te integreren als bron in uw eventstream, kunt u de realtime gebeurtenissen naadloos vanuit uw MSK Kafka overbrengen en verwerken voordat u ze doorsturen naar meerdere bestemmingen in Fabric. |
| Voorbeeldgegevens | U kunt fietsen, yellow taxi- of aandelenmarktgebeurtenissen kiezen als voorbeeldgegevensbron om de gegevensopname te testen tijdens het instellen van een eventstream. |
| Aangepast eindpunt (dat wil gezegd, aangepaste app in standaardmogelijkheid) | Met de aangepaste eindpuntfunctie kunnen uw toepassingen of Kafka-clients verbinding maken met Eventstream met behulp van een verbindingsreeks, waardoor de soepele opname van streaminggegevens naar Eventstream mogelijk wordt. |
| Azure Service Bus (preview) | U kunt gegevens opnemen uit een Azure Service Bus-wachtrij of het abonnement van een onderwerp in Microsoft Fabric met behulp van Eventstream. |
| Apache Kafka (preview) | Apache Kafka is een opensource, gedistribueerd platform voor het bouwen van schaalbare, realtime gegevenssystemen. Door Apache Kafka te integreren als bron in uw eventstream, kunt u naadloos realtime gebeurtenissen uit uw Apache Kafka overbrengen en verwerken voordat u ze doorsturen naar meerdere bestemmingen in Fabric. |
| Azure Blob Storage-gebeurtenissen (preview) | Azure Blob Storage-gebeurtenissen worden geactiveerd wanneer een client een blob maakt, vervangt of verwijdert. Met de connector kunt u Blob Storage-gebeurtenissen koppelen aan Fabric-gebeurtenissen in realtime hub. U kunt deze gebeurtenissen converteren naar continue gegevensstromen en deze transformeren voordat u ze doorsturen naar verschillende bestemmingen in Fabric. |
| Item-gebeurtenissen voor infrastructuurwerkruimten (preview) | Items in de infrastructuurwerkruimte zijn afzonderlijke Fabric-gebeurtenissen die optreden wanneer wijzigingen worden aangebracht in uw infrastructuurwerkruimte. Deze wijzigingen omvatten het maken, bijwerken of verwijderen van een Fabric-item. Met Fabric-gebeurtenisstromen kunt u deze Fabric-werkruimtegebeurtenissen vastleggen, transformeren en routeren naar verschillende bestemmingen in Fabric voor verdere analyse. |
| Fabric OneLake-gebeurtenissen (voorbeeld) | Met OneLake-gebeurtenissen kunt u zich abonneren op wijzigingen in bestanden en mappen in OneLake en vervolgens in realtime reageren op deze wijzigingen. Met Fabric-gebeurtenisstromen kunt u deze OneLake-gebeurtenissen vastleggen, transformeren en routeren naar verschillende bestemmingen in Fabric voor verdere analyse. Deze naadloze integratie van OneLake-gebeurtenissen in Fabric-gebeurtenisstromen biedt u meer flexibiliteit voor het bewaken en analyseren van activiteiten in uw OneLake. |
| Fabric-taakgebeurtenissen (preview) | Met taakevenementen kunt u zich abonneren op wijzigingen die worden geproduceerd wanneer Fabric een taak uitvoert. U kunt bijvoorbeeld reageren op wijzigingen wanneer u een semantisch model vernieuwt, een geplande pijplijn uitvoert of een notebook uitvoert. Elk van deze activiteiten kan een bijbehorende taak genereren, die op zijn beurt een set bijbehorende taakevenementen genereert. Met Fabric-gebeurtenisstromen kunt u deze taakgebeurtenissen vastleggen, transformeren en doorsturen naar verschillende bestemmingen in Fabric voor verdere analyse. Dankzij deze naadloze integratie van taakevenementen in Fabric-gebeurtenisstromen hebt u meer flexibiliteit voor het bewaken en analyseren van activiteiten in uw taak. |
Notitie
Het maximum aantal bronnen en bestemmingen voor één eventstream is 11.
Gerelateerde inhoud
Vereisten
Voordat u begint, moet u de volgende vereisten voltooien:
- Toegang tot een werkruimte in de licentiemodus voor infrastructuurcapaciteit (of) de modus Voor proeflicenties met inzender- of hogere machtigingen.
- Als u een Azure Event Hubs of Azure IoT Hub als eventstream-bron wilt toevoegen, moet u over de juiste machtigingen beschikken om toegang te krijgen tot de beleidssleutels. Ze moeten openbaar toegankelijk zijn en niet achter een firewall of beveiligd in een virtueel netwerk.
Ondersteunde bronnen
Fabric-gebeurtenisstromen ondersteunen de volgende bronnen. Gebruik koppelingen in de tabel om te navigeren naar artikelen met meer informatie over het toevoegen van specifieke bronnen.
| Bronnen | Beschrijving |
|---|---|
| Azure Event Hubs | Als u een Azure Event Hub hebt, kunt u event hub-gegevens opnemen in Microsoft Fabric met behulp van Eventstream. |
| Azure IoT Hub | Als u een Azure IoT-hub hebt, kunt u IoT-gegevens opnemen in Microsoft Fabric met behulp van Eventstream. |
| Voorbeeldgegevens | U kunt fietsen, yellow taxi- of aandelenmarktgebeurtenissen kiezen als voorbeeldgegevensbron om de gegevensopname te testen tijdens het instellen van een eventstream. |
| Aangepaste app | Met de aangepaste app-functie kunnen uw toepassingen of Kafka-clients verbinding maken met Eventstream met behulp van een verbindingsreeks, waardoor de soepele opname van streaminggegevens naar Eventstream mogelijk is. |
Notitie
Het maximum aantal bronnen en bestemmingen voor één eventstream is 11.
Een bron beheren
Bewerken/verwijderen: u kunt een gebeurtenisstreambron selecteren om te bewerken of verwijderen via het navigatiedeelvenster of canvas. Wanneer u Bewerken selecteert, wordt het bewerkingsvenster rechts van de hoofdeditor geopend.
Sleutel opnieuw genereren voor een aangepaste app: als u een nieuwe verbindingssleutel voor uw toepassing opnieuw wilt genereren, selecteert u een van uw aangepaste app-bronnen op het canvas en selecteert u Opnieuw genereren om een nieuwe verbindingssleutel op te halen.
