流处理系统中的事件处理方法及流处理系统

摘要

本发明实施例提供一种流处理系统中的事件处理方法及流处理系统，该方法包括，将基础事件与规则引擎中匹配模式对应的引擎内存中存储的基础事件进行匹配，确定包括基础事件的引擎内存；若确定包括基础事件的引擎内存为全环模式对应的引擎内存，则将基础事件输入规则引擎的全环模式，在基础事件中增加全环标识，将增加全环标识的基础事件作为全环匹配结果，并执行基础事件获得执行结果，根据执行结果修改全环模式对应的引擎内存中目标对象的属性信息，并将执行结果与规则引擎中各引擎内存中存储的基础事件进行匹配。实现了采用规则引擎的不同匹配模式对复杂事件进行分类处理，从而提高了ESP业务处理过程中复杂事件的处理性能。

主权项

一种流处理系统中的事件处理方法，其特征在于，所述流处理系统包括：输入单元和规则引擎，所述规则引擎的匹配模式至少包括全环模式、半环模式和无环模式，所述规则引擎的每个匹配模式对应一个引擎内存，各所述引擎内存中存储至少一个基础事件，所述方法包括：通过所述输入单元获取用于表征目标对象状态的至少一个基础事件，所述基础事件包括条件或所述目标对象的属性信息中的至少一个；将所述基础事件与所述规则引擎中匹配模式对应的引擎内存中存储的基础事件进行匹配，确定包括所述基础事件的引擎内存；若确定包括所述基础事件的引擎内存为全环模式对应的引擎内存，则将所述基础事件输入所述规则引擎的全环模式，在所述基础事件中增加全环标识，将增加全环标识的基础事件作为全环匹配结果，并执行所述基础事件获得执行结果，根据所述执行结果修改所述全环模式对应的引擎内存中所述目标对象的属性信息，并将所述执行结果与所述规则引擎中各引擎内存中存储的基础事件进行匹配；若确定包括所述基础事件的引擎内存为半环模式对应的引擎内存，则将所述基础事件输入所述规则引擎的半环模式，在所述基础事件中增加半环标识，将增加半环标识的基础事件作为半环匹配结果，并执行所述基础事件获得执行结果，根据所述执行结果修改所述半环模式对应的引擎内存中所述目标对象的属性信息，并输出所述执行结果；若确定包括所述基础事件的引擎内存为无环模式对应的引擎内存，则将所述基础事件输入所述规则引擎的无环模式，在所述基础事件中增加无环标识，将增加无环标识的基础事件作为无环匹配结果，并执行所述基础事件，获得执行结果，并输出所述执行结果。