Esper / NEsper EPL语句
Esper是一种高性能、开源的复杂事件处理（CEP）引擎，而NEsper是其针对.NET平台的版本。它们都支持EPL（Event Processing Language）语句，用于描述和处理实时数据流中的复杂事件。
EPL语句是Esper / NEsper中的核心概念，它允许用户定义一系列规则和条件来过滤和处理实时数据流。下面是对EPL语句的详细说明：
概念： EPL语句（Event Processing Language）是Esper / NEsper中用于定义和处理复杂事件的一种查询语言。它允许用户以声明式的方式描述事件的关系和模式，并通过EPL引擎实时地从事件流中匹配和处理符合条件的事件。
分类： EPL语句可以分为两类：查询语句和模式语句。
- 查询语句：用于从实时事件流中过滤、聚合和选择符合特定条件的事件。例如，可以使用查询语句计算某个时间窗口内的平均值或总和。
- 模式语句：用于描述和匹配一系列事件的模式。例如，可以使用模式语句定义一个由多个事件组成的序列，然后在实时数据流中查找匹配该序列的事件。
优势：
- 实时性能：Esper / NEsper的EPL引擎具有卓越的实时处理性能，可以快速地从大规模的事件流中提取有价值的信息。
- 灵活性：EPL语句提供了丰富的语法和功能，使用户能够根据不同的业务需求灵活地定义和处理复杂事件。
- 可扩展性：Esper / NEsper提供了丰富的API和扩展点，允许用户根据需要自定义各种功能和扩展。
应用场景：
- 金融领域：Esper / NEsper的EPL语句可以用于实时监测和分析金融市场中的交易数据，快速识别潜在的风险和机会。
- 物联网：EPL语句可以用于实时处理物联网设备生成的海量数据，例如监测传感器数据、智能家居、智能工厂等。
- 电信领域：Esper / NEsper的EPL引擎可以用于实时分析和处理电信网络中的大量信令和事件，例如实时识别异常通信行为、网络故障等。
- 电子商务：EPL语句可以用于实时监测和分析电子商务平台上的用户行为和交易数据，快速响应用户需求并做出个性化推荐。
推荐的腾讯云相关产品和产品介绍链接地址： 由于要求不能提及具体的云计算品牌商，这里不提供具体的链接地址。然而，腾讯云和其他云计算品牌商一样，也提供了一系列与复杂事件处理相关的产品和服务，包括实时计算、数据湖、流式数据处理等，您可以在腾讯云官方网站中查询相关产品和详细介绍。
相关·内容
目前，我在Java环境中使用Esper8来使用CEP。最近，我问自己是否有可能在运行时更改EPL语句。例如，如果您有一个使用EPL语句运行的Esper CEP，并且您希望在不中断CEP运行时的情况下更改此EPL语句。因此，使用新的EPL语句或相同语句的SQL查询每隔x分钟更新一次EPL语句。这是可能的吗?或者每次更改EPL语句时，我都必须中断Java运行时，更改EPL语句并重新启动CEP吗？也许这个问题听起来很愚蠢，但我对Esper CEP还知之甚少。 提前感谢
浏览 22提问于2019-01-06得票数 0
回答已采纳
在使用Esper时，我得到了这个错误。
可能的原因是什么？
2017-02-05 15:51:59,781 [...] ERROR com.espertech.esper.core.service.ExceptionHandlingService - Exception encountered processing statement '...' statement text 'INSERT INTO Window
SELECT *
FROM TableWithJoins
WHERE test=3
ORDER BY (Math.abs(
浏览 18提问于2017-07-06得票数 0
1回答
我想用下面的语法触发一个模式。
EPStatement raiseStmt = cepAdm.createEPL("[1] Event");
但是我得到了下面的例外
Exception in thread "main" com.espertech.esper.client.EPStatementSyntaxException: Incorrect syntax near '[' [[1] Event]
at com.espertech.esper.epl.parse.ExceptionConvertor.convertStatement(
浏览 1提问于2014-06-24得票数 0
回答已采纳
在Esper版本5中，我们使用以下代码注册EPL语句并添加监听器-
final EPStatement statement = admin.createEPL(epl, subsc.getId().toString(), subsc);
statement.addListener(createListenerAdapter(listenerCallback));
根据版本8()中的Esper文档，我们可以编写实用方法compileDeploy()来注册epl语句，如下所示--
public EPDeployment compileDeploy(EPRuntime runtime, final
浏览 7提问于2020-06-04得票数 0
回答已采纳
1回答
我正在尝试将订阅者附加到Esper中的事件，但我想为此使用.epl文件。我一直在浏览存储库，我看到了通过使用注释接口来实现这一点的例子。我试着用他们在CoinTrader中做这件事的方式来做，但我似乎无法让它起作用。但是，如果我用Java设置订阅服务器，它就能工作。
这是我的.epl文件：
module queries;
import events.*;
import configDemo.*;
import annotations.*;
create schema MyTickEvent as TickEvent;
@Name('allEvents')
@Descri
浏览 6提问于2017-12-26得票数 0
回答已采纳
1回答
我是Esper的新手。有人能帮助我定义EPL语句，以便在发生以下情况时捕捉事件：
之和:有三个属性-(字符串)符号、(布尔值)值、(日期时间)时间戳的事件。例如，event1 (符号-苹果，值-真，时间戳- 2020.10.07 14:00)，event2 (符号-橙色，值-真，时间戳- 2020.10.07 14:00)和event3 (符号-香蕉，值-假，时间戳- 2020.10.07 14:00)。如果它们具有相同的时间戳(或几乎相同的时间戳)，那么只有一个时间戳的属性值为true。在本例中，event2匹配需求，应该被捕获。
我如何定义语句来捕获它？
谢谢你的帮助。
纳苏
浏览 2提问于2020-10-07得票数 0
1回答
我是新使用esper的。我对esper epl不太了解，所以我有麻烦了。
问题是这个。
用户定义值部分。
For Example,
Level1 : 1~3
Level2 : 4~6
Level3 : 7~9
因此，当数据第一次出现时，请检查该部分并创建事件。但是以前的值和新的值是相同的级别，不做任何(ex. prev value=1, next value=2 These are in same Level1)。
换句话说，当数据出现时，检查前面的值和级别。如果他们有不同的水平，做点什么。
Epl能做到吗？我怎么能做到呢？
浏览 1提问于2016-04-19得票数 0
回答已采纳
1回答
处理本地时间的EPL语句在Esper中不起作用。我使用的是版本5.3.0。我似乎没有时间去做正确的事情。
timer:within(1 sec)
我在让计时器正常工作时遇到了问题。我将and语句附加到EPL语句和EPL语句函数中，而不考虑timer:within(1 sec)。
浏览 10提问于2018-08-07得票数 0
回答已采纳
我知道您可以使用Esper的语句对象模型使用CreateExpressionClause和ExpressionDeclaration创建全局表达式，但我不确定在为模式构建EPStatementObjectModel时如何引用它们的别名。例如，假设我有这样的模式：
every (a=Event(fizz = 3 and buzz = 5) -> b=Event(fizz = 3 and buzz = 5 and foo = 1 and bar = 2))
我想将fizz = 3 and buzz = 5声明为全局表达式：
create expression fizzbuzz alias f
浏览 1提问于2015-09-24得票数 0
回答已采纳
EPL如下：
select * from EventObject(name='abc')#win(2 min) e1 inner join EventObject(name='bcd')#win(2 min) e2 on e1.length > e2.length
但是，有一个错误：
Exception in thread "main" com.espertech.esper.client.EPStatementSyntaxException: Incorrect syntax near '>' expectin
浏览 0提问于2020-04-18得票数 0
我是esper的新手，我想把数据存储在tbl_config中。下面是一些esper配置文件：
config.epl
module rms.config;
create table tbl_config(
id java.math.BigDecimal primary key,
time java.math.BigDecimal
);
create schema ConfigListEvent as (
id java.math.BigDecimal,
浏览 0提问于2016-03-22得票数 1
我正在使用Esper5.0，需要对关系数据库中的数据执行查询。在我的例子中，这是一个通过JDBC连接的MySQL数据库。现在，我想对数据库中的数据制定一个EPL查询。因此，我的查询类似于这个查询：
String parameter = "any"; // untrusted (!) parameter from some user input
String mySqlQuery = "SELECT `sth` FROM `mytable` WHERE `att` = " + parameter;
String query = "select sth fr
浏览 0提问于2014-08-12得票数 0
嗨，Esper专业人士！
有没有办法/或解决办法，让我强制Esper依赖于某个脚本引擎(比如Mozilla Rhino)来处理所有的表达式？
首先，我知道我们可以配置Esper的默认方言。例如，如果我们将默认脚本引擎配置为rhino，如config.getEngineDefaults().getScripts().setDefaultDialect("rhino");
像concat(str) [ str + "sth"];这样的表达式将由Rhino执行。
不幸的是，如果我们想强制Esper使用某种脚本语言，设置默认方言是不够的。原因是Esper允许脚本方言与
浏览 15提问于2017-07-03得票数 0
经过无数次的尝试和搜索，如何在esper中使用模块并跨多个epl文件分发epl语句？
例如，有两个文件：
// events.epl
module events;
create schema OrderExample as (symbol string);
和
//example.epl
module tally;
uses events;
Select * from OrderExample;
通过以下方式组合这些模块：
EPCompiler compiler = EPCompilerProvider.getCompiler();
List&l
浏览 10提问于2022-08-18得票数 0
回答已采纳
我是Esper的新手，开始使用EPL Online进行测试。当我创建一个命名窗口并将事件插入其中时，我从两个语句中得到了重复的输出。例如：
将窗口OrdersNamedWindow.win:keepall()创建为OrderMapEventType；
insert into OrdersNamedWindow select * from OrderMapEventType
有没有办法对这两个语句的输出进行重复数据消除？提前感谢！
浏览 22提问于2016-07-26得票数 0
回答已采纳
我正在从事的项目使用Esper创建监控规则。这些规则可以是活动的，也可以是非活动的，具体取决于SQL行中的布尔值。我想设置一个检查，看看是否有任何新的活动规则，从创建一条语句，并将它们添加到hashmap中。这将使用Spring调度器定期运行。到目前为止，代码如下所示：
private void refreshStatement(Rule rule) throws Expression {
List<String> allRules = dao.getAllRules();
for (String rule : allRules) {
EPState
浏览 15提问于2018-08-14得票数 0
1回答
我在试着解决违反路线的问题。用户将路由定义为一系列需要查看的位置序列(按确切顺序排列)。因此，让我们说正确的路由是(这是由用户定义的)
一种-> B -> C
我试着写Esper EPL，它会对所有违反路线的行为开火。A是一个起点，需要启动一个模式(一个有效的位置)。
A -> !B -> !C
当在ESPER中发现所有3种类型的事件时，这将触发。
但是我想要的是在只有部分组合的情况下也要开火，比如
A -> !B
或
!B -> !C
或
B -> !C
因为如果在B上错过了路由，那么我可能永远不会来C，也不会被通知路由违规。
这在Esper中的模式
浏览 0提问于2017-04-25得票数 0
回答已采纳
我不明白为什么我不能这样做：
select * from pattern [every A = EventA -> EventB(myFunction(A.property))]
来自Esper文档：“所有表达式都可以在过滤器中使用，包括返回布尔值的静态方法调用”。
如果我不尝试引用第一个匹配事件(EventA)中的属性，而只是尝试将属性从EventB传递给myFunction，那么它就可以正常工作。
我得到的错误是：
com.espertech.esper.client.EPException: java.lang.ArrayIndexOutOfBoundsException: 1
a
浏览 2提问于2015-11-06得票数 0
我正在使用Esser EPL Online来更深入地了解CEP引擎Esper。现在，我正在努力定义一个EPL语句，如果一个事件发生在另一个事件之前，那么它就是真的。我想使用“之前”的-Statement。 create schema A as (startts long, endts long) starttimestamp 'startts' endtimestamp 'endts'
create schema B as (startts long, endts long) starttimestamp 'startts' endtimes
浏览 16提问于2020-11-10得票数 0
1回答
寻找一种方法来计算指数移动平均超过5 EMA5和EMA20的窗口使用Esper (EPL)语句。
我有一个priceEvent (timeStamp，符号和价格)流进来，我写了一个简单的移动平均SMA在一个5的滑动窗口。但作为Esper的新手，正在寻找一种方法来计算滑动窗口上的指数移动平均(EMA)。
另外，如果有人能帮助我写抛物线SAR函数，那将是非常有帮助的
浏览 4提问于2012-12-16得票数 5
回答已采纳
我正在学习一个教程。但是当我试图编译这个项目时，它给了我以下错误：
Exception in thread "main" java.lang.NoClassDefFoundError: org/antlr/runtime/RecognizerSharedState
at com.espertech.esper.epl.generated.EsperEPL2GrammarLexer.<init>(EsperEPL2GrammarLexer.java:326)
at com.espertech.esper.epl.parse.ParseHelper.pa
浏览 3提问于2013-04-25得票数 0
回答已采纳
我们正在为我们的BI解决方案使用Esper CEP engine (基础版)。我还希望将事件持久化到Oracle。Esper有一个独立的企业产品EsperHA，它提供此功能。Esper HA是成熟的HA产品。我们只需要事件持久化，这样数据就可以直接或通过Esper被其他应用程序使用。对于EsperHA类型的功能，有没有基于java的开源实现？我找不到一个。基本上，我正在寻找基于RDBMS的时序数据库，它透明地为Esper提供事件持久性(不需要编写任何sql查询/像esper EPL中那样嵌入sql )。
浏览 1提问于2013-05-31得票数 1
1回答
我想在Esper中使用EPL查询监视应用程序是否关闭。应用程序在运行时每30秒不断发送一次心跳事件。如果在2分钟后没有接收到心跳，则可以认为应用程序已关闭。为了防止垃圾邮件，只要应用程序关闭，输出事件就应该每隔10分钟发送一次。
我非常确定可以使用Esper为此编写一个EPL查询，但我不知道这个查询应该是什么样子。
有什么想法吗？
谢谢!
浏览 1提问于2014-03-24得票数 1
1回答
我想用一个值对事件进行排序；所以我找到了eseper，但我想不出解决方案。
我从互联网上找到了一个例子，并试图对其进行定制，但失败了。
以下是我尝试过的代码。
SampleEvent.java
public class SampleEvent {
private String item = null;
private int times = 0;
public SampleEvent(String item, int times) {
super();
this.item = item;
thi
浏览 15提问于2019-07-26得票数 1
1回答
在Java Esper中，我想知道时间窗口上的计时器到底什么时候结束。换句话说，例如，在EPL语句中(取自esper主页)：
select avg(price) from org.myapp.event.OrderEvent.win:time(30 sec)
该语句将用于计算30秒内传入事件的平均价格，我想知道我是否可以知道该语句何时结束。如果我可以说运行这个语句，并且每隔30秒输出一条语句，说明30秒的摘要和整个30秒的输出，那就太好了。
我尝试使用isStopped()方法，但似乎没有帮助，除非它确实有用，而且我可能用错了它？
浏览 1提问于2012-12-15得票数 0
启用外部计时时，我们使用的Esper和Metrics报告不起作用。当我禁用外部计时时，指标又恢复工作了。
UpdateListener statsListener = this;
esper.getEpAdministrator().createEPL("select * from
com.espertech.esper.client.metric.EngineMetric",
QQQ_ENGINE_METRIC).addListener(statsListener);
esper.getEpAdministrator().createEPL("select * fr
浏览 7提问于2014-06-19得票数 0
我们可以基于某些条件在按需查询中编写update语句吗？我正在尝试执行以下查询: update istream StockEventWindow设置价格= 100 where price > 250且id = 10；
但执行语句时出现以下错误: select子句表达式类型的无效null或零元素列表update istream StockEventWindow set price = 100 where price > 250 and id = 10
我的任务是更新具有价格大于250的事件后，从时间事件收到一定的时间间隔。
如果有人能给出一个按需使用更新查询的解决方案，那就太好了。另
浏览 0提问于2016-08-09得票数 0
我使用Kafka生成器连续向Kafka主题发送CSV行，并生成以下形式的CSV行流：
temp=23.3, pressure=1015, humidity=63.4, windspeed=7.4.....
现在，我想使用ESPER在这个流上执行复杂的事件处理，但是Esper使用预定义的POJO类并使用EPL语句来过滤事件。
如何在运行时将CSV流转换为事件流，以便Esper可以根据某些逻辑提取或过滤参数，如温度或压力(例如，提取在5分钟内变化的参数)？
浏览 1提问于2018-07-24得票数 0
1回答
我正在试验Nesper (Esper的.NET版本)，遇到了一些我无法理解的麻烦。以下简单的EPL (根据本教程建模)失败，并出现错误：
select * from pattern [every (e1=SeenEvent -> e2=SeenEvent(ID=e1.ID))
where timer:within(1 min)]
我得到的错误是：
Property named 'ID' is not valid in any stream
我的第一个怀疑是ID在从Observation类派生的SeenEvent类中可能没有正确公开。但我确认在Observation类中，
浏览 1提问于2011-12-01得票数 0
我使用Esper从车流中获取车辆数，运行时间为1分钟，
它工作得很好，可以根据传感器的分组、车辆类型和方向进行计数。
它运行了一天，但在一天结束时，它给出了记忆，你能帮我们解决这个问题吗？4.我曾用@提示收回，请建议是否必须更改EPL。
信息: a) Esper版本: 6.1.0，而不是企业版
( b) JDK: 1.8
( c)操作系统: RHEL 7.0
d) EPL：
@Hint('reclaim_group_aged=60,reclaim_group_freq=5')
select max(time) as time, event_name, obj
浏览 0提问于2017-10-11得票数 0
我正在尝试用Java构建Esper语句。
为此，我使用了com.espertech.esper.client.soda库，但是我找不到一个教程来帮助我。
到目前为止，PatternExpressions是我唯一需要的部分。
举个例子，让我们使用EPL：
every a=Event((a).getEventTypeCode()='E00001')
因此，他应该用事件类型代码E00001触发每个事件，我们通过调用getEventTypeCode方法获得代码。
我怎么把这个投射给SOM？
通过以下方式：
PatternExpr pattern = Patterns.everyFilt
浏览 0提问于2014-07-29得票数 0
回答已采纳
2回答
我使用Esper根据激发的esper查询生成警报消息。
我使用Map作为java对象来绑定所有日志消息，这是在外部esper文件中定义的，如下所示。
<?xml version="1.0" encoding="UTF-8"?>
<esper-configuration xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://www.espertech.com/schema/esper"
xsi:schemaLocation="
浏览 0提问于2013-11-26得票数 0
回答已采纳
如何在Esper中将重叠的翻滚窗口定义为EPL查询？我正在寻找与跳跃窗口类似的等价物： https://docs.microsoft.com/en-us/stream-analytics-query/hopping-window-azure-stream-analytics 例如:1秒跳频窗口，重叠500ms。 Esper的参考手册描述了tumbling windows和重叠上下文，但我如何将其表示为查询？ 谢谢。
浏览 13提问于2019-01-11得票数 0
回答已采纳
1回答
下面是我们的Esper EPL语句：
insert rstream into SelectedFieldsStream
select rstream feedId as feedId
, data.inputEvents.inputEventCount as inputCounts
, data.inputEvents.inputEvent[1].name as inputName
, data.inputEvents.inputEvent[1].count as inputCount
from
浏览 0提问于2013-06-02得票数 0
回答已采纳
1回答
我是NEsper/Esper的新手。我想要捕捉当两个事件发生少于3秒时的事件，换句话说，当两个事件之间的时间戳差小于3秒时。如何定义EPL语句？例如，事件是一个记号(它包含属性-符号、价格和时间戳)。当前一次滴答后不到3秒出现滴答时，应捕获第二次滴答。如何编写EPL语句"select * from StockTick(symbol='anySymbol')...."？提前谢谢。纳尔苏
浏览 26提问于2020-10-06得票数 0
我有一个元组：
public class mytuple
{
private int status;
private int userid;
private int location;
private int count1;
private int count2;
// corresponding getter settrs included.
}
我创建了两个esper语句EPL：
select mytuple.userid as userid, sum(count1) as count1, sum(count2) as count2
f
浏览 2提问于2013-08-10得票数 0
我目前正在努力使一些Esper EPL查询工作。查询如下所示：
select a.center.distance(b.center) as delta
from pattern [
every-distinct(a.id, b.id) (
a=org.example.PositionEvent -> b=org.example.PositionEvent
)
]
当我试图通过EPLStatement将其编译成EPAdministrator.createEPL()时，它会抛出以下异常：
com.espertech.esper.client.EPStateme
浏览 1提问于2011-02-08得票数 1
回答已采纳
1回答
我想使用Esper处理以下JSON消息：
{
"firstname":"John",
"lastname":"Do",
"address":[{"street":"Maplestreet","number":100,"city":"New York"}]
}
声明事件类型模式的正确方法是什么？有人能帮我为EPL在线构建正确的：create schema ();语句吗？谢谢!
浏览 2提问于2016-11-05得票数 0
回答已采纳
1回答
我正在从事一个项目，其中有一个连续的事件流。有许多并发用户可以创建/更新/删除规则，并在流与这些规则匹配时收到警报。
为此，我使用了Esper，我从规则动态生成EPL语句并注册它们。这是非常容易出错的，因为规则有时很复杂，并且不能动态地转换为EPL。这也是不可伸缩的。
处理这个问题的正确方法是什么？对于这种用例，有没有标准的方法/库？
谢谢
浏览 1提问于2018-05-14得票数 0
1回答
我是Esper的新手。我需要帮助来维护EPL流。我有一个java类EsperTest.java，该类将数据发送给EPL，以便在每10 Sec中进行计算。
在EPL的中，我有4个压缩级别。例如CompressionA，CompressionB，CompressionC，CompressionD。在每次压缩中，我们根据一些字段执行分组。
在完成了对'CompressionACompleted'.的计算之后，我们引发了一个事件，即CompressionA在'CompressionACompleted'，的基础上，对CompressionB进行了计算。在完成了对'
浏览 3提问于2017-03-22得票数 0
1回答
目前，我正在尝试用Java将几个EPL语句与Esper CEP 8结合起来。当我在EPCompile中读到单个EPLs时，它们都像打开一样工作。例如： String EPL1 ="@name('EPA12') select * from IEvent where j>3;\n"; 但是当我试图一次读取多个EPL操作时，只考虑第一个操作。例如，如果我尝试下面的语句，它只检查j>3，而CEP打印它的所有事件。但未选中i>4 (EPA13)。 String EPLnotworking ="@name('EPA12') ins
浏览 20提问于2018-12-22得票数 0
我正在尝试使用esper创建一个epl语句来监控响应时间，如下所示：
SELECT QUEUENAME, count(latency>1000) AS NUMBER_OF_SLA_BREACHES, COUNT(latency) AS TOTALS FROM ResponseWindow GROUP BY QUEUENAME
。。然而，两个count()给出了相同的结果，这是不正确的。
感谢您帮助更正此查询！
浏览 1提问于2015-08-01得票数 0
我使用的是Esper (事件处理引擎)，EPL查询是：
select * from Event.ext:time_order(timestamp_event, 10000 minutes) where duration > 10
但输出不是按“timestamp_event”排序的：
id int = 1, timestamp_event= 1412686800000, duration = 30
id int = 4, timestamp_event= 1412685900000, duration = 70
id int = 2, timestamp_event= 141268860
浏览 5提问于2014-10-11得票数 0
1回答
Esper的可选值
、、、
Esper中是否支持具有可选值的属性？
我正在使用Esper和Scala构建一个POC，并且让EPL查询处理非可选的值。我有一个用来测试的简单对象：
case class EsperEvent(@BeanProperty id: Int, @BeanProperty eventtype: Int)
并且可以通过以下查询获得我预期的结果：
select * from EsperEvent
match_recognize (
measures A as event1, B as event2
pattern (A B)
define
A as A.eventtype
浏览 12提问于2018-08-23得票数 1
回答已采纳
在我们现有的应用程序中，我们使用Esper版本5.3。我们添加了一些addPlugInSingleRowFunction()来在EPL中使用它，如下所示--
最终配置cepConfiguration.addPlugInSingleRowFunction("toNumber"，= cepConfiguration.addPlugInSingleRowFunction("toBoolean"，cepConfiguration ()；最终配置Double.class.getName()，"parseDouble")；最终配置Boolean.class.
浏览 0提问于2020-06-01得票数 0
我想聚合一天中每一个小时的传感器值。时间信息来自事件流中的时间戳。为此，我创建了四个EPL语句：
第一个语句声明了一个上下文，该上下文通过sensorId对事件进行分区。
第二条语句检测特定传感器的事件流中的一天小时变化，并在事件发生时发送事件。
第三个语句是一个上下文声明，它通过sensorId和hourOfDay对事件进行分区。上下文的生存期由第二条语句发布的事件控制。
最后一条语句使用在语句#3中创建的上下文，并计算传感器值的总和。
我每2-6秒收到大约300个感应器的信息。我在一个堆大小为8GB的java应用程序中嵌入了esper 6.1.0。大约15分钟后，内
浏览 2提问于2017-09-11得票数 1
回答已采纳
我使用的是esper，当我用timer:interval(10秒)查询我的命名窗口时，我每隔10秒就会得到相同的事件。我不会输出窗口中出现的其他事件。
这是EPL on patternevery计时器:间隔(20秒) select DeviceIP，parent，child，Supress，Status from testZabbixProblem“
浏览 1提问于2014-10-20得票数 0
我对这项技术非常陌生，我需要能够准确地按顺序检测发生的事件。例如:a -> b -> c根据这些事件输出事件a -> b -> d ->…-> C将不会基于这些事件输出事件，因为a、b和C事件不是按顺序排列的。
是否可以使用ESPER EPL语句。
感谢您的帮助
浏览 0提问于2019-10-08得票数 0
我正在尝试实现一个EPL查询，它可以获取时间(T)&时间(t-1)的avg。
例如，：
( a)在前5秒(秒0-5)中，有2个事件的avg为12。
( b)在接下来的5秒(秒5-10)中，有3个事件的avg为23，在捕获此信息的EPL查询中，我还可以从前5秒的前一个时间窗口中看到12的avg。
我的想法是将对象/查询错开，使最终的epl查询具有时间(T)&时间(t-1)的快照，就像在虚拟创建的对象ScoreInfoBeforeAfter中看到的那样。但是它不起作用。
任何想法都将不胜感激。谢谢。
// The object being published to the Esp
浏览 3提问于2010-10-26得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
