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 ondersteunt ook verwerking van gegevens van externe platforms 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 Fabric capaciteitslicentiemodus of de Proeflicentiemodus met inzender- of hogere machtigingen.
- Vereisten die specifiek zijn voor elke bron die worden beschreven in de volgende bronspecifieke artikelen.
Ondersteunde bronnen
Gebeurtenisstromen voor fabric 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 Event Grid | Als u een Azure Event Grid-naamruimte hebt, kunt u MQTT- of niet-MQTT-gebeurtenisgegevens opnemen in Microsoft Fabric met behulp van Eventstream. |
| Azure Data Explorer | Als u een Azure Data Explorer-database en een tabel hebt, kunt u gegevens uit de tabel 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 Azure MySQL Database Change Data Capture (CDC) bronconnector 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 een VM DB als CDC-bronconnector voor Fabric-gebeurtenisstromen kunt u een momentopname van de huidige gegevens in een SQL Server-database op een 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, Gele Taxi of aandelenmarktgebeurtenissen kiezen als voorbeeldgegevensbron om de gegevensopname te testen tijdens het instellen van een eventstream. |
| #B0 Weer in realtime #C1 | U kunt een realtime weerbron toevoegen aan een eventstream om realtime weersgegevens van verschillende locaties te streamen. |
| Aangepast eindpunt (dat wil zeggen, Aangepaste App in standaardfunctionaliteit) | 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 | 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. |
| Gebeurtenissen van Fabric Werkruimte-item | Fabric-werkruimte-itemgebeurtenissen zijn afzonderlijke Fabric-gebeurtenissen die plaatsvinden wanneer er wijzigingen worden aangebracht in uw Fabric-werkruimte. 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. |
| #B0 Fabric OneLake-gebeurtenissen #C1 | 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-processgebeurtenissen | 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 Fabric capaciteitslicentiemodus of de Proeflicentiemodus met medewerker- 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, Gele Taxi, of aandelenmarktgebeurtenissen kiezen als voorbeeldgegevensbron om de gegevensopname te testen bij 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.
