流式数据处理方法、装置、计算机设备及存储介质.pdf

本申请涉及大数据处理技术领域,特别是涉及一种流式数据处理方法、装置、计算机设备、存储介质和计算机程序产品。所述方法包括:从规则组件中确定出目标作业处理所需的目标规则组件,所述规则组件为不同的流式事件处理规则代码的抽象表示;从基础组件中确定出目标作业处理所需的目标基础组件,所述基础组件为不同作业处理中通用的功能模块;确定所述目标规则组件以及所述目标基础组件之间的逻辑关系,根据所述逻辑关系生成事件链路;根据所述事件链路生成目标代码,所述目标代码用于处理目标作业,所述目标代码由预先封装的不同流式事件处理规则代码编译而成。采用本方法能够能够提高流式数据处理所用代码的开发效率,降低代码开发学习成本。