Legge til og behandle en hendelseskilde i en hendelsesstrøm
Når du har opprettet en hendelsesstrøm, kan du koble den til ulike datakilder og mål.
Merk
Forbedrede funksjoner aktiveres som standard når du oppretter hendelsesstrømmer nå. Hvis du har hendelsesstrømmer som ble opprettet ved hjelp av standardfunksjoner, vil disse hendelsesstrømmene fortsette å fungere. Du kan fortsatt redigere og bruke dem som vanlig. Vi anbefaler at du oppretter en ny hendelsesstrøm for å erstatte standard hendelsesstrømmer, slik at du kan dra nytte av flere funksjoner og fordeler ved forbedrede hendelsesstrømmer.
Når du har opprettet en hendelsesstrøm, kan du koble den til ulike datakilder og mål.
Eventstream lar deg ikke bare strømme data fra Microsoft-kilder, men støtter også inntak fra tredjepartsplattformer som Google Cloud og Amazon Kinesis med nye meldingskoblinger. Denne utvidede funksjonen gir sømløs integrering av eksterne datastrømmer i Fabric, noe som gir større fleksibilitet og gir deg mulighet til å få innsikt i sanntid fra flere kilder.
I denne artikkelen lærer du om hendelseskildene du kan legge til i en hendelsesstrøm.
Forutsetning
- Tilgang til et arbeidsområde i lisensmodus for stoffkapasitet (eller) prøveversjonslisensmodus med bidragsyter eller høyere tillatelser.
- Forutsetninger som er spesifikke for hver kilde som er dokumentert i følgende kildespesifikke artikler.
Støttede kilder
Stoffhendelsesstrømmer med forbedrede funksjoner støtter følgende kilder. Hver artikkel inneholder detaljer og instruksjoner for å legge til bestemte kilder.
| Kilder | Bekrivelse |
|---|---|
| Azure Event Hubs | Hvis du har en Azure-hendelseshub, kan du innta hendelseshubdata i Microsoft Fabric ved hjelp av Eventstream. |
| Azure IoT Hub | Hvis du har en Azure IoT-hub, kan du innta IoT-data i Microsoft Fabric ved hjelp av Eventstream. |
| Azure SQL Database Change Data Capture (CDC) | Med azure SQL Database CDC-kildekoblingen kan du ta et øyeblikksbilde av gjeldende data i en Azure SQL-database. Koblingen overvåker og registrerer deretter eventuelle fremtidige endringer på radnivå i disse dataene. |
| PostgreSQL Database CDC | Med kildekoblingen PostgreSQL Database Change Data Capture (CDC) kan du ta et øyeblikksbilde av gjeldende data i en PostgreSQL-database. Koblingen overvåker og registrerer deretter eventuelle fremtidige endringer på radnivå i disse dataene. |
| MySQL Database CDC | Med kildekoblingen Azure MySQL Database Change Data Capture (CDC) kan du ta et øyeblikksbilde av gjeldende data i en Azure Database for MySQL-database. Du kan angi tabellene som skal overvåkes, og eventstreamen registrerer eventuelle fremtidige endringer på radnivå i tabellene. |
| Azure Cosmos DB CDC | Azure Cosmos DB Change Data Capture (CDC)-kildekoblingen for Microsoft Fabric-hendelsesstrømmer lar deg ta et øyeblikksbilde av gjeldende data i en Azure Cosmos DB-database. Koblingen overvåker og registrerer deretter eventuelle fremtidige endringer på radnivå i disse dataene. |
| SQL Server på virtual machine (VM) Database (DB) CDC | Med SQL Server på VM DB-kildekoblingen (CDC) for fabric-hendelsesstrømmer kan du ta et øyeblikksbilde av gjeldende data i en SQL Server-database på VM. Koblingen overvåker og registrerer deretter eventuelle fremtidige endringer på radnivå i dataene. |
| Azure SQL administrert forekomst CDC | Azure SQL administrert forekomst CDC-kildekobling for Microsoft Fabric-hendelsesstrømmer lar deg ta et øyeblikksbilde av gjeldende data i en SQL administrert forekomst-database. Koblingen overvåker og registrerer deretter eventuelle fremtidige endringer på radnivå i disse dataene. |
| Google Cloud Pub/Sub | Google Pub/Sub er en meldingstjeneste som lar deg publisere og abonnere på strømmer av hendelser. Du kan legge til Google Pub/Sub som en kilde i eventstreamen for å registrere, transformere og rute sanntidshendelser til ulike destinasjoner i Fabric. |
| Amazon Kinesis Data Streams | Amazon Kinesis Data Streams er en massivt skalerbar, svært holdbar datainntak og behandlingstjeneste optimalisert for streaming av data. Ved å integrere Amazon Kinesis Data Streams som en kilde i hendelsesstrømmen, kan du sømløst behandle sanntids datastrømmer før du dirigerer dem til flere destinasjoner i Fabric. |
| Confluent Cloud Kafka | Confluent Cloud Kafka er en strømmeplattform som tilbyr kraftige datastrømmings- og behandlingsfunksjonaliteter ved hjelp av Apache Kafka. Ved å integrere Confluent Cloud Kafka som en kilde i hendelsesstrømmen, kan du sømløst behandle sanntids datastrømmer før du ruter dem til flere destinasjoner i Fabric. |
| Amazon MSK Kafka | Amazon MSK Kafka er en fullstendig administrert Kafka-tjeneste som forenkler oppsettet, skaleringen og ledelsen. Ved å integrere Amazon MSK Kafka som en kilde i eventstreamen, kan du sømløst ta med sanntidshendelser fra MSK Kafka og behandle dem før du ruter dem til flere destinasjoner i Fabric. |
| Eksempeldata | Du kan velge sykler, gul taxi eller børshendelser som en eksempeldatakilde for å teste datainntaket mens du konfigurerer en hendelsesstrøm. |
| Egendefinert endepunkt (det vil eksempel: Egendefinert app i standardfunksjonalitet) | Med den egendefinerte endepunktfunksjonen kan programmene eller Kafka-klientene koble til Eventstream ved hjelp av en tilkoblingsstreng, noe som muliggjør jevn inntak av strømming av data i Eventstream. |
| Azure Service Bus (forhåndsversjon) | Du kan innta data fra en Azure Service Bus-kø eller et emneabonnement i Microsoft Fabric ved hjelp av Eventstream. |
| Apache Kafka (forhåndsversjon) | Apache Kafka er en åpen kildekode, distribuert plattform for bygging av skalerbare datasystemer i sanntid. Ved å integrere Apache Kafka som en kilde i eventstreamen, kan du sømløst ta med hendelser i sanntid fra Apache Kafka og behandle dem før du dirigerer dem til flere destinasjoner i Fabric. |
| Azure Blob Storage-hendelser (forhåndsversjon) | Azure Blob Storage-hendelser utløses når en klient oppretter, erstatter eller sletter en blob. Koblingen lar deg koble Blob Storage-hendelser til Fabric-hendelser i Sanntidshub. Du kan konvertere disse hendelsene til kontinuerlige datastrømmer og transformere dem før du distribuerer dem til ulike mål i Fabric. |
| Fabric Workspace Item-hendelser (forhåndsversjon) | Fabric Workspace Item-hendelser er diskrete Fabric-hendelser som oppstår når endringer gjøres i Fabric Workspace. Disse endringene omfatter oppretting, oppdatering eller sletting av et stoffelement. Med Fabric-hendelsesstrømmer kan du fange opp disse Fabric-arbeidsområdehendelsene, transformere dem og rute dem til ulike destinasjoner i Fabric for videre analyse. |
| Fabric OneLake-hendelser (forhåndsversjon) | OneLake-hendelser lar deg abonnere på endringer i filer og mapper i OneLake, og deretter reagere på disse endringene i sanntid. Med Fabric-hendelsesstrømmer kan du fange opp disse OneLake-hendelsene, transformere dem og rute dem til ulike destinasjoner i Fabric for videre analyse. Denne sømløse integreringen av OneLake-hendelser i Fabric-hendelsesstrømmer gir deg større fleksibilitet til å overvåke og analysere aktiviteter i OneLake. |
| Fabric Job-hendelser (forhåndsversjon) | Med jobbhendelser kan du abonnere på endringer som produseres når Fabric kjører en jobb. Du kan for eksempel reagere på endringer når du oppdaterer en semantisk modell, kjører et planlagt datasamlebånd eller kjører en notatblokk. Hver av disse aktivitetene kan generere en tilsvarende jobb, som igjen genererer et sett med tilsvarende jobbhendelser. Med Fabric-hendelsesstrømmer kan du fange opp disse jobbhendelsene, transformere dem og rute dem til ulike destinasjoner i Fabric for videre analyse. Denne sømløse integreringen av jobbhendelser i Fabric-hendelsesstrømmer gir deg større fleksibilitet til å overvåke og analysere aktiviteter i jobben din. |
Merk
Maksimalt antall kilder og mål for én hendelsesstrøm er 11.
Relatert innhold
Forutsetning
Før du begynner, må du fullføre følgende forutsetninger:
- Tilgang til et arbeidsområde i lisensmodus for stoffkapasitet (eller) prøveversjonslisensmodus med bidragsyter eller høyere tillatelser.
- Hvis du vil legge til en Azure Event Hubs eller Azure IoT Hub som hendelsesstrømskilde, må du ha riktig tillatelse til å få tilgang til policynøklene. De må være offentlig tilgjengelige og ikke bak en brannmur eller sikret i et virtuelt nettverk.
Støttede kilder
Stoffhendelsesstrømmer støtter følgende kilder. Bruk koblinger i tabellen til å navigere til artikler som gir mer informasjon om hvordan du legger til bestemte kilder.
| Kilder | Bekrivelse |
|---|---|
| Azure Event Hubs | Hvis du har en Azure-hendelseshub, kan du innta hendelseshubdata i Microsoft Fabric ved hjelp av Eventstream. |
| Azure IoT Hub | Hvis du har en Azure IoT-hub, kan du innta IoT-data i Microsoft Fabric ved hjelp av Eventstream. |
| Eksempeldata | Du kan velge sykler, gul taxi eller børshendelser som en eksempeldatakilde for å teste datainntaket mens du konfigurerer en hendelsesstrøm. |
| Egendefinert app | Med den egendefinerte appfunksjonen kan programmene eller Kafka-klientene koble til Eventstream ved hjelp av en tilkoblingsstreng, noe som muliggjør jevn inntak av strømming av data i Eventstream. |
Merk
Maksimalt antall kilder og mål for én hendelsesstrøm er 11.
Behandle en kilde
Rediger/fjern: Du kan velge en hendelsesstrømskilde for å redigere eller fjerne enten via navigasjonsruten eller lerretet. Når du velger Rediger, åpnes redigeringsruten til høyre for hovedredigeringsprogrammet.
Regenerer nøkkel for en egendefinert app: Hvis du vil generere en ny tilkoblingsnøkkel for programmet på nytt, velger du en av de egendefinerte appkildene på lerretet og velger Regenerer for å få en ny tilkoblingsnøkkel.
