processing different message types in stream analytics

Question

An event stream has a few message types, all json, very different schemas, the system that produces the events provides an AMQP interface The idea is to use event hubs and stream analytics to capture the events to an sql database. Can a single stream analytics job process mutliple message types? If not what would be the alternative?

Answer 1

Hi,

You can create multiple outputs in Stream Analytics. So if you can identify the different message types than split them.
For example:

WITH TMP_Input as(  
    SELECT  
        *   
    FROM  
        [Input]  
    )  
      
  
SELECT   
        *   
INTO          
        [Output1]   
FROM  
        [TMP_Input]  
WHERE  
        Type = 'Type1'  
  
      
  
SELECT   
        *   
INTO          
        [Output2]   
FROM  
        [TMP_Input]  
WHERE  
        Type = 'Type2'