wso2 - 如何将事件插入 http sink 彼此分开？

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长度批处理窗口，

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

   from DataStreamTemp 
   select f_id
   insert into OutputToHttpEndpoint ;