cep

0热度

1回答

warnings.print（）打印以相反的顺序事件（最后的情况下第一）节选第一事件中的Apache弗林克CEP

我想筛选是>在弗林克10使用以下图案中的所有临时事件， Pattern<MonitoringEvent, ?> warningPattern = Pattern.<MonitoringEvent>begin("first") .subtype(TemperatureEvent.class) .where(new FilterFunction<TemperatureE

1热度

2回答

我选择哪种开源CEP应用于分布式和流水线处理; siddhi，Flink，Esper？

我对siddhi cep很少有兴趣，因为它具有siddhi查询语言，但它使用storm进行分布式处理，WSO2提供了一个Web界面/仪表板来创建和部署应用程序。我认为这会降低我独立性来增强/使用某些功能。 Flink另一方面似乎是不错的选择，但它需要很多代码来实现简单的逻辑。难道还有比这更好的选择，我困惑

1热度

1回答

FIWARE Cepheus通用配置

我打算使用Cepheus来允许用户创建Orion实体之间的关系。问题是只有一个配置文件。因此，很难创建几个CEP（在同一个租户内）。例如，假设我想创建地板的平均温度，并关闭百叶窗（请参阅示例http://fiware-cepheus.readthedocs.io/en/latest/examples/2_CloseShutters/index.html）。订阅配置文件中的所有实体/属性是否可能

0热度

1回答

在Cumulocity实时通知中使用“建议”

根据http://cumulocity.com/guides/reference/real-time-notifications/，启动用于接收实时通知的握手的客户端可以在其请求主体中包含建议。这个建议可以有一个超时（“以毫秒为单位最大时间一个连接消息，并从服务器响应的发送之间。”）和间隔（“期间，高于该服务器将关闭会话，如果没有接收到下一个从连接消息客户。”）。我不明白这些参数以及它们如何适用于

1热度

1回答

错误仙王星经纪不转发更新到仙王座CEP

我使用Cepheus GE为我的用例，我启用它在多租户模式，并上传我的config.json文件，但当我开始发送更新到仙王座经纪人的顺序为了将它们转发给CEP，Cepheus经纪人只收到更新，但不会将它们转发给Cepheus上限，因为它无法识别在config.json中设置的服务和服务路径。当我试图将我的更新直接发送到Cepheus-CEP时，它接受并成功处理了它们。所以我想知道为什么Cepheu

0热度

1回答

来自具有时间和长度的Esper窗口的最后一个事件

我试图从time_length_batch中获取最后一个事件，但我无法在WRT中如何执行此操作。例如...有一个库存事件，并希望从每个可用产品获取最新更新。下面的查询主要提供所需要的： SELECT product, inventory FROM InventoryEvents.std:groupwin(name).win:time_length_batch(1 min, 2); 除了窗口

0热度

1回答

在滑动窗口的最大选择事件

我有这样的流： define stream locationStream (cell string, device string, power long); 我想在此流中进行选择，以10秒的滑动窗口，对于每一个设备，在“单元格的值'权力'是最大的属性。我应该用什么查询来获得Siddhi的结果？像 from locationStream#window.time(10 seconds) sel

1热度

1回答

如何删除cumulocity中的实时模块？

要删除现有模块，文档（http://cumulocity.com/guides/reference/real-time-statements/）表示要对/cep/module/<<moduleId>>执行删除请求。但是这会导致响应状态500，原因是“请求方法”DELETE'不受支持“。删除单个模块的正确请求是什么？

0热度

1回答

Esper链 - 重复一次后续模式n次？

是否有可能连续重复一次跟随模式n次？我想实现的是这种模式： every a=A -> b=B(b.price < a.price) -> c=C(c.price < b.price) -> d=D(d.price < c.price) -> e=E(e.price < d.price) -> f=F(f.price < e.price) -> g=G(g.price < f.pric

0热度

1回答

CEP问题，而检查点。“找不到ID为条目”

检查点时打开一个简单的CEP环形图案 private Pattern<Tuple2<Integer, SimpleBinaryEvent>, ?> alertPattern = Pattern.<Tuple2<Integer, SimpleBinaryEvent>>begin("start").where(checkStatusOn) .followedBy("middle").whe