问题标签 [esper]

找了很长时间的解决方案：

我有一个联系表格。每次有人通过它发送邮件时，都会向 Esper 发出一个 ContactEvent(receiver, senderIpAddress)。现在，我希望 Esper 通知我，当一个特定的 IP 地址在 10 分钟内发出超过 50 个联系事件时。

以下代码中的语法错误是由于代码简化

然后我像这样填充它：

最终，有一个事件监听器是这样的：

这实际上有效。这并不完全是我想要的强硬，因为每次发出我的语句侦听器，IP 地址的消息计数都会发生变化。（“IP X 在过去 10 分钟发送了 43 条消息”，“IP X 在过去 10 分钟发送了 44 条消息”，...）我只想得到一个事件告诉我“IP X 超过 50 条消息在最后 10 分钟”，另一个告诉我，它现在已经下降到该边界以下。

有没有办法让它工作？

我读了很多关于 NEsper 的文章并尝试了示例代码。我有一些问题 ：

1. 它是一个事件处理器引擎，它如何获取事件？
2. 它在哪里保存数据？
3. 当它轮询它？
4. 谁来投票？
5. 我下载了一个项目，比如大项目，如果我想使用NEsper我必须使用该项目吗？我必须建立另一个项目？我该如何使用它？

我正在试验 Nesper（Esper 的 .NET 版本）并遇到了一些我无法理解的麻烦。以下简单的 EPL（根据本教程建模）失败并出现错误：

我得到的错误是：

我的第一个怀疑是 ID 可能没有在派生自 Observation 类的 SeenEvent 类中正确公开。但我确认在 Observation 类中，属性 ID 被定义为 Public。

这是 EPL 的一个已知问题吗？Nesper 与 Esper（它是 Java 表亲）不同吗？

请好心人给我看一个食谱，我可以从我的 C 程序中调用 Esper 吗？理想情况下（我认为）我想用一行 EDL 调用一个 Esper 函数/方法并返回一个值。

编辑：我问这个问题是因为我有 12,000 行我想保留的工作 C 代码。Esper 提供了一些对我的 C 代码至关重要的非常好的事件评估。JNI 似乎面向从 Java 调用 C 代码，可能是因为 C 在某些方面更快；我想另辟蹊径：从 C 调用 Java 代码以利用 Java 包中的强大功能，这就是所谓的 Esper。

谢谢！

我有一个接收 MSMQ 消息并使用NEsper执行（接近）实时分析的系统。有些消息可能会迟到，并且可能以不同的顺序出现。这种情况应予以标记和报告。不要写这是它的工作方式（元代码）：

如何更好地处理消息“从过去”到达的情况，我不能抛出异常，因为我仍然需要处理消息，但我希望用户了解有关消息的更多详细信息，而不是仅仅说有N错误地接收到消息。我正在考虑做类似 AggregateException 的事情，但不确定它是如何工作的。有任何想法吗？

我想开始学习 ESPER 引擎，我发现酯类原生示例有点复杂。

有没有人有一个很好的简单示例java代码，关于使用esper？

如何重置 esper every-distinct 子表达式？

我有许多具有唯一 ID 的航行报告，我想检测他们何时更改目的地。以下检测到第一个更改，但未检测到后续更改。

id=1，目的地=A

id=1，目的地=B

好的

id=1，目的地=C

没有检测到？

我一直在关注 Esper（和 Storm）的流处理。Esper 似乎完全符合我的要求。即滚动意味着、中位数、复杂查询等......但有一件事让我想知道。

如何使用 Esper 扩展到多个实例？

据我了解，Storm 处理分布式处理，但使用 Esper，您就得靠自己了。

在可预见的未来，我不需要这样做，但随着我们的增长，我们的数据量也会随之增长，然后也需要向外扩展。我们很可能会部署在 Amazon EC2 中。

在将它们发送到我的 Esper 应用程序之前，我是否需要运行多个服务器和分片数据？

有没有更优雅的处理方式？

-萨哈尔

我是 Esper 的新手，我想知道 UpdateListener 的更新方法是否由多个线程同时执行。如果是这种情况，我得出结论，在此方法中写入 HashMap 是不安全的。它是正确的，还是我错过了什么？

提前致谢

我正在尝试使用 NEsper，并且我想创建自插入作为返回字段以来需要时间的语句。

例如：选择 avg((insertTime - now)) 作为 timeElapsed from Blah.win:time(1 min)

这可能吗？我可以破解获取 insertTime 但有 now 功能吗？