Orion Contex Broker as a data source in Eventstream, is possible?

[JuanMahecha]

Hello, good day.
I have the following question:
I want to connect an eventstream as a data source to FIWARE's Orion Context Broker, since I want to bring the real-time data from there, I only see the option of doing it through the custom endpoint but Orion uses the HTTP protocol, and I don't know how or even if I can make this connection because it seems that the endpoints offered by the eventstream do not handle that protocol, has anyone done something similar, REST API could work and how?
If it is not possible, what option do I have to make this connection? how to use a bridge, such as Azure IoT but I don't know if it is possible to make the connection.

Thank you very much, I appreciate any support.

[v-veshwara-msft · Accepted solution]

Hi @JuanMahecha ,

Thank you for your question on integrating FIWARE Orion Context Broker with Microsoft Fabric Eventstream.

Currently, Fabric Eventstream supports input from sources like Azure Event Hub, Azure IoT Hub, Kafka, and custom HTTPS endpoints that follow specific schemas. Since Orion Context Broker primarily sends notifications using HTTP/REST in NGSI-v2 or NGSI-LD format, it doesn’t natively integrate with Eventstream’s required schema or input protocols.

Recommended Approach : Using a Bridge to Azure Event Hub
A proven method to achieve this integration is by introducing a lightweight middleware service that acts as a bridge between Orion and Eventstream.

We recommend reviewing the following open-source project:
GitHub - JMayrbaeurl/fiware-azure-eventhub-publisher: Sample showing FIWARE Context broker notificat...

This solution uses a Spring Boot REST microservice to:

    1. Receive NGSI notifications from Orion Context Broker

    2. Transform and publish the data to a configured Azure Event Hub

    3. From there, you can easily ingest the data into Microsoft Fabric Eventstream by configuring Event Hub as a         source.

This pattern maintains near real-time ingestion and is highly extensible.

Hope this helps. Please reach out for further assistance.
If this post helps, then please consider Accept it as the solution to help the other members find it more quickly and a kudos would be appreciated.

Thank you.

[JuanMahecha]

Muchas gracias, revisaré el proyecto y en caso de dudas volveré aquí, que tengas un buen día