Tilføj og administrer en hændelseskilde i en hændelsesstream
Når du har oprettet en hændelsesstream, kan du oprette forbindelse til forskellige datakilder og destinationer.
Bemærk
Forbedrede funktioner aktiveres som standard, når du opretter eventstreams nu. Hvis du har hændelsesstreams, der er oprettet ved hjælp af standardfunktioner, fungerer disse hændelsesstreams fortsat. Du kan stadig redigere og bruge dem som normalt. Vi anbefaler, at du opretter en ny hændelsesstream for at erstatte standardhændelsesstreams, så du kan drage fordel af yderligere funktioner og fordele ved forbedrede hændelsesstreams.
Når du har oprettet en eventstream, kan du oprette forbindelse til forskellige datakilder og destinationer.
Eventstream giver dig ikke kun mulighed for at streame data fra Microsoft-kilder, men understøtter også indtagelse fra tredjepartsplatforme som Google Cloud og Amazon Kinesis med nye meddelelsesconnectors. Denne udvidede funktionalitet giver problemfri integration af eksterne datastrømme i Fabric, hvilket giver større fleksibilitet og giver dig mulighed for at få indsigt i realtid fra flere kilder.
I denne artikel får du mere at vide om de hændelseskilder, du kan føje til en hændelsesstream.
Forudsætninger
- Adgang til et arbejdsområde i Fabric-kapacitetslicenstilstand (eller) prøvelicenstilstand med bidragydertilladelser eller højere tilladelser.
- Forudsætninger, der er specifikke for hver kilde, og som er dokumenteret i følgende kildespecifikke artikler.
Understøttede kilder
Fabric-hændelsesstrømme med forbedrede egenskaber understøtter følgende kilder. Hver artikel indeholder oplysninger og instruktioner til tilføjelse af bestemte kilder.
| Kilder | Beskrivelse |
|---|---|
| Azure Event Hubs | Hvis du har en Azure-hændelseshub, kan du indføde hændelseshubdata i Microsoft Fabric ved hjælp af Eventstream. |
| Azure IoT Hub | Hvis du har en Azure IoT-hub, kan du indføde IoT-data i Microsoft Fabric ved hjælp af Eventstream. |
| Azure SQL Database Change Data Capture (CDC) | Azure SQL Database CDC-kildeconnectoren giver dig mulighed for at hente et snapshot af de aktuelle data i en Azure SQL-database. Connectoren overvåger og registrerer derefter eventuelle fremtidige ændringer af disse data på rækkeniveau. |
| PostgreSQL Database CDC | Med POSTgreSQL-kildeconnectoren (Change Data Capture) til Database Change Data Capture (CDC) kan du hente et snapshot af de aktuelle data i en PostgreSQL-database. Connectoren overvåger og registrerer derefter eventuelle fremtidige ændringer af disse data på rækkeniveau. |
| Cdc til MySQL-database | Azure MySQL Database Change Data Capture (CDC) Source-connectoren giver dig mulighed for at hente et snapshot af de aktuelle data i en Azure Database til MySQL-database. Du kan angive de tabeller, der skal overvåges, og eventstream registrerer eventuelle fremtidige ændringer af tabellerne på rækkeniveau. |
| Azure Cosmos DB CDC | Azure Cosmos DB CDC-kildeconnectoren (Change Data Capture) til Microsoft Fabric-hændelsesstrømme giver dig mulighed for at hente et snapshot af de aktuelle data i en Azure Cosmos DB-database. Connectoren overvåger og registrerer derefter eventuelle fremtidige ændringer af disse data på rækkeniveau. |
| SQL Server på CDC (Virtual Machine ( VM) Database (DB) | SQL Server på CDC-kildeconnectoren (VMC) til Fabric-hændelsesstrømme giver dig mulighed for at hente et snapshot af de aktuelle data i en SQL Server-database på VM. Connectoren overvåger og registrerer derefter eventuelle fremtidige ændringer af dataene på rækkeniveau. |
| Azure SQL Managed Instance CDC | Azure SQL Managed Instance CDC-kildeconnectoren til Microsoft Fabric-hændelsesstrømme giver dig mulighed for at hente et snapshot af de aktuelle data i en SQL Managed Instance-database. Connectoren overvåger og registrerer derefter eventuelle fremtidige ændringer af disse data på rækkeniveau. |
| Google Cloud Pub/Sub | Google Pub/Sub er en meddelelsestjeneste, der giver dig mulighed for at publicere og abonnere på streams af begivenheder. Du kan føje Google Pub/Sub som kilde til din eventstream for at registrere, transformere og dirigere begivenheder i realtid til forskellige destinationer i Fabric. |
| Amazon Kinesis Data Streams | Amazon Kinesis Data Streams er en enormt skalerbar, yderst holdbar dataindtagelse og behandlingstjeneste, der er optimeret til streamingdata. Ved at integrere Amazon Kinesis Data Streams som en kilde i din eventstream kan du problemfrit behandle datastrømme i realtid, før du distribuerer dem til flere destinationer i Fabric. |
| Confluent Cloud Kafka | Confluent Cloud Kafka er en streamingplatform, der tilbyder effektive funktioner til datastreaming og -behandling ved hjælp af Apache Kafka. Ved at integrere Confluent Cloud Kafka som en kilde i din eventstream kan du problemfrit behandle datastrømme i realtid, før du distribuerer dem til flere destinationer i Fabric. |
| Amazon MSK Kafka | Amazon MSK Kafka er en fuldt administreret Kafka-tjeneste, der forenkler konfiguration, skalering og administration. Ved at integrere Amazon MSK Kafka som en kilde i din eventstream kan du problemfrit hente hændelserne i realtid fra din MSK Kafka og behandle dem, før du distribuerer dem til flere destinationer i Fabric. |
| Eksempeldata | Du kan vælge Cykler, Gul taxa eller Aktiemarkedshændelser som en eksempeldatakilde for at teste dataindtagelse, mens du konfigurerer en hændelsesstream. |
| Brugerdefineret slutpunkt (dvs. brugerdefineret app i standardfunktionalitet) | Den brugerdefinerede slutpunktsfunktion gør det muligt for dine programmer eller Kafka-klienter at oprette forbindelse til Eventstream ved hjælp af en forbindelsesstreng, hvilket muliggør problemfri indtagelse af streamingdata til Eventstream. |
| Azure Service Bus (prøveversion) | Du kan hente data fra en Azure Service Bus-kø eller et emnes abonnement i Microsoft Fabric ved hjælp af Eventstream. |
| Apache Kafka (prøveversion) | Apache Kafka er en distribueret platform med åben kildekode til opbygning af skalerbare datasystemer i realtid. Ved at integrere Apache Kafka som en kilde i din eventstream kan du problemfrit medbringe hændelser i realtid fra din Apache Kafka og behandle dem, før du distribuerer dem til flere destinationer i Fabric. |
| Azure Blob Storage-hændelser (prøveversion) | Azure Blob Storage-hændelser udløses, når en klient opretter, erstatter eller sletter en blob. Med connectoren kan du linke Blob Storage-hændelser til Fabric-hændelser i realtidshubben. Du kan konvertere disse hændelser til fortløbende datastrømme og transformere dem, før du distribuerer dem til forskellige destinationer i Fabric. |
| Fabric Workspace Item-hændelser (prøveversion) | Fabric Workspace Item-hændelser er diskrete Fabric-hændelser, der opstår, når der foretages ændringer i dit Fabric Workspace. Disse ændringer omfatter oprettelse, opdatering eller sletning af et Fabric-element. Med Fabric-hændelsesstrømme kan du registrere disse Fabric-arbejdsområdehændelser, transformere dem og dirigere dem til forskellige destinationer i Fabric for yderligere analyse. |
| Fabric OneLake-hændelser (prøveversion) | Med OneLake-hændelser kan du abonnere på ændringer i filer og mapper i OneLake og derefter reagere på disse ændringer i realtid. Med Fabric-hændelsesstrømme kan du fange disse OneLake-begivenheder, transformere dem og dirigere dem til forskellige destinationer i Fabric for at få yderligere analyse. Denne problemfrie integration af OneLake-hændelser i Fabric-hændelsesstrømme giver dig større fleksibilitet til at overvåge og analysere aktiviteter i din OneLake. |
| Fabric Job-begivenheder (prøveversion) | Jobhændelser giver dig mulighed for at abonnere på ændringer, der er produceret, når Fabric kører et job. Du kan f.eks. reagere på ændringer, når du opdaterer en semantisk model, kører en planlagt pipeline eller kører en notesbog. Hver af disse aktiviteter kan generere et tilsvarende job, hvilket igen genererer et sæt tilsvarende jobhændelser. Med Fabric-hændelsesstrømme kan du registrere disse Job-begivenheder, transformere dem og dirigere dem til forskellige destinationer i Fabric for yderligere analyse. Denne problemfrie integration af Job-begivenheder i Fabric-hændelsesstrømme giver dig større fleksibilitet til at overvåge og analysere aktiviteter i dit job. |
Bemærk
Det maksimale antal kilder og destinationer for én hændelsesstream er 11.
Relateret indhold
Forudsætninger
Før du starter, skal du fuldføre følgende forudsætninger:
- Adgang til et arbejdsområde i Fabric-kapacitetslicenstilstand (eller) prøvelicenstilstand med bidragydertilladelser eller højere tilladelser.
- Hvis du vil tilføje en Azure Event Hubs eller Azure IoT Hub som eventstream-kilde, skal du have den nødvendige tilladelse til at få adgang til politiknøglerne. De skal være offentligt tilgængelige og ikke bag en firewall eller være sikret i et virtuelt netværk.
Understøttede kilder
Fabric-hændelsesstrømme understøtter følgende kilder. Brug links i tabellen til at navigere til artikler, der indeholder flere oplysninger om tilføjelse af bestemte kilder.
| Kilder | Beskrivelse |
|---|---|
| Azure Event Hubs | Hvis du har en Azure-hændelseshub, kan du indføde hændelseshubdata i Microsoft Fabric ved hjælp af Eventstream. |
| Azure IoT Hub | Hvis du har en Azure IoT-hub, kan du indføde IoT-data i Microsoft Fabric ved hjælp af Eventstream. |
| Eksempeldata | Du kan vælge Cykler, Gul taxa eller Aktiemarkedshændelser som en eksempeldatakilde for at teste dataindtagelse, mens du konfigurerer en hændelsesstream. |
| Brugerdefineret app | Den brugerdefinerede appfunktion gør det muligt for dine programmer eller Kafka-klienter at oprette forbindelse til Eventstream ved hjælp af en forbindelsesstreng, hvilket muliggør problemfri indtagelse af streamingdata til Eventstream. |
Bemærk
Det maksimale antal kilder og destinationer for én hændelsesstream er 11.
Administrer en kilde
Rediger/fjern: Du kan vælge en hændelsesstreamkilde, der skal redigeres eller fjernes enten via navigationsruden eller lærredet. Når du vælger Rediger, åbnes redigeringsruden til højre for hovededitoren.
Regenerer nøgle for en brugerdefineret app: Hvis du vil genoprette en ny forbindelsesnøgle for dit program, skal du vælge en af dine brugerdefinerede appkilder på lærredet og vælge Regenerate for at få en ny forbindelsesnøgle.
