Как вставлять события в сток 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 можно использовать,

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

   from DataStreamTemp 
   select f_id
   insert into OutputToHttpEndpoint ;