问题标签 [complex-event-processing]

我想在 EPL 查询中为不同用户设置查看权限，如下所示：

我认为上下文会做到这一点，但需要一些帮助来简化事件流和配置上下文。

所以我需要在视图组的基础上创建上下文分区。如

这样所有的计算都可以在它们的基础上进行。如您所见，上下文的分区键不是单属性或双属性，它基本上是一组相同的属性。所以我不能写成

我试图从 WSO CEP 示例中执行示例访问分析。在创建与示例中给出的相同的存储桶后，我收到一个错误并且它没有创建存储桶。任何人都可以帮助解决问题吗？

错误日志：

当我在添加查询表达式中提供查询语法时出现此错误。如果我不给这个，它将创建存储桶。

据我了解，Esper 是使用查询构建的，以区分传入事件中的相关内容和不相关内容。

我正在考虑使用 Esper，但我不确定它是否适合我的场景。

我的场景：

我需要为大量客户跟踪一些事情。我每秒会收到大量事件，每个事件都需要确定某个客户的进度速率。

示例一：假设我卖火柴，因此我卖得很快。所以我一直有很多交易，我想跟踪每个客户购买了多少匹配项。当一位顾客购买了 10 支火柴时，我希望他得到一个免费的火柴盒。所以对于这个简单的例子，我会说，不要使用 Esper。

但是随着这种情况的发展，问题可能是客户应该为他购买的第 10 场比赛获得一个免费盒子，之后每第 3 场他将获得 2 场比赛的奖金。

购买 50 根火柴后，他会得到一个 XL 大小的火柴盒，里面装满了火柴。

依此类推，多个规则相互叠加。

我对 Esper 如何解决它的猜测：

所以，我认为这应该在 Esper 中完成的方式是，在运行时为每个客户创建一个查询。但由于我有 2 000 000 名客户，我售出的每场比赛的查询量都会以极快的速度增长。（也许我误解了埃斯珀的工作原理？）

现在我只被问题困住了......

随着查询的增加，Esper 的性能下降了多少？是否可以让 Esper 在不创建客户特定查询的情况下在客户级别进行计算？

我还听说 Esper 有时缺乏线程和稳定性，有人对此有任何问题吗？

总的来说，我对 Esper 真的很陌生，可能根本不是我想要的。或者，也许我只是误解了 Esper 的用法。:)

感谢您的阅读！

寻找一种使用 Esper (EPL) 语句计算 5 EMA5 和 EMA20 窗口上的指数移动平均线的方法。

我有一个 priceEvent 流（timeStamp、symbol 和 price）进来，我在 5 的滑动窗口上写了一个简单的移动平均 SMA。但是对于 Esper 来说相当新，正在寻找一种方法来计算滑动窗口上的指数移动平均线 (EMA)。

http://www.iexplain.org/ema-how-to-calculate/

如果有人可以帮助我编写抛物线SAR函数，那也会有很大帮助

只能定义类型的元素

如何定义具有复杂类型元素的流。例如

如何创建Person如上定义的流。

是否可以像在 ESPER 中那样根据 Pojo 类定义来定义 Stream？

我想知道 WSO2 CEP/Siddhi 查询是否支持返回多行，如果是的话，如何将这些行中的数据映射到输出 XML？例如，我的事件流有一个字段 statusCode，它可以有值 A/B/CI 想要编写一个查询，它给我过去 5 分钟的状态类型计数，例如 A-10、B-5、C-2.. 在当前查询我使用按状态代码分组来获取状态计数

是否可以在单个 XML 中获取查询结果？即在上述情况下，单个 XML 中的 A、B、C 计数？

谢谢拉吉夫

有没有办法在使用 WSO2 Developer Studio 创建存储桶时为编写 EPL 查询提供一些语法或上下文帮助？WSO2 堆栈之外是否存在任何 EPL 查询编辑器？

WSO2 CEP 或 BAM 如何进行负载平衡？使其处于集群模式（主动-主动）需要哪些配置更改。

发布者如何通过 Thrift 向此集群服务器发送事件，请提供示例。

如果我有一个以 JMS 代理作为主要输入的分布式 CEP 设置。

现在，如果我们告诉我们的客户端应用程序向主题 X 发送事件，这些事件将被分发到 CEP 集群中的每个节点，因为每个节点都将监听同一个主题 X。这会导致结果重复（假设我正在计算某些数据字段，现在由于每个节点都在接收重复数据，如果我有一个 2 节点集群，我的计数是否会是实际值的两倍）

CEP 可以使用 JMS 队列而不是主题吗？这样，哪个节点首先获取事件数据将消耗队列中的消息？WSO2 CEP 是否支持 JMS 队列？

我有以下问题 - 1. WSO2 CEP 是否也可以收听 JMS 队列？如果是，请分享任何文章。2. 如果上游应用程序向主题发布消息并且我们已经分发（2 节点 CEP 设置）CEP 设置，那么两个节点不应该处理此 JMS 消息并处理重复的消息数据吗？