基于流计算的事件处理方法和装置

摘要

本发明公开了一种基于流计算的事件处理方法和装置。其中，该方法包括：通过流计算引擎处理第一条事件记录，得到第一处理结果；将第一处理结果存储到局部完整性存储区中，其中，局部完整性存储区用于存储事件的处理结果；通过流计算引擎处理第二条事件记录，得到第二处理结果，其中，第二条事件记录与第一条事件记录之间存在关联关系；从局部完整性存储区中获取第一处理结果，并根据第一处理结果和第二处理结果计算得到事件处理结果。本发明解决了无法实现跨多条事件的条件计算，导致存在关联性的多条事件处理结果不准确的技术问题。

主权项

一种基于流计算的事件处理方法，其特征在于，包括：通过流计算引擎处理第一条事件记录，得到第一处理结果；将所述第一处理结果存储到局部完整性存储区中，其中，所述局部完整性存储区用于存储事件的处理结果；通过所述流计算引擎处理第二条事件记录，得到第二处理结果，其中，所述第二条事件记录与所述第一条事件记录之间存在关联关系；从所述局部完整性存储区中获取所述第一处理结果，并根据所述第一处理结果和所述第二处理结果计算得到事件处理结果。