如何将 Esper CEP 引擎与 DDS 连接

Posted

技术标签:

【中文标题】如何将 Esper CEP 引擎与 DDS 连接【英文标题】:How to connect Esper CEP engine with DDS 【发布时间】:2018-07-11 22:04:56 【问题描述】:

我相信我缺少与 dds 概念相关的内容。我的想法是使用 EsperIO 适配器、数据流或插件将来自 dds 的传入事件插入到 esper 引擎中,但我看不清楚。

有人帮忙!! (提前致谢)

【问题讨论】:

【参考方案1】:

一步一步是 1) 从 DDS 即 Java DataReader 接收事件数据 2)构建一个Esper可以理解的事件对象;例如,为此使用 JavaBean 样式的类 3) 将事件对象发送到 Esper

无需构建适配器或使用 EsperIO。将事件输入 Esper 的 API 非常简单。有关 API 代码,请参阅 http://www.espertech.com/esper/longer-case-study/ 或 Esper 文档。

【讨论】:

非常感谢,我将尝试您的解决方案并评论反馈。 这是每个人的。有没有例子实现?? 示例是您可以下载的 Esper zip 或 jar 文件的一部分 非常感谢,我们将为此目的开发一个 Java API。

以上是关于如何将 Esper CEP 引擎与 DDS 连接的主要内容,如果未能解决你的问题,请参考以下文章

风控系统之CEP - Esper还是Flink?

springboot中使用esper入门

esper 事件引擎,各种事件类型示例代码

使用 CEP 引擎时通常如何执行权利?

大数据计算引擎之Flink Flink CEP复杂事件编程

Flink/CEP/规则引擎/风控