wso2 - WSO2 SP：从流构造 JSON 对象

Question

我正在尝试使用以下代码从 JSON 数据流生成 JSON 对象：

@sink(type='log')
define stream TempStream(designation object);

from TestStream
select json:setElement("{}", "$", json:getString(json,"$.DESIGNATION"), "designation") as designation
insert into TempStream;

但是输出数据具有空值。请问代码有问题吗？

TempStream : Event{timestamp=1554192487415, data=[null], isExpired=false} 

具有数据传递的输入流如下：

TestStream : Event{timestamp=1554192487415, data=[{"STATUS":"AA","CREATED_DATE":"2010-11-23 10:24:36","DESIGNATION":"Manager"}], isExpired=false}

Answer 1

我在 SP 4.3.0 包上对此进行了检查，并且能够得到以下结果

 SiddhiApp : TempStream : Event{timestamp=1554733451717, data=[{designation=Manager}], isExpired=false}

我在发送到“ TestStream ”的事件中使用的查询如下，

@sink(type='log',"TEMPSTREAM")
define stream TempStream(designation object);

@sink(type='log')
define stream TestStream(json string);

from TestStream
select json:setElement("{}", "$", json:getString(json,"$.DESIGNATION"), "designation") as designation
insert into TempStream;

SiddhiApp : TestStream : Event{timestamp=1554733451717, data=[{ "STATUS": "AA", "CREATED_DATE": "2010-11-23 10:24:36", "DESIGNATION": "Manager" } ], isExpired=false}

我相信这是您所期望的结果。