自定义规则引擎中的esper

Question

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;

在这一点上，您将存储所有订单和价格，因此它们可以很容易地根据不同的规则“合并”。如果用户在按数量下单时需要发出警报

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语句。