如何将事件彼此分开插入到 http 接收器中？

Question

我需要将事件发送到 http 端点。如果我做类似的事情：

from DataStream
 select f_id
insert into OutputToHttpEndpoint ;

我的网络服务中有以下消息： [{f_id:1}, {f_id:2}, ...] 相反，N 请求带有 {f_id:N}.

等预期消息

我找到了解决方案：

from ExtractedDataStream
 select f_id 
 output last every 1 events 
insert into OutputToNodejs ;

对吗？还有其他方法可以解决这个问题吗？

Answer 1

可以使用尺寸 1 的 Siddhi length batch window，

   from DataStream#window.lengthBatch(1)
   select * 
   insert into DataStreamTemp;

   from DataStreamTemp 
   select f_id
   insert into OutputToHttpEndpoint ;

如何将事件彼此分开插入到 http 接收器中？

How Insert events into http sink apart from one another?

wso2

siddhi

wso2sp