这是一个IT事件爆发的时代，各种IT系统之间或系统内部，每天产生大量事件。系统在关键点打日志、系统之间交流信息，都是事件。但我们对这些事件往往视而不见，当成垃圾一股脑儿全扔了。其实只要处理得当，垃圾也可以变成资源。
复合事件处理（CEP，Complex Event Processing）是一种基于动态环境中事件流的分析技术，事件在这里通常是有意义的状态变化，通过分析事件间的关系，利用过滤、关联、聚合等技术，根据事件间的时序关系和聚合关系制定检测规则，持续地从事件流中查询出符合要求的事件序列，最终分析得到更复杂的复合事件，主要用于网络诈欺识别等防止犯罪，银行等金融行业防止，以及风险规避和营销决策等。
首先，CEP是一种框架。和其他框架一样，它也提供了一套流程或一种标准。CEP提供的则是一套处理复合事件（complex event)的流程。其次，CEP的特点和核心能力在于可以便捷地处理复合事件。CEP之所以有这样的能力，是由于它可以处理多输入对多输出的映射关系，“复合(complex)”也正是相对于传统的单一输入和单一输出而言的。CEP多个输入之间的关系可以是独立的，也可以是相关的，它的多个输出亦是如此。举个例子：
输入：
判断模块得出结论：即将下雨
输出：
最后，CEP天然拥有强大的可扩展性（Scalability）。因为输出可以很方便的转化为下一个系统的输入，所以可以用串联、级联等多种方式连接不同的CEP系统，从而组合成一个复合系统，以应对复杂的业务需求。
复合事件处理过程包括：
复合事件处理系统中的关键模块：
此外，CEP系统的辅助工具有：
事件应该包含一些基本的要素：类型、发生事件以及更多的一些定义属性。通常需要关联多个事件进行分析处理，其中事件间的关系主要有5种：
复合事件处理面临的挑战：
CEP 依赖下面的一组技术：
事件处理语言（EPL，Event processing language）用于系统中制定和查询感兴趣的事件序列，通常是类SQL的语句，从SQL语句中扩展而来。
相关开源项目：
实时计算也是一种框架，负责提供低延迟的计算服务，这样就给人一种“实时”的感觉，它本身并不关心被计算的是什么。大部分实时计算框架采用了流式(stream)计算的方法，是因为该方法可以很好地满足实时计算的设计需求。CEP和实时计算其实是属于两个不同领域的框架，但两者在业务和具体实现的需求下，紧密地结合到了一起。CEP只是提供了一种处理复合事件的框架，并没有对时效性做严格要求。我们也可以用传统技术实现CEP系统，只不过从事件发生到结果获取，再到采取行动，中间的延迟很大。而我们通常希望降低这种延迟，来获取更大的业务价值。实时计算恰恰提供了一种低延迟的计算服务，所以多数CEP系统在实现其计算模块时采用了实时计算的技术。
再者，如同前面提到的，CEP较佳的设计模式是管线架构设计。这种设计可以让事件像水一样流过各个处理模块，它和实时计算的流式计算非常相似。基于这个共同点，CEP和实时计算紧密地结合在一起。总的来说，我感觉两者的关系是：实时计算提供了一种底层的计算服务，CEP可以架构其上。
实时营销
异常检测（事后回溯->提前干预）
The post 复合事件处理CEP简介 appeared first on 标点符.
Related posts: