基于CEP能否实现复杂模式事件关联及乱序、不完整序列匹配？

完全可以实现指定场景的匹配输出，核心是调整原有默认的严格顺序绑定的CEP模式规则，具体优化点如下：

• 替换默认的严格followedBy约束为松弛连续匹配，允许目标序列中间插入不属于当前匹配链路的其他事件，避免a1、b1之间插入a2时打断原有匹配链路
• 新增业务链路唯一标识绑定规则，给每个a/b/c事件加上同链路共用的trace_id类关联字段，模式匹配时强制校验a.trace_id = b.trace_id = c.trace_id，从逻辑上避免不同链路的事件乱序绑定
• 切换事件时间语义并配置匹配窗口，使用事件实际发生的event_time替代事件到达时间作为时间判断标准，给a->b->c的完整匹配逻辑配置合理的滑动/滚动窗口，允许乱序事件在窗口内到达后再完成匹配
• 开启完整序列输出配置，设置仅当a、b、c三个事件全部匹配完成时才输出结果，窗口关闭后自动丢弃缺少b或c的不完整链路，避免无效链路打断全局匹配

如果使用Flink CEP框架，参考配置代码如下：

Pattern<Event, ?> abcPattern = Pattern.<Event>begin("a")
    .where(event -> event.getEventType().equals("a"))
    .followedBy("b")
    .where(event -> event.getEventType().equals("b"))
    .where((bEvent, context) -> bEvent.getTraceId().equals(context.getEventsForPattern("a").get(0).getTraceId()))
    // 允许中间插入其他事件
    .allowCombinations()
    .followedBy("c")
    .where(event -> event.getEventType().equals("c"))
    .where((cEvent, context) -> cEvent.getTraceId().equals(context.getEventsForPattern("a").get(0).getTraceId()))
    .allowCombinations()
    // 配置10分钟匹配窗口，可根据业务场景调整
    .within(Time.minutes(10));

以上配置针对示例输入{a1,b1,a2,c1,b2,a3,b3,c3}，会自动过滤缺少c的链路2，正确输出两个完整匹配序列{a1,b1,c1}、{a3,b3,c3}。

内容的提问来源于stack exchange，提问作者IsidIoan