Oplossingsidee
Als u wilt dat we dit artikel uitbreiden met meer informatie, zoals mogelijke use cases, alternatieve services, implementatieoverwegingen of prijsinformatie, laat het ons dan weten met GitHub Feedback!
Dit oplossingsidee toont een variant van een serverloze gebeurtenisgestuurde architectuur met behulp van Azure Event Hubs en Azure Functions om een gegevensstroom op te nemen en te verwerken. Zodra de batch is verwijderd en gefilterd, worden de resultaten naar een database geschreven voor opslag en toekomstige beoordeling.
Raadpleeg de referentiearchitectuur serverloze gebeurtenisverwerking voor meer informatie over de basisconcepten, overwegingen en benaderingen voor serverloze gebeurtenisverwerking.
Potentiële gebruikscases
Een veelgebruikte use-case voor het implementeren van een end-to-end verwerkingspatroon voor gebeurtenisstroom omvat de Event Hubs streaming-opnameservice voor het ontvangen en verwerken van gebeurtenissen per seconde met behulp van een ontbatchverwerkings- en transformatielogica die is geïmplementeerd met uiterst schaalbare, door Event Hub–geactiveerde functies.
Architectuur
- Gebeurtenissen komen aan bij de Event Hub Input.
- De Azure-functie Voor het debatcheren en filteren wordt geactiveerd om de gebeurtenis te verwerken. Met deze stap worden ongewenste gebeurtenissen gefilterd en worden de ontvangen gebeurtenissen gedebatched voordat ze naar de Output Event Hub worden verzenden.
- Als de Azure-functie voor het verwijderen van batches en filteren de gebeurtenis niet kan opslaan, wordt de gebeurtenis verzonden naar De Deadletter Event Hub 1.
- Gebeurtenissen die aankomen bij de Event Hub voor uitvoer activeren de Azure-functie transformeren. Met deze Azure-functie wordt de gebeurtenis omgezet in een bericht voor de Cosmos DB.
- De gebeurtenis wordt opgeslagen in een Cosmos DB database.
- Als de gebeurtenis niet kan worden opgeslagen met de Functie transformeren van Azure, wordt de gebeurtenis opgeslagen in Deadletter Event Hub 2.
Onderdelen
- Event Hubs de gegevensstroom op. Event Hubs is ontworpen voor scenario's voor gegevensstreaming met hoge doorvoer.
- Azure Functions is een serverloze rekenoptie. Er wordt gebruikgemaakt van een gebeurtenisgestuurd model, waarbij een stuk code (een functie ) wordt aangeroepen door een trigger.
- Azure Cosmos DB is een databaseservice met meerdere modellen die beschikbaar is in een serverloze modus op basis van verbruik. Voor dit scenario slaat de functie voor gebeurtenisverwerking JSON-records op met behulp van Cosmos DB SQL API.
Volgende stappen
- Serverloze gebeurtenisverwerking is een referentiearchitectuur met een typische architectuur van dit type, met codevoorbeelden en bespreking van belangrijke overwegingen.
- Bewaking van serverloze gebeurtenisverwerking biedt een overzicht en richtlijnen voor het bewaken van serverloze gebeurtenisgestuurde architecturen zoals deze.
- Azure Kubernetes in de verwerking van gebeurtenisstroom beschrijft een variant van een serverloze gebeurtenisgestuurde architectuur die wordt uitgevoerd op Azure Kubernetes met KEDA-scaler.
- Een Private Link-scenario in de verwerking van gebeurtenisstroom is een oplossingsidee voor het implementeren van een vergelijkbare architectuur in een virtueel netwerk (VNet) met privé-eindpunten om de beveiliging te verbeteren.