问题标签 [esper]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
events - 埃斯珀对珊瑚8。. .事件流处理
有没有人做过比较coral8和esper的事件流处理分析?
licensing - 埃斯珀的替代品?
我对复杂事件处理非常感兴趣,并且一直在关注 Esper。但是,我的公司有反 GPL 的立场,我想知道在 Apache 或 BSD 等更商业友好的许可下是否有非 GPL 替代方案?
oracle - 从哪个 CEP 产品开始?
我想了解有关如何构建基于 CEP 的应用程序的更多信息。所以我环顾四周,发现了几个产品(在这里找到概述:http ://rulecore.com/CEPblog/?page_id=47 )。
但由于目前有很多,我不知道哪个是最好的开始。总的来说,我只会考虑免费提供的那个。其余的对于私人使用来说有点贵;)
Esper 是免费的,但是没有 Esper 工作室,开发一个 cep 应用程序似乎很乏味。Streambase 提供免费试用,但我不知道您可以使用多长时间(如果只有一个月,对更长时间的研究没有帮助)。Oracle CEP 套件似乎相当完整,但在 cep 场景中——据我所知——与 Esper 或 Streambase 相比,它是最不被认可的。
那么您对开始 cep 开发的最佳方式有什么提示吗?花时间研究 oracle 文档是否值得,还是从 Esper 或 Streambase 开始更好?
干杯,
安德烈亚斯
cloud - 埃斯珀和 SQS
我想知道这里是否有人尝试过使用 Esper 来处理来自云端的东西?特别是亚马逊的简单排队服务。我已经用谷歌搜索了这个,我们知道这是可行的,但是很高兴知道是否有人尝试过。更好的是,有人也尝试过将 Esper 放入云端吗?
esper - 在 Esper 中强制输出
我有一个非实时的 Esper 配置,我在其中提供从文件中读取的流。我正在尝试创建一个表达式来计算整个流的统计数据并在最后输出一个值。例如,Esper 具有强制视图每 X 秒输出一次的语义,但是当您知道没有更多事件要提供时,是否有一种语义可以要求视图或引擎“刷新”输出。
jms - Esper 通过 JMS 示例
在模糊的问题部门中,有没有人都使用带有 JMS 的 Esper 作为输入适配器?如果是这样,那里有任何示例代码吗?
spring - ETL、Esper 还是 Drools?
题环境涉及JavaEE、Spring
我正在开发一个可以为传入消息启动和停止任意 TCP(或其他)侦听器的系统。可能需要对这些消息进行身份验证。这些消息需要解析并存储在其他一些实体中。这些实体对它们存储的字段进行建模。
因此,例如,如果我的 property1 可以有两个文本字段 FillLevel1 和 FillLevel2,我可以在 TCP 上接收消息,其中两个填充级别在文本中指定为 F1=100;F2=90
稍后当我开始接收消息 F1=xx;F2=xx;F3=xx 时,我可以添加另一个字段,例如 FillLevel3。但这是系统建模者有意识的决定。
我的问题是您认为什么更好用于解析和存储消息。ETL(使用 Pantaho,在其他系统中使用)在其中存储原始消息并使用任务执行器一一使用它们并根据您的规则存储转换后的消息。
可以使用 Espr 或 Drools 来做同样的事情,存储规则并使用计时器执行它们,但我不确定通过制定规则可以获得多大的动态(它们必须由最终用户在正在运行的系统中制定,最好是在大多数情况下)用户友好的方式,即没有脚本或代码,只有 GUI)
最终用户应该能够更改解析规则。最终用户也可能希望更改存档数据(例如,在上面的示例中,如果添加了新的 FillLevel 值,则希望将 FillLevel=-99 放在以前的值中以生成数据持续的)。
请大家多多指教,我感觉这个问题需要稍微修改一下。
谢谢
esper - Esper (CEP) 查询每整分钟计算一次烛台
我正在使用复杂事件处理 (Esper) 技术在我的系统中提供实时烛台计算。我在计算值方面做得很好,但是我发现很难确保蜡烛窗口从整分钟开始(对于一分钟蜡烛)并在下一分钟开始之前结束(即蜡烛 1[06:00.000 - 06:00.999],蜡烛2[06:01.000 - 06:01.999] 等...)。
Esper 的查询语言中是否有能够提供此类功能的模式或命令?
我会很感激建设性的意见和指导。
java - 使用 Esper,我如何执行事件的动态过滤?
我是在 Java 中使用 Esper 事件流引擎的新手。场景是事件以 POJO 的形式出现。他们有一个我想过滤的字段。过滤后的值会随着时间而改变。我宁愿不要在每次发生更改时删除并插入新语句。
例子:
事件名为“ MyEvent ”,并具有字段“ source ”。值可以是“家”、“工作”或“学校”之一。Web 服务允许用户更改他们感兴趣的“源”的值。EPL 语句看起来像
所以在任何时候,“学校”都可能被取消,影响必须尽快体现出来。问题是,如何最好地做到这一点?由于更新生效之间的延迟,我已经排除了缓存的数据库调用。
想法是:
1) 有一个名为 'SourcesOfInterest' 的流,其类型为 List 的 'sources' 字段,并将语句更改为:
Web 服务将“SourcesOfInterest”事件插入此流,其中仅查看最近的事件。甚至不确定语法是否正确。
2) 让语句引用运行时变量。那么声明将是:
Web 服务将调用
还有其他选择吗?这些中的任何一个的性能问题?
java - 如何在 Jython 解释器中将 Jython 类转换为 Java 类?
我正在尝试使用 Esper API 注册用户定义的函数。它需要一个类或字符串类型的争论
错误信息
我可以通过
@larsmans:类似乎只存在于 Java Class 类中