问题标签 [wso2cep]

我正在尝试做一个简单的查询，但有两个时间窗口；该查询类似于尝试向在过去四个月内访问过网络产品两次以上的用户发送消息，前提是您已在上个月发送了该产品的广告。

并将继续？

当我将参数传递给我的自定义函数并且我想获取它时，我需要这样做：

但是当我有 30 个参数时，我需要重复这个过程近 30 次，当我的输入参数发生变化时，我也必须更改索引。所以我的问题是，是否可以通过他们的名字在 Custom Fuc​​ntion 中获取参数？比如这样：

类似的东西在 Transformer 中可用，但在 Function 中可能吗？

我们试图实现每小时事件计数的时间序列。我们想在 CEP 中进行每小时计数并将输出存储在数据存储/nosql 中。缺少的是我们想要存储的是某一天每小时的计数。

为此，我们需要在每次时间批处理窗口到期时从 CEP 输出当前时间戳。

有人可以解释如何使用 WSO2 CEP 实现这一目标吗？

谢谢 反相

我有一个 userStreamusername,ipaddress,timestamp

我想将此详细信息存储在UserDetailsTable（内存表中）并需要执行upsert。如果用户名和 ipaddress 相同，我怎么能更新该行，否则作为新行插入。

例如：

UserDetailsTable 的结果如下

在 (CEP) WSO2 Adapter 中，登录名和密码必须这样写：

是否可以对登录名和密码进行编码，而不是 admin/admin 编写编码参数，例如 MD5 或其他？

我有一个 userStreamname,address,status

我想将此详细信息存储在UserDetailsTable（内存表中）

UserDetailsTable 的结果如下

我还有另一个triggerStream名字，triggerStatus

案例1） 当triggerStream作为“Rockey”出现时，我想UserDetailsTable根据（名称和triggerStatus）加入这个triggerStream并从UserDetailsTable中删除该行。

案例2）当triggerStream作为“Jose”出现时，我想根据（名称和triggerStatus）加入这个triggerStream并在UserDetailsTable中将状态更新为“true”。UserDetailsTable

UserDetailsTable 的最终状态如下。

怎么能用 WSO2 CEP 做到这一点？

我需要在 Wso2 CEP (3.1.0) 中添加新用户，我知道这可以通过在控制台中“单击”几个步骤（文档中的示例）来实现。我想知道是否可以在不登录控制台的情况下添加新用户，但连接到 H2 数据库并在那里插入用户？

我知道新用户已保存到“UM_USER”表中。也许有人知道什么类将用户写入 H2，密码是如何加密的，什么是“UM_SALT_VALUE”以及我为什么需要它？

我正在尝试实现与 WS02 CEP 的 Solace 消息传递系统集成。

是否存在任何直接连接集成？或者我可以使用单独的层（Active MQ）来集成这两者吗？如果可能的话，请您与我们分享任何文件。

我有一个场景，其中我有 MQTT 发布者。

MQTT 客户端 --> 消息代理 --> WSO2 CEP（JMS 输入适配器）

我可以通过哪些方式将此已发布的 MQTT 消息作为 WSO2 CEP 的输入？

我尝试使用 ActiveMQ 作为消息代理和 CEP JMS 输入适配器来侦听 JMS 消息，但 ActiveMQ 将 MQTT 消息转换为 ByteMessage，我相信 CEP 目前还没有处理它，因为在同一设置中发布的 JMS 消息工作正常。
我知道 WSO2 CEP 4.0.0 具有 MQTT 输入适配器的功能。如何在 CEP 3.1.0 中处理它？

目前我热衷于寻找开源实体服务总线（ESB）来构建架构。我在上面搜索，发现 WSO2 ESB 很好。在所有 WSO2 相关产品中，只有 WSO2 ESB 产品已经过基准测试。我不知道剩余产品性能。我想获得有关实时世界中最新 ESB 性能的建议。