How to route Event Hub messages to different Azure functions based on their message type
I have an Azure Event Hub over which I would like to send various types of messages. Each message should be handled by a separate Azure Function, based on their message type. What is the best way to accomplish this?
Actually, I could create some JSON container with a type and payload property and let one parent Azure Function dispatch all the messages payloads - based on their type - to other functions, but that feels a bit hacky.
This question basically asks the same - however it is answered how it can be done using the IoT Hub and message routing. In the Event Hub configuration I cannot find any setting to configure message routing though.
Or should I switch to an Azure Message Queue to get this functionality?
I ended up using Azure Durable Functions using the Fan Out/Fan In pattern.
In this approach, all events are handled by a single Orchestrator Function which in fact is a Durable Azure Function (F1). This deserializes incoming JSON to the correct DTO. Based on the content of the DTO, a corresponding activity function (F2) is invoked which processes it.
- Filter specific items that are alone in an array of Collection String in Azure Search
- Azure Autoscaling Duration Time and Cool Down Time
- Partition Key for Cosmos DB
- How to extract TLS 1.X of all app services/web app running Azure
- VSTS Build Pipeline: Test fails connecting to Azure Key Vault
- How to Get BootStrapper.exe work in Windows Azure?
- Why Can't I See Roles Assigned to an App Registration in Azure?
- Email errors from all activities in ADF at once
- How can I ensure that Azure Text-to-Speech properly pronounces word-for-word translations?
- NGINX + Cloudflare SSL Certificate is not valid
- What the proper way to store PAT from azure registry for UV?
- Display Image stored in a sharepoint Site, on a pdf that i want to export
- Deploy Azure Initiative (set definition) with Azure PowerSHell
- Where can I find docker container logs for Azure App Service
- Variables and Parameters in Azure Data Factory?
- Secret scoped role definition and assignment using bicep
- How to get the count of files inside a certain folder of container in Azure Blob storage in C#
- Getting Error while trying to do Terraform Import of Azure Disk Encryption Sets
- Error on calling Azure Get blobs zip API, parameter blobsID
- Azure Queue Trigger is hit but not executing the logic inside of it
- trying to find out week of year in kql
- Data Factory to Snowflake copy task Fails with Failed to open the database error
- How to create BAK file from azure sql db
- Specifying user-assigned managed identity in Azure Function Terraform script
- Azure SQL Server Auditing EventHub Bicep
- BlobServiceClient singleton?
- Azure Devops Apple App Store Release.Missing value for the attribute 'whatsNew'
- How to use environment variables in React app hosted in Azure
- Azure function python app - getting nested environments variables
- Managed Identity Authentication for Azure AI Speech - WebSocket upgrade failed: Authentication error (401)