问题标签 [nesper]

我有一个简单的问题，我在 stackoverflow 或 ESPERTECH 网站上找不到任何分析器。我的计划是编写一个 ESPER CEP 引擎来检查实时系统中的值。为了检查规则在编辑后是否正确，我在数据库中已经记录了一些测试用例，规则应该明确触发这些用例。所有传感器值都在一个看起来像这样的表中：

如果我以这种格式获取事件数据是否有可能：

在 EPL 在线试用中以任何方式将其用作输入流，以便我可以立即使用它并将时间戳用作“esper-time”？我想避免 t.plus(10 seconds) 因为我必须手动添加它。

Hej，有谁知道如果值为 NaN，我如何检查 ESPER？我想得到一些有效的变量的斜率，但第一个值总是 NaN。我想排除该值。 value ='NaN'并且 value = NaN不工作

我正在尝试使用 AMQPSource 并且我收到了下面描述的错误，并且导入在 EPL 模块中也不起作用。事先，我测试了将完整的包名添加到 DistanceEvent （events.DistanceEvent 并且不起作用）。

要发送消息，我正在使用带有下一个有效负载的发布 Rabbitmq webadmin queue 选项：{"distance":33}

有人可以帮我吗？

我正在尝试创建一组 EPL 语句，允许引擎在值超过或不超过阈值时发出警报。另一种理解它的方式就像一个“围栏”或地理围栏。

当值进入或离开该区域时，语句集必须发出警报。例如，下一个 'fence' 值>45 必须仅在值大于 45 或小于或等于 45 时发出警报，但仅在值超过阈值时才会发出警报。

这是一个 I/O 示例。对于具有属性距离且围栏距离>45 的 DistanceEvents。

输入

输出

有人可以帮我吗？

我们正在评估 NEsper。我们的重点是监控企业环境中的数据质量。在一个应用程序中，我们将记录很多字段的每一个变化——例如在一个“订单”中。所以我们有像

• 收货人姓名
• 收货人街道
• 订购日期

....还有更多领域。正如您可以想象的那样，日志文件会变得很大。

因为数据是由不同的客户发送的，并且是在应用程序中导入的，所以我们要分析有多少（以及哪些）字段从“无值”更新为“有值”（仅作为示例）。

我试图用这些字段构建一个测试用例

• 订单参考
• 字段名
• 字段值

对于我的测试用例，我添加了两个带有上下文信息的语句。第一个应该只计算每个订单的一般变化：

第二条语句应该计算从“无值”到“有值”的更新：

要读取测试日志文件，我使用 csvInputAdapter：

我不想使用更新侦听器，因为我只对所有事件的结果感兴趣（可能这是不可能的，这是我的失败）。

因此，在读取 csv（csvInputAdapter.Start() 返回）后，我读取了所有事件，这些事件存储在语句 NewEvents-Stream 中。

在 CSV 文件中使用 10 个条目一切正常。使用 100 万行需要很长的时间。我尝试不使用 EPL-Statement（所以只是导入 CSV）——大约需要 5 秒。对于第一个语句（不是复杂模式语句），我总是在 20 分钟后停止 - 所以我不确定需要多长时间。

然后我更改了第一条语句的 EPL：我引入了一个 group by 而不是 context。

现在它真的很快 - 但在 CSVInputAdapter 回来后我的 NewEvents Stream 中没有任何结果......

我的问题：

1. 我想使用 NEsper 的方式是受支持的用例，还是我失败的根本原因？

2. 如果这是一个有效的用例：我的错误在哪里？如何以高效的方式获得我想要的结果？

3. 当使用“group by”而不是“context”时，为什么我的 EPL 语句中没有 NewEvents？

我有一个返回多行的 Esper 查询，但我想获得一行，其中该行有一个列表（或连接字符串），其中包含我当前匹配的行（的对应列）中的所有值查询返回。

例如：

回报：

我真正想要的是：

这可以通过查询本身来完成吗？我尝试使用子查询来完成这项工作，但我没有使用多个流。我在 Esper 文档中也找不到任何符合我想要做的事情的聚合函数或枚举函数。

感谢任何对我有任何见解或方向的人。

编辑：如果这不能通过查询来完成，我愿意改变订阅者，或者如果需要的话。

当我以这种方式将默认事件表示更改为 Object 数组时，我遇到了一个错误：

我的事件定义采用创建模式的方式。epl 文件已成功部署，但是当我插入一个新的 Object[] 事件时，会出现一个错误，提示此事件名称没有事件定义。

如果需要更多详细信息，请询问。

我已经阅读了 Java 文档。不幸的是，Java API 和 C# API 完全不同。

我正在尝试为 Nesper CEP 框架实现一个 CSV 适配器。

提前致谢！

是否有任何示例代码或配置文件可用于 dockerizing esper 应用程序？

是否可以在内核 ARM Cortex M4 120 MHz 的微控制器 LPC4088 中运行 Esper CEP？

我想知道是否可以在 JVM 下或使用 Nesper for .NET

太感谢了