自定义规则引擎中的esper

Question

我需要使用ESPER实现规则引擎

为此，我必须准备规则查询(如果有任何其他优化方法，请建议)。规则必须是声明的，而且在运行时必须是可修改的。

此外，我还必须创建一个UI来定义规则。

请提出更好和优化的方法来做这件事。。

举个例子：

可以在运行时定义更多的规则。

Answer 1

没有什么可供参考的上下文，但一个简单的解决方案是简单地保持每个订单和每个价格的最新状态，并将每条规则作为引擎订阅来实现。可以使用以下EPL语句初始化引擎：

/* Minimal schema-s */
create schema LiveOrder (user string, orderid string, quantity, double, symbol string);
create schema LivePrice (symbol string, price double);

/* create two windows to store the latest order by orderid, and latest price by symbol */
create window LiveOrders.std:unique(orderid) as select * from LiveOrder;
create window LivePrices.std:unique(symbol) as select * from LivePrice;

/* insert data into the windows when data arrives */
insert into LiveOrders select * from LiveOrder;
insert into LivePrices select * from LivePrice;

在这一点上，您将有所有的订单和价格存储，以便他们可以很容易地“结合”为不同的规则。如果用户在下单并订购数量> 100时需要一个警报，您只需创建以下EPL语句并附加一个侦听器即可发送警报：

select * from LiveOrders where user='U1' and quantity > 100;

若要在任何符号的订购金额超过10000的情况下创建警报，请对此EPL执行相同的操作：

select LiveOrders.symbol as symbol, LiveOrders.quantity*LivePrices as total from LiveOrders
inner join LivePrices on LiveOrders.symbol=LivePrices.symbol
where LiveOrders.quantity*LivePrices > 10000

每当警报不再需要时，您只需删除侦听器并销毁EPL语句。