Delen via


Gegevensstromen routeren op basis van inhoud in Fabric-gebeurtenisstromen

In dit artikel leest u hoe u gebeurtenissen routeert op basis van inhoud in Microsoft Fabric-gebeurtenisstromen.

U kunt nu de editor zonder code in het hoofdcanvas van fabric-gebeurtenisstromen gebruiken om complexe logica voor stroomverwerking te maken zonder code te schrijven. Met deze functie kunt u uw gegevensstromen eenvoudiger aanpassen, transformeren en beheren. Nadat u uw stroomverwerkingsbewerkingen hebt ingesteld, kunt u uw gegevensstromen probleemloos naar verschillende bestemmingen verzenden op basis van het specifieke schema en gegevens streamen.

Ondersteunde bewerkingen

Hier volgt de lijst met bewerkingen die worden ondersteund voor realtime gegevensverwerking:

  • Aggregaties: Ondersteuning voor SOM-, AVG-, MIN- en MAX-functies waarmee berekeningen worden uitgevoerd op een kolom met waarden, waardoor één resultaat wordt geretourneerd.

  • Uitvouwen: Vouw een matrixwaarde uit en maak een nieuwe rij voor elke waarde in een matrix.

  • Filter: Selecteer of filter specifieke rijen uit de gegevensstroom op basis van een voorwaarde.

  • Groeperen op: alle gebeurtenisgegevens samenvoegen binnen een bepaald tijdvenster, met de optie om een of meer kolommen te groeperen.

  • Velden beheren: gegevenstype van een veld of kolom van uw gegevensstromen toevoegen, verwijderen of wijzigen.

  • Samenvoeging: Verbind twee of meer gegevensstromen met gedeelde velden met dezelfde naam en hetzelfde gegevenstype in één gegevensstroom. Velden die niet overeenkomen, worden verwijderd.

  • Join: Gegevens uit twee streams combineren op basis van een overeenkomende voorwaarde ertussen.

Ondersteunde bestemmingen

De ondersteunde bestemmingen zijn:

  • Lakehouse: Deze bestemming biedt u de mogelijkheid om uw realtime gebeurtenissen te transformeren voordat ze in uw lakehouse worden opgenomen. Realtime gebeurtenissen worden omgezet in Delta Lake-indeling en worden vervolgens opgeslagen in de aangewezen lakehouse-tabellen. Deze bestemming helpt bij scenario's voor datawarehousing.

  • Eventhouse: met deze bestemming kunt u uw realtime gebeurtenisgegevens opnemen in Eventhouse, waar u de krachtige Kusto Query Language (KQL) kunt gebruiken om query's uit te voeren en de gegevens te analyseren. Met de gegevens in Eventhouse krijgt u meer inzicht in uw gebeurtenisgegevens en kunt u uitgebreide rapporten en dashboards maken.

  • Fabric Activator: Met deze bestemming kunt u uw realtime gebeurtenisgegevens rechtstreeks verbinden met een Fabric Activator. Activator is een type intelligente agent die alle informatie bevat die nodig is om verbinding te maken met gegevens, voorwaarden te bewaken en actie te ondernemen. Wanneer de gegevens bepaalde drempelwaarden bereiken of overeenkomen met andere patronen, neemt Activator automatisch de juiste actie, zoals het waarschuwen van gebruikers of het starten van Power Automate-werkstromen.

  • Aangepast eindpunt (voormalige aangepaste app): Met deze bestemming kunt u eenvoudig uw realtimegebeurtenissen doorsturen naar een aangepaste toepassing. Met deze bestemming kunt u uw eigen toepassingen verbinden met de eventstream en de gebeurtenisgegevens in realtime gebruiken. Het is handig als u realtime gegevens naar een extern systeem buiten Microsoft Fabric wilt uitgaan.

  • Stream: Deze bestemming vertegenwoordigt de standaard onbewerkte gebeurtenisstroom die wordt getransformeerd door een reeks bewerkingen, ook wel een afgeleide stroom genoemd. Zodra u de stroom hebt gemaakt, kunt u de stream bekijken vanuit de realtime-hub.

In het volgende voorbeeld ziet u hoe drie afzonderlijke Fabric-gebeurtenisstreambestemmingen afzonderlijke functies kunnen leveren voor één gegevensstroombron. Eén Eventhouse is aangewezen voor het opslaan van onbewerkte gegevens, een tweede Eventhouse is voor het behouden van gefilterde gegevensstromen en het Lakehouse wordt gebruikt voor het opslaan van geaggregeerde waarden.

Een schermopname van routeringsevenementen op basis van inhoud.

Als u uw gegevensstroom wilt transformeren en routeren op basis van inhoud, volgt u de stappen bij Een gebeurtenisstroom bewerken en publiceren en beginnen met het ontwerpen van stroomverwerkingslogica voor uw gegevensstroom.