Как динамически создавать потоки на основе значений в одном атрибуте события?

Question

Я пытаюсь создать несколько потоков динамически.Например.

{'event_type': 'temperature',
 'users' : ['john', 'gary'],
 'data': {'type': 'temperature', 
 'DeviceID': 'bcd', 'temperature': '45',
 'timestamp': '2019-03-22T12:32:02.208223Z'
         }
} 

Возможные значения для type: ['temperature','geolocation,'pressure'].Желаемый вывод - один поток на пользователя и один поток на комбинацию типа пользователя

The following queries are what we expect (Code that creates the following)

select x,y,z from stream
insert into john

select x,y,z from stream
insert into gary

select x,y,z from stream
insert into john_temperature

select x,y,z from stream
insert into gary_temperature

etc.

1. Возможно ли это сделать в wso2?

Я пытался https://docs.wso2.com/display/SP4xx/Complex+JSON+Processing для сложной обработки json, но синтаксис @source четко не указан.

Answer 1

Нет, это невозможно в Сиддхи.В сиддхи потоки предопределены и не могут быть созданы на основе атрибутов событий.