[发明专利]一种业务日志数据访问与统计分析的方法及装置

摘要

本发明涉及一种业务日志数据访问与统计分析的方法及装置，其中装置包括业务系统模块、业务事件总线模块和多个对应的统计分析模块；其中方法包括以下步骤A、将统计分析模块注册到业务事件总线模块，完成统计分析模块对业务日志的订阅；B、业务系统处理业务请求后，将处理的结果生成业务日志并发布到业务事件总线模块，完成业务日志的发布；C、当业务事件总线模块中有新发布的业务日志时，通知所有注册的统计分析模块；D、统计分析模块主动订阅业务日志，并将其实时处理成统计数据。与现有技术相比，本发明具有支持实时的复杂更新查询和减小系统性能损耗等优点。

主权项

一种业务日志数据访问与统计分析的方法，其特征在于，该方法包括以下步骤：A、将统计分析模块注册到业务事件总线模块，完成统计分析模块对业务日志的订阅；B、业务系统处理业务请求后，将处理的结果生成业务日志并发布到业务事件总线模块，完成业务日志的发布；C、当业务事件总线模块中有新发布的业务日志时，通知所有注册的统计分析模块；D、统计分析模块主动订阅业务日志，并将其实时处理成统计数据；所述统计分析模块包括实时计算子系统、历史统计结果缓存子系统和统计信息持久化子系统，所述实时计算子系统与历史统计结果缓存子系统建立双向数据连接，所述历史统计结果缓存子系统与统计信息持久化子系统建立双向数据连接；所述实时计算子系统负责计算处理新获取到的业务日志，并将处理后的结果与历史统计结果合并生成最新的统计分析结果，所述历史统计结果缓存子系统负责缓存已处理过的统计数据，所述统计信息持久化子系统负责持久化已处理过的统计数据；所述步骤D中对业务日志的实时处理包括统计处理过程和分析处理过程；所述统计处理过程包括以下步骤：D11)实时计算子系统将新获取到的业务日志进行计算处理，结果发送给历史统计结果缓存子系统；D12)历史统计结果缓存子系统将处理后的结果缓存后，并通知统计信息持久化子系统持久化最新处理后的统计结果；D13)统计信息持久化子系统将实时处理后的统计结果进行持久化处理；所述分析处理过程包括以下步骤：D21)历史统计结果缓存子系统从统计信息持久化子系统中加载统计结果到缓存中；D22)实时计算子系统从历史统计结果缓存子系统中获取历史统计结果数据；D23)实时计算子系统计算处理实时获取到的业务日志，并将实时计算的结果与历史结果数据进行合并生成最终的分析报表数据后返回给上层。