wso2 - 将 WSO2 CEP Siddhi 事件聚合到单个 json 对象

Question

我正在尝试构建一个执行计划，将不同的事件聚合为一个并计算发生次数（CurrentEventId）。该计划如下所示：

define stream inStream (correlation_EventName string, LastEventId int, CurrentEventId int);

partition with (CurrentEventId of inStream)
begin

    from inStream#window.timeBatch(10 sec)
    select correlation_EventName as meta_Label, CurrentEventId as meta_Id, LastEventId as correlation_From, CurrentEventId as correlation_To, count(CurrentEventId) as correlation_Value
    insert into outStream

end;

实际上，我有以下输出：

Event: {"event":{"metaData":{"Label":"StartCalculationEvent","Id":2},"correlationData":{"From":2,"To":2,"Value":66}}}
Event: {"event":{"metaData":{"Label":"LoginEvent","Id":1},"correlationData":{"From":1,"To":1,"Value":693}}}

我每 10 秒只需要一个事件，而不是多个事件。此事件应具有以下格式：

[
    {
        "event":{"metaData":"..."}
    },
    {
        "event":{"metaData":"..."}
    }
]

你知道如何实现这一点吗？

Answer 1

使用 siddhi 分区，将为每个分区变量（在本例中为 ）生成单独的事件CurrentEventId。由于您有两个 CurrentEventId，因此您会在 outStream 中接收两个事件。如果有三个 CurrentEventId，您将分别收到 3 个事件。

截至目前，无法按照您的要求在 siddhi 中批处理事件。有一个相关的Jira，它与您期望的功能相似。