Please me patient with me, I'm a junior developer. I'm working on a project where we're aiming to integrate lots of different LoRaWAN sensors, from multiple vendors. This means we are ingesting many different types of payloads from Azure IoT hub, each with different schemas and measurement types. I want to standardize these different measurements into a single REST API POST request to a cloud service. My project manager wants to use Azure Stream Analytics as a component in this setup, and ingesting messages from IoT Hub and outputting them to the REST API. Incoming sensor messages have different formats and I would need a system to:
Read the sensor ID of the message Lookup the sensor ID in an internal sensor database and match it to a known sensor type. Use the matching decoder to pick out the important parts of the received message Post the important bits of information from the message to a POST request Now to the problem: Is this even doable with the relatively limited query language of Azure Stream Analytics? To me, it sounds like an Azure Function would be a better choice when it comes to these slightly more complex use cases. Or am I misunderstanding the capabilities of the platform completely, and this could be done easily?
I've tried running several SQL commands that could get me closer to a solution, but find myself limited by the "dumbed down" SQL language in ASA.