WSO2SP:处理不同计算的正确方法是什么？

Question

想象一下，许多不同的传感器可以发送值。有一个后端，可以根据传感器ids和值输入不同的计算。这些计算被转换为siddhi应用程序，并部署在siddhi主机上。

为每一次计算创建自己的应用程序的方法正确吗？

示例

from a=SpeedStream[a.id == "s1"], b=SpeedStream[b.id == "s1"]
select b.speed-a.speed as acceleration
insert into AccelerationStream

可能会多次部署相同的计算，其中只有a.id和b.id不同。

这个方法正确吗？

Answer 1

将用例划分为多个siddhi应用程序将有助于维护性。它有时会导致多次部署相同的查询，这很好。

虽然我建议在管道开始时设置过滤器，只过滤需要处理的事件，以提高效率。

from SpeedStream[id == "s1"] 
select *
insert into FilteredSpeedStream;

现在，FilteredSpeedStream可以在以后的查询中使用，如果没有过滤器，FilteredSpeedStream将只包含一种传感器类型的事件，从而提高管道的效率。