wso2 - 如何根据事件的一个属性中的值动态创建流？

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

不，这在 Siddhi 是不可能的。在 Siddhi 中，流是预定义的，不能基于事件属性创建。